9 "google.golang.org/grpc"
11 test "github.com/go-kit/kit/transport/grpc/_grpc_test"
12 "github.com/go-kit/kit/transport/grpc/_grpc_test/pb"
16 hostPort string = "localhost:8002"
19 func TestGRPCClient(t *testing.T) {
21 server = grpc.NewServer()
22 service = test.NewService()
25 sc, err := net.Listen("tcp", hostPort)
27 t.Fatalf("unable to listen: %+v", err)
29 defer server.GracefulStop()
32 pb.RegisterTestServer(server, test.NewBinding(service))
36 cc, err := grpc.Dial(hostPort, grpc.WithInsecure())
38 t.Fatalf("unable to Dial: %+v", err)
41 client := test.NewClient(cc)
44 a = "the answer to life the universe and everything"
47 ctx = test.SetCorrelationID(context.Background(), cID)
50 responseCTX, v, err := client.Test(ctx, a, b)
52 t.Fatalf("unable to Test: %+v", err)
54 if want, have := fmt.Sprintf("%s = %d", a, b), v; want != have {
55 t.Fatalf("want %q, have %q", want, have)
58 if want, have := cID, test.GetConsumedCorrelationID(responseCTX); want != have {
59 t.Fatalf("want %q, have %q", want, have)