From 9630e153a535f0eee4cf9a8c89188d7098a77a1d Mon Sep 17 00:00:00 2001 From: Asim Aslam Date: Thu, 27 Jun 2019 13:08:06 +0100 Subject: [PATCH] fix grpc proto wrapper --- client/grpc/grpc.go | 2 +- network/router/options.go | 2 +- server/grpc/grpc.go | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/client/grpc/grpc.go b/client/grpc/grpc.go index b067d826..9a1843bc 100644 --- a/client/grpc/grpc.go +++ b/client/grpc/grpc.go @@ -33,7 +33,7 @@ type grpcClient struct { func init() { encoding.RegisterCodec(wrapCodec{jsonCodec{}}) - encoding.RegisterCodec(wrapCodec{jsonCodec{}}) + encoding.RegisterCodec(wrapCodec{protoCodec{}}) encoding.RegisterCodec(wrapCodec{bytesCodec{}}) } diff --git a/network/router/options.go b/network/router/options.go index 9c5581d4..0d525f76 100644 --- a/network/router/options.go +++ b/network/router/options.go @@ -67,6 +67,6 @@ func DefaultOptions() Options { Address: DefaultAddress, Registry: registry.DefaultRegistry, Table: NewTable(), - Network: "local", + Network: "local", } } diff --git a/server/grpc/grpc.go b/server/grpc/grpc.go index 2f6e1d40..4ff4b79f 100644 --- a/server/grpc/grpc.go +++ b/server/grpc/grpc.go @@ -56,8 +56,8 @@ type grpcServer struct { } func init() { - encoding.RegisterCodec(wrapCodec{protoCodec{}}) encoding.RegisterCodec(wrapCodec{jsonCodec{}}) + encoding.RegisterCodec(wrapCodec{protoCodec{}}) encoding.RegisterCodec(wrapCodec{bytesCodec{}}) }