dubbo3

Documentation

Index

• func GetProtocol() protocol.Protocol
• type Dubbo3GrpcService
• type DubboExporter
  • func NewDubboExporter(key string, invoker protocol.Invoker, exporterMap *sync.Map, ...) *DubboExporter
  • func (de *DubboExporter) Unexport()
• type DubboInvoker
  • func NewDubboInvoker(url *common.URL) (*DubboInvoker, error)
  • func (di *DubboInvoker) Destroy()
  • func (di *DubboInvoker) Invoke(ctx context.Context, invocation protocol.Invocation) protocol.Result
  • func (di *DubboInvoker) IsAvailable() bool
• type DubboProtocol
  • func NewDubboProtocol() *DubboProtocol
  • func (dp *DubboProtocol) Destroy()
  • func (dp *DubboProtocol) Export(invoker protocol.Invoker) protocol.Exporter
  • func (dp *DubboProtocol) Refer(url *common.URL) protocol.Invoker
• type UnaryService
  • func (d *UnaryService) GetReqParamsInterfaces(methodName string) ([]interface{}, bool)
  • func (d *UnaryService) InvokeWithArgs(ctx context.Context, methodName string, arguments []interface{}) (interface{}, error)

Functions

func GetProtocol

func GetProtocol() protocol.Protocol

GetProtocol get a single dubbo3 protocol.

Types

type Dubbo3GrpcService

type Dubbo3GrpcService interface {
	// SetProxyImpl sets proxy.
	XXX_SetProxyImpl(impl protocol.Invoker)
	// GetProxyImpl gets proxy.
	XXX_GetProxyImpl() protocol.Invoker
	// ServiceDesc gets an RPC service's specification.
	XXX_ServiceDesc() *grpc.ServiceDesc
}

Dubbo3GrpcService is gRPC service

type DubboExporter

type DubboExporter struct {
	protocol.BaseExporter
	// contains filtered or unexported fields
}

DubboExporter is dubbo3 service exporter.

func NewDubboExporter

func NewDubboExporter(key string, invoker protocol.Invoker, exporterMap *sync.Map, serviceMap *sync.Map) *DubboExporter

NewDubboExporter get a Dubbo3Exporter.

func (*DubboExporter) Unexport

func (de *DubboExporter) Unexport()

Unexport unexport dubbo3 service exporter.

type DubboInvoker

type DubboInvoker struct {
	protocol.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 protocol.Invocation) protocol.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 {
	protocol.BaseProtocol
	// contains filtered or unexported fields
}

It support dubbo protocol. It implements Protocol interface for dubbo protocol.

func NewDubboProtocol

func NewDubboProtocol() *DubboProtocol

NewDubboProtocol create a dubbo protocol.

func (*DubboProtocol) Destroy

func (dp *DubboProtocol) Destroy()

Destroy destroy dubbo3 service.

func (*DubboProtocol) Export

func (dp *DubboProtocol) Export(invoker protocol.Invoker) protocol.Exporter

Export export dubbo3 service.

func (*DubboProtocol) Refer

func (dp *DubboProtocol) Refer(url *common.URL) protocol.Invoker

Refer create dubbo3 service reference.

type UnaryService

type UnaryService struct {
	// contains filtered or unexported fields
}

func (*UnaryService) GetReqParamsInterfaces

func (d *UnaryService) GetReqParamsInterfaces(methodName string) ([]interface{}, bool)

func (*UnaryService) InvokeWithArgs

func (d *UnaryService) InvokeWithArgs(ctx context.Context, methodName string, arguments []interface{}) (interface{}, error)