grpc

Jan 4, 2021

Changes in this version

type Server

+ func (s *Server) SetBufferSize(n int)

Jul 23, 2020

Changes in this version

+ type ClientConfig struct

+ ContentSubType string

+ func GetClientConfig() ClientConfig

+ func GetDefaultClientConfig() ClientConfig

+ func (c *ClientConfig) Validate() error

+ type ServerConfig struct

+ func GetDefaultServerConfig() ServerConfig

+ func (c *ServerConfig) Validate() error

Mar 1, 2020

Changes in this version

+ const GRPC

+ var ErrNoReply = errors.New("request need @response")

+ func GetProtocol() protocol.Protocol

+ type Client struct

+ func NewClient(url common.URL) *Client

+ type DubboGrpcService interface

+ GetProxyImpl func() protocol.Invoker

+ ServiceDesc func() *grpc.ServiceDesc

+ SetProxyImpl func(impl protocol.Invoker)

+ type GrpcExporter struct

+ func NewGrpcExporter(key string, invoker protocol.Invoker, exporterMap *sync.Map) *GrpcExporter

+ func (gg *GrpcExporter) Unexport()

+ type GrpcInvoker struct

+ func NewGrpcInvoker(url common.URL, client *Client) *GrpcInvoker

+ func (gi *GrpcInvoker) Destroy()

+ func (gi *GrpcInvoker) Invoke(invocation protocol.Invocation) protocol.Result

+ func (gi *GrpcInvoker) IsAvailable() bool

+ func (gi *GrpcInvoker) IsDestroyed() bool

+ type GrpcProtocol struct

+ func NewGRPCProtocol() *GrpcProtocol

+ func (gp *GrpcProtocol) Destroy()

+ func (gp *GrpcProtocol) Export(invoker protocol.Invoker) protocol.Exporter

+ func (gp *GrpcProtocol) Refer(url common.URL) protocol.Invoker

+ type Server struct

+ func NewServer() *Server

+ func (s *Server) Start(url common.URL)

+ func (s *Server) Stop()