e2e: add gRPC gateway Lease tests

e2e/util.go

@@ -15,7 +15,10 @@
 package e2e
 
 import (
+	"encoding/json"
 	"fmt"
+	"math/rand"
+	"path"
 	"strings"
 	"time"
 
@@ -77,6 +80,29 @@ func spawnWithExpectLines(args []string, xs ...string) ([]string, error) {
 	return lines, perr
 }
 
+func cURLWithExpected(cx ctlCtx, tests []v3cURLTest) error {
+	p := cx.apiPrefix
+	for _, t := range tests {
+		value := fmt.Sprintf("%v", t.value)
+		if err := cURLPost(cx.epc, cURLReq{endpoint: path.Join(p, t.endpoint), value: value, expected: t.expected}); err != nil {
+			return fmt.Errorf("prefix (%s) endpoint (%s): error (%v), wanted %v", p, t.endpoint, err, t.expected)
+		}
+	}
+	return nil
+}
+
+func randomLeaseID() int64 {
+	return rand.New(rand.NewSource(time.Now().UnixNano())).Int63()
+}
+
+func dataMarshal(data interface{}) (pbm string, e error) {
+	m, err := json.Marshal(data)
+	if err != nil {
+		return "", err
+	}
+	return string(m), nil
+}
+
 func closeWithTimeout(p *expect.ExpectProcess, d time.Duration) error {
 	errc := make(chan error, 1)
 	go func() { errc <- p.Close() }()