actor

type Behavior ¶

type Behavior struct {
}

type IActor ¶

type IActor[TKey comparable] interface {
	GetKey() TKey
}

IActor 是 Actor 接口

type IMsg ¶

type IMsg interface {
}

IMsg 是消息接口

type Mgr ¶

type Mgr[TKey comparable] struct {
	// contains filtered or unexported fields
}

Mgr 管理 IActor 的简单系统

func NewMgr[TKey comparable]() *Mgr[TKey]

func (p *Mgr[TKey]) DeleteActor(ctx context.Context, key TKey)

func (p *Mgr[TKey]) SendMessage(key TKey, msg IMsg)

func (p *Mgr[TKey]) SpawnActor(ctx context.Context, key TKey, options ...*Options)

type Msg ¶

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

Msg 是 IMsg 的实现

type Normal ¶

type Normal[TKey comparable] struct {
	// contains filtered or unexported fields
}

func NewNormal[TKey comparable](ctx context.Context, key TKey, options ...*Options) *Normal[TKey]

func (p *Normal[TKey]) GetKey() TKey

type OnDefaultHandler ¶

type OnDefaultHandler func(msg *Msg) error

type Options ¶

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

Options contains Options to configure instance. Each option can be set through setter functions. See documentation for each setter function for an explanation of the option.

func NewOptions() *Options

func (p *Options) WithActorChannelSize(actorChannelSize uint32) *Options

func (p *Options) WithDefaultHandler(defaultHandler OnDefaultHandler) *Options

type State ¶

type State struct {
}