grpcshim

Feb 14, 2020

Changes in this version

+ type ClientConn interface

+ Close func() error

+ type ClientConnShim struct

+ ClientConn *grpc.ClientConn

+ func (c *ClientConnShim) Close() error

+ type Grpc interface

+ Code func(err error) codes.Code

+ Creds func(c credentials.TransportCredentials) grpc.ServerOption

+ CustomCodec func(codec grpc.Codec) grpc.ServerOption

+ Dial func(target string, opts ...grpc.DialOption) (ClientConn, error)

+ DialContext func(ctx context.Context, target string, opts ...grpc.DialOption) (conn *grpc.ClientConn, err error)

+ ErrorDesc func(err error) string

+ Errorf func(c codes.Code, format string, a ...interface{}) error

+ FailFast func(failFast bool) grpc.CallOption

+ FailOnNonTempDialError func(f bool) grpc.DialOption

+ Header func(md *metadata.MD) grpc.CallOption

+ InTapHandle func(h tap.ServerInHandle) grpc.ServerOption

+ Invoke func(ctx context.Context, method string, args, reply interface{}, ...) error

+ MaxConcurrentStreams func(n uint32) grpc.ServerOption

+ MaxMsgSize func(m int) grpc.ServerOption

+ NewClientStream func(ctx context.Context, desc *grpc.StreamDesc, cc *grpc.ClientConn, method string, ...) (_ grpc.ClientStream, err error)

+ NewGZIPCompressor func() grpc.Compressor

+ NewGZIPDecompressor func() grpc.Decompressor

+ NewServer func(opt ...grpc.ServerOption) *grpc.Server

+ RPCCompressor func(cp grpc.Compressor) grpc.ServerOption

+ RPCDecompressor func(dc grpc.Decompressor) grpc.ServerOption

+ RoundRobin func(r naming.Resolver) grpc.Balancer

+ SendHeader func(ctx context.Context, md metadata.MD) error

+ SetHeader func(ctx context.Context, md metadata.MD) error

+ SetTrailer func(ctx context.Context, md metadata.MD) error

+ StatsHandler func(h stats.Handler) grpc.ServerOption

+ StreamInterceptor func(i grpc.StreamServerInterceptor) grpc.ServerOption

+ Trailer func(md *metadata.MD) grpc.CallOption

+ UnaryInterceptor func(i grpc.UnaryServerInterceptor) grpc.ServerOption

+ WithBackoffConfig func(b grpc.BackoffConfig) grpc.DialOption

+ WithBackoffMaxDelay func(md time.Duration) grpc.DialOption

+ WithBalancer func(b grpc.Balancer) grpc.DialOption

+ WithBlock func() grpc.DialOption

+ WithCodec func(c grpc.Codec) grpc.DialOption

+ WithCompressor func(cp grpc.Compressor) grpc.DialOption

+ WithDecompressor func(dc grpc.Decompressor) grpc.DialOption

+ WithDialer func(f func(string, time.Duration) (net.Conn, error)) grpc.DialOption

+ WithInsecure func() grpc.DialOption

+ WithPerRPCCredentials func(creds credentials.PerRPCCredentials) grpc.DialOption

+ WithServiceConfig func(c <-chan grpc.ServiceConfig) grpc.DialOption

+ WithStatsHandler func(h stats.Handler) grpc.DialOption

+ WithStreamInterceptor func(f grpc.StreamClientInterceptor) grpc.DialOption

+ WithTimeout func(d time.Duration) grpc.DialOption

+ WithTransportCredentials func(creds credentials.TransportCredentials) grpc.DialOption

+ WithUnaryInterceptor func(f grpc.UnaryClientInterceptor) grpc.DialOption

+ WithUserAgent func(s string) grpc.DialOption

+ type GrpcShim struct

+ func (sh *GrpcShim) Code(err error) codes.Code

+ func (sh *GrpcShim) Creds(c credentials.TransportCredentials) grpc.ServerOption

+ func (sh *GrpcShim) CustomCodec(codec grpc.Codec) grpc.ServerOption

+ func (sh *GrpcShim) Dial(target string, opts ...grpc.DialOption) (ClientConn, error)

+ func (sh *GrpcShim) DialContext(ctx context.Context, target string, opts ...grpc.DialOption) (conn *grpc.ClientConn, err error)

+ func (sh *GrpcShim) ErrorDesc(err error) string

+ func (sh *GrpcShim) Errorf(c codes.Code, format string, a ...interface{}) error

+ func (sh *GrpcShim) FailFast(failFast bool) grpc.CallOption

+ func (sh *GrpcShim) FailOnNonTempDialError(f bool) grpc.DialOption

+ func (sh *GrpcShim) Header(md *metadata.MD) grpc.CallOption

+ func (sh *GrpcShim) InTapHandle(h tap.ServerInHandle) grpc.ServerOption

+ func (sh *GrpcShim) Invoke(ctx context.Context, method string, args interface{}, reply interface{}, ...) error

+ func (sh *GrpcShim) MaxConcurrentStreams(n uint32) grpc.ServerOption

+ func (sh *GrpcShim) MaxMsgSize(m int) grpc.ServerOption

+ func (sh *GrpcShim) NewClientStream(ctx context.Context, desc *grpc.StreamDesc, cc *grpc.ClientConn, method string, ...) (_ grpc.ClientStream, err error)

+ func (sh *GrpcShim) NewGZIPCompressor() grpc.Compressor

+ func (sh *GrpcShim) NewGZIPDecompressor() grpc.Decompressor

+ func (sh *GrpcShim) NewServer(opt ...grpc.ServerOption) *grpc.Server

+ func (sh *GrpcShim) RPCCompressor(cp grpc.Compressor) grpc.ServerOption

+ func (sh *GrpcShim) RPCDecompressor(dc grpc.Decompressor) grpc.ServerOption

+ func (sh *GrpcShim) RoundRobin(r naming.Resolver) grpc.Balancer

+ func (sh *GrpcShim) SendHeader(ctx context.Context, md metadata.MD) error

+ func (sh *GrpcShim) SetHeader(ctx context.Context, md metadata.MD) error

+ func (sh *GrpcShim) SetTrailer(ctx context.Context, md metadata.MD) error

+ func (sh *GrpcShim) StatsHandler(h stats.Handler) grpc.ServerOption

+ func (sh *GrpcShim) StreamInterceptor(i grpc.StreamServerInterceptor) grpc.ServerOption

+ func (sh *GrpcShim) Trailer(md *metadata.MD) grpc.CallOption

+ func (sh *GrpcShim) UnaryInterceptor(i grpc.UnaryServerInterceptor) grpc.ServerOption

+ func (sh *GrpcShim) WithBackoffConfig(b grpc.BackoffConfig) grpc.DialOption

+ func (sh *GrpcShim) WithBackoffMaxDelay(md time.Duration) grpc.DialOption

+ func (sh *GrpcShim) WithBalancer(b grpc.Balancer) grpc.DialOption

+ func (sh *GrpcShim) WithBlock() grpc.DialOption

+ func (sh *GrpcShim) WithCodec(c grpc.Codec) grpc.DialOption

+ func (sh *GrpcShim) WithCompressor(cp grpc.Compressor) grpc.DialOption

+ func (sh *GrpcShim) WithDecompressor(dc grpc.Decompressor) grpc.DialOption

+ func (sh *GrpcShim) WithDialer(f func(string, time.Duration) (net.Conn, error)) grpc.DialOption

+ func (sh *GrpcShim) WithInsecure() grpc.DialOption

+ func (sh *GrpcShim) WithPerRPCCredentials(creds credentials.PerRPCCredentials) grpc.DialOption

+ func (sh *GrpcShim) WithServiceConfig(c <-chan grpc.ServiceConfig) grpc.DialOption

+ func (sh *GrpcShim) WithStatsHandler(h stats.Handler) grpc.DialOption

+ func (sh *GrpcShim) WithStreamInterceptor(f grpc.StreamClientInterceptor) grpc.DialOption

+ func (sh *GrpcShim) WithTimeout(d time.Duration) grpc.DialOption

+ func (sh *GrpcShim) WithTransportCredentials(creds credentials.TransportCredentials) grpc.DialOption

+ func (sh *GrpcShim) WithUnaryInterceptor(f grpc.UnaryClientInterceptor) grpc.DialOption

+ func (sh *GrpcShim) WithUserAgent(s string) grpc.DialOption