actor

Documentation

Index

• Variables
• func Final()
• func GetLogger(ctx sadefine.Context) slog.ILogger
• func GetTimerManager(ctx sadefine.Context) *satimer.Manager
• func Init(rootName string, deciderFunc sadefine.DeciderFunc, ...)
• func IsPIDEmpty(pid *sadefine.PID) bool
• func Poison(pid *sadefine.PID)
• func RequestFuture(pid *sadefine.PID, message any, timeout time.Duration) *sadefine.Future
• func RestartDecider(reason any) sadefine.Directive
• func ResumeDecider(reason any) sadefine.Directive
• func RootContext() *sadefine.RootContext
• func RootPID() *sadefine.PID
• func Send(pid *sadefine.PID, message any)
• func Spawn(ctx sadefine.Context, fromRoot bool, name string, wait bool, ...) (*sadefine.PID, error)
• func Stop(pid *sadefine.PID)
• func StopDecider(reason any) sadefine.Directive
• type Actor
  • func (a *Actor) Receive(ctx sadefine.Context)
• type OptionFunc
  • func WithAfterTriggerTimerFunc(funcs ...sdefine.AfterActorTriggerTimerFunc) OptionFunc
  • func WithBeforeTriggerTimerFunc(funcs ...sdefine.BeforeActorTriggerTimerFunc) OptionFunc
  • func WithDecider(decider sadefine.DeciderFunc) OptionFunc
  • func WithLogger(logger slog.ILogger) OptionFunc
  • func WithMailBoxSize(mailBoxSize int) OptionFunc
  • func WithName(name string) OptionFunc
  • func WithOnReceiveMessageFunc(t reflect.Type, funcs ...sdefine.OnActorReceiveMessageFunc) OptionFunc
  • func WithOnRestartingFunc(funcs ...sdefine.OnActorRestartingFunc) OptionFunc
  • func WithOnStartedFunc(funcs ...sdefine.OnActorStartedFunc) OptionFunc
  • func WithOnStoppedFunc(funcs ...sdefine.OnActorStoppedFunc) OptionFunc
  • func WithOnStoppingFunc(funcs ...sdefine.OnActorStoppingFunc) OptionFunc
  • func WithOnTerminatedFunc(funcs ...sdefine.OnActorTerminatedFunc) OptionFunc
  • func WithStartedWaitGroup(startedWg *sync.WaitGroup) OptionFunc
  • func WithStoppedWaitGroup(stoppedWg *sync.WaitGroup) OptionFunc

Variables

var (
	ErrAlreadyStart = errors.New("already start")
	ErrNotStart     = errors.New("not start")
	ErrAlreadyStop  = errors.New("already stop")
)

Functions

func Final

func Final()

func GetLogger

func GetLogger(ctx sadefine.Context) slog.ILogger

func GetTimerManager

func GetTimerManager(ctx sadefine.Context) *satimer.Manager

func Init

func Init(rootName string, deciderFunc sadefine.DeciderFunc, options ...sadefine.ConfigOption)

func IsPIDEmpty

func IsPIDEmpty(pid *sadefine.PID) bool

func Poison

func Poison(pid *sadefine.PID)

func RequestFuture

func RequestFuture(pid *sadefine.PID, message any, timeout time.Duration) *sadefine.Future

func RestartDecider

func RestartDecider(reason any) sadefine.Directive

func ResumeDecider

func ResumeDecider(reason any) sadefine.Directive

func RootContext

func RootContext() *sadefine.RootContext

func RootPID

func RootPID() *sadefine.PID

func Send

func Send(pid *sadefine.PID, message any)

func Spawn

func Spawn(ctx sadefine.Context, fromRoot bool, name string, wait bool, optionFuncs ...OptionFunc) (*sadefine.PID, error)

func Stop

func Stop(pid *sadefine.PID)

func StopDecider

func StopDecider(reason any) sadefine.Directive

Types

type Actor

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

func (*Actor) Receive

func (a *Actor) Receive(ctx sadefine.Context)

type OptionFunc

type OptionFunc func(option *option)

func WithAfterTriggerTimerFunc

func WithAfterTriggerTimerFunc(funcs ...sdefine.AfterActorTriggerTimerFunc) OptionFunc

func WithBeforeTriggerTimerFunc

func WithBeforeTriggerTimerFunc(funcs ...sdefine.BeforeActorTriggerTimerFunc) OptionFunc

func WithDecider

func WithDecider(decider sadefine.DeciderFunc) OptionFunc

func WithLogger

func WithLogger(logger slog.ILogger) OptionFunc

func WithMailBoxSize

func WithMailBoxSize(mailBoxSize int) OptionFunc

func WithName

func WithName(name string) OptionFunc

func WithOnReceiveMessageFunc

func WithOnReceiveMessageFunc(t reflect.Type, funcs ...sdefine.OnActorReceiveMessageFunc) OptionFunc

func WithOnRestartingFunc

func WithOnRestartingFunc(funcs ...sdefine.OnActorRestartingFunc) OptionFunc

func WithOnStartedFunc

func WithOnStartedFunc(funcs ...sdefine.OnActorStartedFunc) OptionFunc

func WithOnStoppedFunc

func WithOnStoppedFunc(funcs ...sdefine.OnActorStoppedFunc) OptionFunc

func WithOnStoppingFunc

func WithOnStoppingFunc(funcs ...sdefine.OnActorStoppingFunc) OptionFunc

func WithOnTerminatedFunc

func WithOnTerminatedFunc(funcs ...sdefine.OnActorTerminatedFunc) OptionFunc

func WithStartedWaitGroup

func WithStartedWaitGroup(startedWg *sync.WaitGroup) OptionFunc

func WithStoppedWaitGroup

func WithStoppedWaitGroup(stoppedWg *sync.WaitGroup) OptionFunc