Versions in this module Expand all Collapse all v1 v1.0.0 Dec 28, 2024 Changes in this version + const GRPC + func GetProtocol() protocol.Protocol + type Client struct + func NewClient(url *common.URL) (*Client, error) + type ClientConfig struct + ContentSubType string + func GetClientConfig() ClientConfig + func GetDefaultClientConfig() ClientConfig + func (c *ClientConfig) Validate() error + 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(ctx context.Context, 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) GracefulStop() + func (s *Server) SetBufferSize(n int) + func (s *Server) Start(url *common.URL) + func (s *Server) Stop() + type ServerConfig struct + func GetDefaultServerConfig() ServerConfig + func (c *ServerConfig) Validate() error
Go to main page