Documentation
¶
Index ¶
- Variables
- type ForwardDeliverer
- func (d *ForwardDeliverer) Init(ctx service.Context)
- func (d *ForwardDeliverer) Match(ctx service.Context, dst, path string, oneWay bool) bool
- func (d *ForwardDeliverer) Notify(ctx service.Context, dst, path string, args []any) error
- func (d *ForwardDeliverer) Request(ctx service.Context, dst, path string, args []any) runtime.AsyncRet
- func (d *ForwardDeliverer) Shut(ctx service.Context)
- type ServiceDeliverer
- func (d *ServiceDeliverer) Init(ctx service.Context)
- func (d *ServiceDeliverer) Match(ctx service.Context, dst, path string, oneWay bool) bool
- func (d *ServiceDeliverer) Notify(ctx service.Context, dst, path string, args []any) error
- func (d *ServiceDeliverer) Request(ctx service.Context, dst, path string, args []any) runtime.AsyncRet
- func (d *ServiceDeliverer) Shut(ctx service.Context)
- type ServiceDispatcher
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrDistEntityNotFound = errors.New("rpc: distributed entity node not found") ErrForwardToServiceNotFound = errors.New("rpc: the forwarding to the service node is not found") ErrIncorrectDestAddress = errors.New("rpc: incorrect destination AddressDetails") )
View Source
var ( ErrPluginNotFound = errors.New("rpc: plugin not found") ErrMethodNotFound = errors.New("rpc: method not found") ErrComponentNotFound = errors.New("rpc: component not found") ErrMethodParameterCountMismatch = errors.New("rpc: method parameter count mismatch") ErrMethodParameterTypeMismatch = errors.New("rpc: method parameter type mismatch") )
Functions ¶
This section is empty.
Types ¶
type ForwardDeliverer ¶
type ForwardDeliverer struct {
AcceptFrom netpath.AddressDetails // 接受转发的地址信息
ForwardTo string // 转发目的服务
// contains filtered or unexported fields
}
ForwardDeliverer 转发RPC的投递器
type ServiceDeliverer ¶
type ServiceDeliverer struct {
// contains filtered or unexported fields
}
ServiceDeliverer 分布式服务间的RPC投递器
type ServiceDispatcher ¶
type ServiceDispatcher struct {
// contains filtered or unexported fields
}
ServiceDispatcher 分布式服务间的RPC分发器
Click to show internal directories.
Click to hide internal directories.