actor

package module

Go to main page

Versions in this module

v0

v0.0.6

Apr 11, 2026

Changes in this version

+ var ErrMessageDropped = errors.New("message dropped by backpressure")

+ func AwaitFuture[T any](ctx context.Context, f Future[T]) (T, error)

+ func CompleteWith[T any](p Promise[T], val T)

type ActorConfig

+ MailboxFactory MailboxFactory[M, R]

+ type ActorOption func(*ActorConfig[M, R])

+ func WithMailboxFactory[M Message, R any](f MailboxFactory[M, R]) ActorOption[M, R]

+ func WithMailboxSize[M Message, R any](size int) ActorOption[M, R]

+ type BackpressureMailbox struct

+ func NewBackpressureMailbox[M Message, R any](actorCtx context.Context, capacity int, shouldDrop queue.DropCheckFunc) *BackpressureMailbox[M, R]

+ func (m *BackpressureMailbox[M, R]) Close()

+ func (m *BackpressureMailbox[M, R]) Drain() iter.Seq[envelope[M, R]]

+ func (m *BackpressureMailbox[M, R]) IsClosed() bool

+ func (m *BackpressureMailbox[M, R]) Receive(ctx context.Context) iter.Seq[envelope[M, R]]

+ func (m *BackpressureMailbox[M, R]) Send(ctx context.Context, env envelope[M, R]) bool

+ func (m *BackpressureMailbox[M, R]) TrySend(env envelope[M, R]) bool

+ type MailboxFactory func(ctx context.Context, capacity int) Mailbox[M, R]

v0.0.5

Feb 18, 2026

Changes in this version

+ type ChannelMailbox struct

+ func NewChannelMailbox[M Message, R any](actorCtx context.Context, capacity int) *ChannelMailbox[M, R]

+ func (m *ChannelMailbox[M, R]) Close()

+ func (m *ChannelMailbox[M, R]) Drain() iter.Seq[envelope[M, R]]

+ func (m *ChannelMailbox[M, R]) IsClosed() bool

+ func (m *ChannelMailbox[M, R]) Receive(ctx context.Context) iter.Seq[envelope[M, R]]

+ func (m *ChannelMailbox[M, R]) Send(ctx context.Context, env envelope[M, R]) bool

+ func (m *ChannelMailbox[M, R]) TrySend(env envelope[M, R]) bool

+ type Mailbox interface

+ Close func()

+ Drain func() iter.Seq[envelope[M, R]]

+ IsClosed func() bool

+ Receive func(ctx context.Context) iter.Seq[envelope[M, R]]

+ Send func(ctx context.Context, env envelope[M, R]) bool

+ TrySend func(env envelope[M, R]) bool

v0.0.4

Feb 11, 2026

Changes in this version

+ var ErrDuplicateActorID = fmt.Errorf("actor ID already registered")

+ var ErrEmptyActorID = fmt.Errorf("actor ID must not be empty")

+ var ErrNilBehavior = fmt.Errorf("actor behavior must not be nil")

+ func UseLogger(logger btclog.Logger)

v0.0.3

Nov 13, 2025

Changes in this version

+ type MapInputRef struct

+ func NewMapInputRef[In Message, Out Message](targetRef TellOnlyRef[Out], mapFn func(In) Out) *MapInputRef[In, Out]

+ func (m *MapInputRef[In, Out]) ID() string

+ func (m *MapInputRef[In, Out]) Tell(ctx context.Context, msg In)

v0.0.2

Nov 7, 2025

Changes in this version

+ var ErrActorTerminated = fmt.Errorf("actor terminated")

+ var ErrNoActorsAvailable = errors.New("no actors available for service key")

+ func RegisterWithReceptionist[M Message, R any](r *Receptionist, key ServiceKey[M, R], ref ActorRef[M, R])

+ func UnregisterFromReceptionist[M Message, R any](r *Receptionist, key ServiceKey[M, R], refToRemove ActorRef[M, R]) bool

+ type Actor struct

+ func NewActor[M Message, R any](cfg ActorConfig[M, R]) *Actor[M, R]

+ func (a *Actor[M, R]) Ref() ActorRef[M, R]

+ func (a *Actor[M, R]) Start()

+ func (a *Actor[M, R]) Stop()

+ func (a *Actor[M, R]) TellRef() TellOnlyRef[M]

+ type ActorBehavior interface

+ Receive func(actorCtx context.Context, msg M) fn.Result[R]

+ type ActorConfig struct

+ Behavior ActorBehavior[M, R]

+ DLO ActorRef[Message, any]

+ ID string

+ MailboxSize int

+ type ActorFunc func(context.Context, M) fn.Result[R]

+ type ActorRef interface

+ Ask func(ctx context.Context, msg M) Future[R]

+ func FindInReceptionist[M Message, R any](r *Receptionist, key ServiceKey[M, R]) []ActorRef[M, R]

+ func RegisterWithSystem[M Message, R any](as *ActorSystem, id string, key ServiceKey[M, R], behavior ActorBehavior[M, R]) ActorRef[M, R]

+ type ActorSystem struct

+ func NewActorSystem() *ActorSystem

+ func NewActorSystemWithConfig(config SystemConfig) *ActorSystem

+ func (as *ActorSystem) DeadLetters() ActorRef[Message, any]

+ func (as *ActorSystem) Receptionist() *Receptionist

+ func (as *ActorSystem) Shutdown() error

+ func (as *ActorSystem) StopAndRemoveActor(id string) bool

+ type BaseMessage struct

+ type FunctionBehavior struct

+ func FunctionBehaviorFromSimple[M Message, R any](sFunc func(M) (R, error)) *FunctionBehavior[M, R]

+ func NewFunctionBehavior[M Message, R any](fn ActorFunc[M, R]) *FunctionBehavior[M, R]

+ func (b *FunctionBehavior[M, R]) Receive(ctx context.Context, msg M) fn.Result[R]

+ type Future interface

+ Await func(ctx context.Context) fn.Result[T]

+ OnComplete func(ctx context.Context, fn func(fn.Result[T]))

+ ThenApply func(ctx context.Context, fn func(T) T) Future[T]

+ type Message interface

+ MessageType func() string

+ type PriorityMessage interface

+ Priority func() int

+ type Promise interface

+ Complete func(result fn.Result[T]) bool

+ Future func() Future[T]

+ func NewPromise[T any]() Promise[T]

+ type Receptionist struct

+ type RoundRobinStrategy struct

+ func NewRoundRobinStrategy[M Message, R any]() *RoundRobinStrategy[M, R]

+ func (s *RoundRobinStrategy[M, R]) Select(refs []ActorRef[M, R]) (ActorRef[M, R], error)

+ type Router struct

+ func NewRouter[M Message, R any](receptionist *Receptionist, key ServiceKey[M, R], ...) *Router[M, R]

+ func (r *Router[M, R]) Ask(ctx context.Context, msg M) Future[R]

+ func (r *Router[M, R]) ID() string

+ func (r *Router[M, R]) Tell(ctx context.Context, msg M)

+ type RoutingStrategy interface

+ Select func(refs []ActorRef[M, R]) (ActorRef[M, R], error)

+ type ServiceKey struct

+ func NewServiceKey[M Message, R any](name string) ServiceKey[M, R]

+ func (sk ServiceKey[M, R]) Spawn(as *ActorSystem, id string, behavior ActorBehavior[M, R]) ActorRef[M, R]

+ func (sk ServiceKey[M, R]) Unregister(as *ActorSystem, refToRemove ActorRef[M, R]) bool

+ func (sk ServiceKey[M, R]) UnregisterAll(as *ActorSystem) int

+ type SystemConfig struct

+ MailboxCapacity int

+ func DefaultConfig() SystemConfig

+ type TellOnlyRef interface

+ ID func() string

+ Tell func(ctx context.Context, msg M)

v0.0.1-alpha

May 17, 2025

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