Documentation
¶
Overview ¶
Package dubbo3 implements dubbo3.0 rpc protocol.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Dubbo3GrpcService ¶
type Dubbo3GrpcService interface {
// SetProxyImpl sets proxy.
XXX_SetProxyImpl(impl base.Invoker)
// GetProxyImpl gets proxy.
XXX_GetProxyImpl() base.Invoker
// ServiceDesc gets an RPC service's specification.
XXX_ServiceDesc() *grpc.ServiceDesc
}
Dubbo3GrpcService is gRPC service
type DubboExporter ¶
type DubboExporter struct {
base.BaseExporter
// contains filtered or unexported fields
}
DubboExporter is dubbo3 service exporter.
func NewDubboExporter ¶
func NewDubboExporter(key string, invoker base.Invoker, exporterMap *sync.Map, serviceMap *sync.Map) *DubboExporter
NewDubboExporter get a Dubbo3Exporter.
func (*DubboExporter) UnExport ¶ added in v3.0.4
func (de *DubboExporter) UnExport()
UnExport unexport dubbo3 service exporter.
type DubboInvoker ¶
type DubboInvoker struct {
base.BaseInvoker
// contains filtered or unexported fields
}
DubboInvoker is implement of protocol.Invoker, a dubboInvoker refer to one service and ip.
func NewDubboInvoker ¶
func NewDubboInvoker(url *common.URL) (*DubboInvoker, error)
NewDubboInvoker constructor
func (*DubboInvoker) Destroy ¶
func (di *DubboInvoker) Destroy()
Destroy destroy dubbo3 client invoker.
func (*DubboInvoker) Invoke ¶
func (di *DubboInvoker) Invoke(ctx context.Context, invocation base.Invocation) result.Result
Invoke call remoting.
func (*DubboInvoker) IsAvailable ¶
func (di *DubboInvoker) IsAvailable() bool
IsAvailable check if invoker is available, now it is useless
type DubboProtocol ¶
type DubboProtocol struct {
base.BaseProtocol
// contains filtered or unexported fields
}
DubboProtocol supports dubbo 3.0 protocol. It implements Protocol interface for dubbo protocol.
func NewDubboProtocol ¶
func NewDubboProtocol() *DubboProtocol
NewDubboProtocol create a dubbo protocol.
type UnaryService ¶
type UnaryService struct {
// contains filtered or unexported fields
}
func (*UnaryService) GetReqParamsInterfaces ¶
func (d *UnaryService) GetReqParamsInterfaces(methodName string) ([]any, bool)
func (*UnaryService) InvokeWithArgs ¶
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.