grpc

Jul 31, 2018

Changes in this version

type CallOption

+ func MaxRetryRPCBufferSize(bytes int) CallOption

type ClientConn

+ func (cc *ClientConn) Target() string

type ClientStream

+ Context func() context.Context

+ RecvMsg func(m interface{}) error

+ SendMsg func(m interface{}) error

type DialOption

+ func WithDisableRetry() DialOption

+ func WithMaxHeaderListSize(s uint32) DialOption

+ type EmptyDialOption struct

+ type MaxRetryRPCBufferSizeCallOption struct

+ MaxRetryRPCBufferSize int

type ServerOption

+ func MaxHeaderListSize(s uint32) ServerOption

type ServerStream

+ Context func() context.Context

+ RecvMsg func(m interface{}) error

+ SendMsg func(m interface{}) error

May 8, 2018

Changes in this version

+ func RegisterChannelz()

type ClientConn

+ func (cc *ClientConn) ChannelzMetric() *channelz.ChannelInternalMetric

type DialOption

+ func WithChannelzParentID(id int64) DialOption

+ func WithDisableServiceConfig() DialOption

type Server

+ func (s *Server) ChannelzMetric() *channelz.ServerInternalMetric

type ServerTransportStream

+ func ServerTransportStreamFromContext(ctx context.Context) ServerTransportStream

Apr 4, 2018

Changes in this version

+ func Method(ctx context.Context) (string, bool)

Mar 27, 2018

Changes in this version

+ func NewContextWithServerTransportStream(ctx context.Context, stream ServerTransportStream) context.Context

type Compressor

+ func NewGZIPCompressorWithLevel(level int) (Compressor, error)

+ type CompressorCallOption struct

+ CompressorType string

+ type ContentSubtypeCallOption struct

+ ContentSubtype string

+ type CustomCodecCallOption struct

+ Codec Codec

+ type FailFastCallOption struct

+ FailFast bool

+ type HeaderCallOption struct

+ HeaderAddr *metadata.MD

+ type MaxRecvMsgSizeCallOption struct

+ MaxRecvMsgSize int

+ type MaxSendMsgSizeCallOption struct

+ MaxSendMsgSize int

+ type PeerCallOption struct

+ PeerAddr *peer.Peer

+ type PerRPCCredsCallOption struct

+ Creds credentials.PerRPCCredentials

+ type ServerTransportStream interface

+ Method func() string

+ SendHeader func(md metadata.MD) error

+ SetHeader func(md metadata.MD) error

+ SetTrailer func(md metadata.MD) error

+ type TrailerCallOption struct

+ TrailerAddr *metadata.MD

Feb 14, 2018

Changes in this version

type CallOption

+ func CallContentSubtype(contentSubtype string) CallOption

+ func CallCustomCodec(codec Codec) CallOption

Jan 2, 2018

Changes in this version

+ const PickFirstBalancerName

+ func NewLBBuilderWithFallbackTimeout(fallbackTimeout time.Duration) balancer.Builder

type DialOption

+ func WithBalancerName(balancerName string) DialOption

+ func WithResolverUserOptions(userOpt interface{}) DialOption

+ func WithWaitForHandshake() DialOption

Nov 21, 2017

Changes in this version

+ const SupportPackageIsVersion5

+ func MethodFromServerStream(stream ServerStream) (string, bool)

type CallOption

+ func UseCompressor(name string) CallOption

type ClientConn

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

+ func (cc *ClientConn) NewStream(ctx context.Context, desc *StreamDesc, method string, opts ...CallOption) (ClientStream, error)

Nov 14, 2017

Changes in this version

type ServerOption

+ func ConnectionTimeout(d time.Duration) ServerOption

Oct 11, 2017

Changes in this version

type DialOption

+ func WithBalancerBuilder(b balancer.Builder) DialOption

+ func WithReadBufferSize(s int) DialOption

+ func WithWriteBufferSize(s int) DialOption

type ServerOption

+ func ReadBufferSize(s int) ServerOption

+ func WriteBufferSize(s int) ServerOption

Aug 14, 2017

Changes in this version

type ClientConn

+ func (cc *ClientConn) GetState() connectivity.State

+ func (cc *ClientConn) WaitForStateChange(ctx context.Context, sourceState connectivity.State) bool

Jun 7, 2017

Changes in this version

type BalancerConfig

+ Dialer func(context.Context, string) (net.Conn, error)

type CallOption

+ func MaxCallRecvMsgSize(s int) CallOption

+ func MaxCallSendMsgSize(s int) CallOption

+ func PerRPCCredentials(creds credentials.PerRPCCredentials) CallOption

type ClientConn

+ func (cc *ClientConn) GetMethodConfig(method string) MethodConfig

type DialOption

+ func WithDefaultCallOptions(cos ...CallOption) DialOption

+ func WithInitialConnWindowSize(s int32) DialOption

+ func WithInitialWindowSize(s int32) DialOption

+ type EmptyCallOption struct

type ServerOption

+ func InitialConnWindowSize(s int32) ServerOption

+ func InitialWindowSize(s int32) ServerOption

+ func MaxRecvMsgSize(m int) ServerOption

+ func MaxSendMsgSize(m int) ServerOption

Apr 28, 2017

Changes in this version

+ type AddrMetadataGRPCLB struct

+ AddrType AddressType

+ ServerName string

+ type AddressType uint8

+ const Backend

+ const GRPCLB

type Balancer

+ func NewGRPCLBBalancer(r naming.Resolver) Balancer

type ServerOption

+ func KeepaliveEnforcementPolicy(kep keepalive.EnforcementPolicy) ServerOption

+ func KeepaliveParams(kp keepalive.ServerParameters) ServerOption

Apr 7, 2017

Changes in this version

+ const Version

Mar 14, 2017

Changes in this version

type CallOption

+ func Peer(peer *peer.Peer) CallOption

type DialOption

+ func WithAuthority(a string) DialOption

+ func WithKeepaliveParams(kp keepalive.ClientParameters) DialOption

+ func WithMaxMsgSize(s int) DialOption

+ func WithServiceConfig(c <-chan ServiceConfig) DialOption

+ func WithStatsHandler(h stats.Handler) DialOption

+ type MethodConfig struct

+ MaxReqSize uint32

+ MaxRespSize uint32

+ Timeout time.Duration

+ WaitForReady bool

type ServerOption

+ func StatsHandler(h stats.Handler) ServerOption

+ func UnknownServiceHandler(streamHandler StreamHandler) ServerOption

+ type ServiceConfig struct

+ LB Balancer

+ Methods map[string]MethodConfig

Dec 2, 2016

Changes in this version

type DialOption

+ func FailOnNonTempDialError(f bool) DialOption

type ServerOption

+ func InTapHandle(h tap.ServerInHandle) ServerOption

Nov 3, 2016

Changes in this version

+ const SupportPackageIsVersion4

Oct 17, 2016

Changes in this version

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

type ServerStream

+ SetHeader func(metadata.MD) error

Oct 3, 2016

Changes in this version

+ type BalancerConfig struct

+ DialCreds credentials.TransportCredentials

type ClientConn

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

type DialOption

+ func WithStreamInterceptor(f StreamClientInterceptor) DialOption

+ func WithUnaryInterceptor(f UnaryClientInterceptor) DialOption

type Server

+ func (s *Server) GracefulStop()

type ServerOption

+ func MaxMsgSize(m int) ServerOption

+ type StreamClientInterceptor func(ctx context.Context, desc *StreamDesc, cc *ClientConn, method string, ...) (ClientStream, error)

+ type Streamer func(ctx context.Context, desc *StreamDesc, cc *ClientConn, method string, ...) (ClientStream, error)

+ type UnaryClientInterceptor func(ctx context.Context, method string, req, reply interface{}, cc *ClientConn, ...) error

+ type UnaryInvoker func(ctx context.Context, method string, req, reply interface{}, cc *ClientConn, ...) error

Jul 11, 2016

Changes in this version

+ const SupportPackageIsVersion3

+ var DefaultBackoffConfig = BackoffConfig

+ var EnableTracing = true

+ var ErrClientConnClosing = errors.New("grpc: the client connection is closing")

+ var ErrClientConnTimeout = errors.New("grpc: timed out when dialing")

+ var ErrServerStopped = errors.New("grpc: the server has been stopped")

+ func Code(err error) codes.Code

+ func ErrorDesc(err error) string

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

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

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

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

+ type Address struct

+ Addr string

+ Metadata interface{}

+ type BackoffConfig struct

+ MaxDelay time.Duration

+ type Balancer interface

+ Close func() error

+ Get func(ctx context.Context, opts BalancerGetOptions) (addr Address, put func(), err error)

+ Notify func() <-chan []Address

+ Start func(target string) error

+ Up func(addr Address) (down func(error))

+ func RoundRobin(r naming.Resolver) Balancer

+ type BalancerGetOptions struct

+ BlockingWait bool

+ type CallOption interface

+ func FailFast(failFast bool) CallOption

+ func Header(md *metadata.MD) CallOption

+ func Trailer(md *metadata.MD) CallOption

+ type ClientConn struct

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

+ func (cc *ClientConn) Close() error

+ type ClientStream interface

+ CloseSend func() error

+ Header func() (metadata.MD, error)

+ Trailer func() metadata.MD

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

+ type Codec interface

+ Marshal func(v interface{}) ([]byte, error)

+ String func() string

+ Unmarshal func(data []byte, v interface{}) error

+ type Compressor interface

+ Do func(w io.Writer, p []byte) error

+ Type func() string

+ func NewGZIPCompressor() Compressor

+ type ConnectivityState int

+ const Connecting

+ const Idle

+ const Ready

+ const Shutdown

+ const TransientFailure

+ func (s ConnectivityState) String() string

+ type Decompressor interface

+ Do func(r io.Reader) ([]byte, error)

+ Type func() string

+ func NewGZIPDecompressor() Decompressor

+ type DialOption func(*dialOptions)

+ func WithBackoffConfig(b BackoffConfig) DialOption

+ func WithBackoffMaxDelay(md time.Duration) DialOption

+ func WithBalancer(b Balancer) DialOption

+ func WithBlock() DialOption

+ func WithCodec(c Codec) DialOption

+ func WithCompressor(cp Compressor) DialOption

+ func WithDecompressor(dc Decompressor) DialOption

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

+ func WithInsecure() DialOption

+ func WithPerRPCCredentials(creds credentials.PerRPCCredentials) DialOption

+ func WithTimeout(d time.Duration) DialOption

+ func WithTransportCredentials(creds credentials.TransportCredentials) DialOption

+ func WithUserAgent(s string) DialOption

+ type MethodDesc struct

+ Handler methodHandler

+ MethodName string

+ type MethodInfo struct

+ IsClientStream bool

+ IsServerStream bool

+ Name string

+ type Server struct

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

+ func (s *Server) GetServiceInfo() map[string]*ServiceInfo

+ func (s *Server) RegisterService(sd *ServiceDesc, ss interface{})

+ func (s *Server) Serve(lis net.Listener) error

+ func (s *Server) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ func (s *Server) Stop()

+ type ServerOption func(*options)

+ func Creds(c credentials.TransportCredentials) ServerOption

+ func CustomCodec(codec Codec) ServerOption

+ func MaxConcurrentStreams(n uint32) ServerOption

+ func RPCCompressor(cp Compressor) ServerOption

+ func RPCDecompressor(dc Decompressor) ServerOption

+ func StreamInterceptor(i StreamServerInterceptor) ServerOption

+ func UnaryInterceptor(i UnaryServerInterceptor) ServerOption

+ type ServerStream interface

+ SendHeader func(metadata.MD) error

+ SetTrailer func(metadata.MD)

+ type ServiceDesc struct

+ HandlerType interface{}

+ Metadata interface{}

+ Methods []MethodDesc

+ ServiceName string

+ Streams []StreamDesc

+ type ServiceInfo struct

+ Metadata interface{}

+ Methods []MethodInfo

+ type Stream interface

+ Context func() context.Context

+ RecvMsg func(m interface{}) error

+ SendMsg func(m interface{}) error

+ type StreamDesc struct

+ ClientStreams bool

+ Handler StreamHandler

+ ServerStreams bool

+ StreamName string

+ type StreamHandler func(srv interface{}, stream ServerStream) error

+ type StreamServerInfo struct

+ FullMethod string

+ IsClientStream bool

+ IsServerStream bool

+ type StreamServerInterceptor func(srv interface{}, ss ServerStream, info *StreamServerInfo, ...) error

+ type UnaryHandler func(ctx context.Context, req interface{}) (interface{}, error)

+ type UnaryServerInfo struct

+ FullMethod string

+ Server interface{}

+ type UnaryServerInterceptor func(ctx context.Context, req interface{}, info *UnaryServerInfo, ...) (resp interface{}, err error)