processors

package
v0.1.32 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 10, 2024 License: LGPL-2.1 Imports: 21 Imported by: 0

Documentation

Index

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的投递器

func (*ForwardDeliverer) Init

func (d *ForwardDeliverer) Init(ctx service.Context)

Init 初始化

func (*ForwardDeliverer) Match

func (d *ForwardDeliverer) Match(ctx service.Context, dst, path string, oneWay bool) bool

Match 是否匹配

func (*ForwardDeliverer) Notify

func (d *ForwardDeliverer) Notify(ctx service.Context, dst, path string, args []any) error

Notify 通知

func (*ForwardDeliverer) Request

func (d *ForwardDeliverer) Request(ctx service.Context, dst, path string, args []any) runtime.AsyncRet

Request 请求

func (*ForwardDeliverer) Shut

func (d *ForwardDeliverer) Shut(ctx service.Context)

Shut 结束

type ServiceDeliverer

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

ServiceDeliverer 分布式服务间的RPC投递器

func (*ServiceDeliverer) Init

func (d *ServiceDeliverer) Init(ctx service.Context)

Init 初始化

func (*ServiceDeliverer) Match

func (d *ServiceDeliverer) Match(ctx service.Context, dst, path string, oneWay bool) bool

Match 是否匹配

func (*ServiceDeliverer) Notify

func (d *ServiceDeliverer) Notify(ctx service.Context, dst, path string, args []any) error

Notify 通知

func (*ServiceDeliverer) Request

func (d *ServiceDeliverer) Request(ctx service.Context, dst, path string, args []any) runtime.AsyncRet

Request 请求

func (*ServiceDeliverer) Shut

func (d *ServiceDeliverer) Shut(ctx service.Context)

Shut 结束

type ServiceDispatcher

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

ServiceDispatcher 分布式服务间的RPC分发器

func (*ServiceDispatcher) Init

func (d *ServiceDispatcher) Init(ctx service.Context)

Init 初始化

func (*ServiceDispatcher) Shut

func (d *ServiceDispatcher) Shut(ctx service.Context)

Shut 结束

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL