The highest tagged major version is v2.

master

package

v0.0.9 Latest Latest Go to latest Published: Jan 30, 2023 License: MIT Imports: 19 Imported by: 4

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/dobyte/due

Links

Documentation ¶

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	ErrInvalidGID         = link.ErrInvalidGID
	ErrInvalidNID         = link.ErrInvalidNID
	ErrInvalidMessage     = link.ErrInvalidMessage
	ErrInvalidArgument    = link.ErrInvalidArgument
	ErrInvalidSessionKind = link.ErrInvalidSessionKind
	ErrNotFoundUserSource = link.ErrNotFoundUserSource
	ErrReceiveTargetEmpty = link.ErrReceiveTargetEmpty
)

Functions ¶

This section is empty.

Types ¶

type Master ¶

type Master struct {
	component.Base
	// contains filtered or unexported fields
}

func NewMaster ¶

func NewMaster(opts ...Option) *Master

func (*Master) Destroy ¶

func (m *Master) Destroy()

Destroy 销毁组件

func (*Master) Init ¶

func (m *Master) Init()

Init 初始化组件

func (*Master) Name ¶

func (m *Master) Name() string

Name 组件名称

func (*Master) Proxy ¶

func (m *Master) Proxy() Proxy

Proxy 获取管理服代理

func (*Master) Start ¶

func (m *Master) Start()

Start 启动组件

type Message ¶

type Message = link.Message

type Option ¶

type Option func(o *options)

func WithCodec ¶

func WithCodec(codec encoding.Codec) Option

WithCodec 设置编解码器

func WithContext ¶

func WithContext(ctx context.Context) Option

WithContext 设置上下文

func WithDecryptor ¶

func WithDecryptor(decryptor crypto.Decryptor) Option

WithDecryptor 设置消息解密器

func WithEncryptor ¶

func WithEncryptor(encryptor crypto.Encryptor) Option

WithEncryptor 设置消息加密器

func WithID ¶

func WithID(id string) Option

WithID 设置实例ID

func WithLocator ¶

func WithLocator(locator locate.Locator) Option

WithLocator 设置定位器

func WithName ¶

func WithName(name string) Option

WithName 设置实例名称

func WithRegistry ¶

func WithRegistry(r registry.Registry) Option

WithRegistry 设置服务注册器

func WithTimeout ¶

func WithTimeout(timeout time.Duration) Option

WithTimeout 设置RPC调用超时时间

func WithTransporter ¶

func WithTransporter(transporter transport.Transporter) Option

WithTransporter 设置消息传输器

type Proxy ¶

type Proxy interface {
	// GetID 获取当前节点ID
	GetID() string
	// GetName 获取当前节点名称
	GetName() string
	// LocateGate 定位用户所在网关
	LocateGate(ctx context.Context, uid int64) (string, error)
	// LocateNode 定位用户所在节点
	LocateNode(ctx context.Context, uid int64) (string, error)
	// FetchGateList 拉取网关列表
	FetchGateList(ctx context.Context, states ...cluster.State) ([]*registry.ServiceInstance, error)
	// FetchNodeList 拉取节点列表
	FetchNodeList(ctx context.Context, states ...cluster.State) ([]*registry.ServiceInstance, error)
	// GetIP 获取客户端IP
	GetIP(ctx context.Context, uid int64) (string, error)
	// Push 推送消息
	Push(ctx context.Context, uid int64, message *Message) error
	// Multicast 推送组播消息
	Multicast(ctx context.Context, uids []int64, message *Message) (int64, error)
	// Broadcast 推送广播消息
	Broadcast(ctx context.Context, kind session.Kind, message *Message) (int64, error)
	// Deliver 投递消息给节点处理
	Deliver(ctx context.Context, uid int64, message *Message) error
	// Disconnect 断开连接
	Disconnect(ctx context.Context, uid int64, isForce bool) error
}

Source Files ¶

View all Source files

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