gRPC Reflection Client

code.go

func TestRunReflection(t *testing.T) {
  var cc *grpc.ClientConn
	var opts []grpc.DialOption
	var mtd *desc.MethodDescriptor

	opts = append(opts, grpc.WithInsecure())

	dialCtx := context.Background()
	cc, err = grpc.DialContext(dialCtx, "host", opts...)
	if err != nil {
		assert.FailNow(t, err.Error())
	}

	refCtx := context.Background()
	refClient := grpcreflect.NewClient(refCtx, reflectpb.NewServerReflectionClient(cc))

	mtd, err = protodesc.GetMethodDescFromReflect("helloworld.Greeter.SayHello", refClient)
	if err != nil {
		assert.FailNow(t, err.Error())
	}

	stub := grpcdynamic.NewStub(cc)

	var input *dynamic.Message

	md := mtd.GetInputType()
	input = dynamic.NewMessage(md)
	err = jsonpb.UnmarshalString(`{"name":"Bob"}`, input)
	if err != nil {
		assert.FailNow(t, err.Error())
	}

	ctx := context.Background()
	ctx, cancel := context.WithCancel(ctx)
	defer cancel()

	res, err := stub.InvokeRpc(ctx, mtd, input)
	if err != nil {
		assert.FailNow(t, err.Error())
	}

	fmt.Printf("%+v\n\n", res)
	assert.False(t, true)
}