life

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

type Broadcastable interface {
	Broadcast(wctx Context, mod climod.ModuleID, seq int32, obj int64, body proto.Message) error
	Multicast(wctx Context, mod climod.ModuleID, seq int32, obj int64, body proto.Message, uids ...int64) error
	Consume() <-chan *BroadcastMessage
	ExecuteBroadcast(msg *BroadcastMessage) error
}

type BuildTunnelResponseFunc = func(mod int32, seq int32, obj int64, msg proto.Message) (xnet.TunnelMessage, error)

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

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

type Context interface {
	context.Context
	EventManageable
	Responsive

	Now() time.Time
	ClientIP() string

	UID() int64
	OID() int64
	SID() int64

	UnsafeObject() any
	Snapshot() VersionProto

	Changed(modules ...ModuleKey)
	ChangedImmediately(modules ...ModuleKey)
	ChangedModules() (modules []ModuleKey, immediately bool)
}

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

type EventArgValue interface {
	int64 | string | float64 | []int64 | []string | []float64
}

type EventFunc func(wctx Context) (err error)

type EventManageable interface {
	EmitEvent(t WorkerEventType, args ...WithArg) error
	EmitEventFunc(f EventFunc) error
	ConsumeEvent() <-chan EventFunc
}

type Manager struct {
	xsync.Stoppable
	*BuiltinEventFuncs
	// contains filtered or unexported fields
}

type Module interface {
	ModuleCodec

	IsLifeModule()
}

type ModuleCodec interface {
	EncodeServer() proto.Message
	DecodeServer(proto.Message) error
}

type ModuleKey string

type NewModuleFunc func() Module

type ObjectHolder interface {
	ID() int64
	Version() int64
	UnsafeObject() any
	Snapshot() VersionProto
}

type Option func(*options)

type PersistManager struct {
	xsync.Stoppable
	// contains filtered or unexported fields
}

type Persistent interface {
	ObjectHolder

	AllModuleKeys() []ModuleKey
	Lock(f func() error) error
	Refresh(ctx context.Context) (err error)
	PrepareToPersist(ctx context.Context, modules []ModuleKey) (VersionProto, error)
	Persist(ctx context.Context, id int64, proto VersionProto) (err error)
	IncVersion(ctx context.Context, id int64) (err error)
	OnStop(ctx context.Context, id int64, proto VersionProto) (err error)
}

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

type Responsive interface {
	Push(mod int32, seq int32, obj int64, sc proto.Message) error
	PushImmediately(mod int32, seq int32, obj int64, sc proto.Message) error
	Reply(msg xnet.TunnelMessage)
	ConsumeTunnelResponse() <-chan xnet.TunnelMessage
	ExecuteSend(msg xnet.TunnelMessage) error
	SendFunc() SendFunc
	UpdateSendFunc(sendFunc SendFunc)
	SCIndex() int32
}

type SendFunc = func(msg xnet.TunnelMessage) error

type Tickers struct {
	*BuiltinEventFuncs
	// contains filtered or unexported fields
}

type Tuple struct {
	Key int64
	Val *Worker
}

type VersionProto interface {
	proto.Message

	GetVersion() int64
}

type WithArg func(arg *EventArg)

type Workable interface {
	xsync.Stoppable
	EventManageable

	ID() int64
}

type Worker struct {
	xsync.Stoppable
	Broadcastable
	Responsive
	*BuiltinEventFuncs
	*Tickers
	// contains filtered or unexported fields
}

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

type WorkerEventType int32

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