sup

May 14, 2026

Changes in this version

type BaseActor

+ func (a *BaseActor) Inspect() Spec

type ComputedSignal

+ func (s *ComputedSignal[V]) Inspect() Spec

type DebouncedSignal

+ func (s *DebouncedSignal[V]) Inspect() Spec

+ type Inspectable interface

+ Inspect func() Spec

type PeriodicSignal

+ func (s *PeriodicSignal[V]) Inspect() Spec

type PushedSignal

+ func (s *PushedSignal[V]) Inspect() Spec

+ type Signal interface

+ type Spec struct

+ Dependencies []string

+ Kind string

+ Metadata map[string]string

type Supervisor

+ func (s *Supervisor) Children() []Actor

+ func (s *Supervisor) Inspect() Spec

type ThrottledSignal

+ func (s *ThrottledSignal[V]) Inspect() Spec

May 9, 2026

Changes in this version

+ type PeriodicSignal struct

+ func NewPeriodicSignal[V any](name string, update func(context.Context) (V, error), interval time.Duration) *PeriodicSignal[V]

+ func (s *PeriodicSignal[V]) Run(ctx context.Context) error

+ func (s *PeriodicSignal[V]) Trigger()

May 6, 2026

Changes in this version

+ type BaseSignal struct

+ func NewBaseSignal[V any](name string) *BaseSignal[V]

+ func (b *BaseSignal[V]) Read() V

+ func (b *BaseSignal[V]) SetBroadcasterBuffer(buffer int)

+ func (b *BaseSignal[V]) SetEqual(eq func(a, b V) bool)

+ func (b *BaseSignal[V]) SetInitialNotify(enabled bool)

+ func (b *BaseSignal[V]) SetInitialValue(v V)

+ func (b *BaseSignal[V]) Subscribe(ctx context.Context) <-chan V

+ func (b *BaseSignal[V]) Watch(ctx context.Context) <-chan struct{}

+ type ComputedSignal struct

+ func NewComputedSignal[V any](name string, update func() V, deps ...WatcherSignal) *ComputedSignal[V]

+ func (s *ComputedSignal[V]) Run(ctx context.Context) error

+ func (s *ComputedSignal[V]) SetCoalesceWindow(window time.Duration)

+ type DebouncedSignal struct

+ func NewDebouncedSignal[V any](name string, src ReadableSignal[V], wait time.Duration) *DebouncedSignal[V]

+ func (s *DebouncedSignal[V]) Run(ctx context.Context) error

+ func (s *DebouncedSignal[V]) SetMaxWait(maxWait time.Duration)

+ type PolledSignal struct

+ func NewPolledSignal[V any](name string, update func(context.Context) (V, error), interval time.Duration) *PolledSignal[V]

+ func (s *PolledSignal[V]) Run(ctx context.Context) error

+ type PushedSignal struct

+ func NewPushedSignal[V any](name string, update func(context.Context, V) error) *PushedSignal[V]

+ func (s *PushedSignal[V]) Run(ctx context.Context) error

+ func (s *PushedSignal[V]) Write(ctx context.Context, value V) error

+ type ReadableSignal interface

+ type ReaderSignal interface

+ Read func() V

+ type SubscriberSignal interface

+ Subscribe func(context.Context) <-chan V

+ type ThrottledSignal struct

+ func NewThrottledSignal[V any](name string, src ReadableSignal[V], interval time.Duration) *ThrottledSignal[V]

+ func (s *ThrottledSignal[V]) Run(ctx context.Context) error

+ type WatcherSignal interface

+ Watch func(ctx context.Context) <-chan struct{}

+ type WritableSignal interface

+ type WriterSignal interface

+ Write func(context.Context, V) error

May 5, 2026

Changes in this version

+ type Router struct

+ func NewRouter[F any](strategy RouterStrategy, routees ...F) *Router[F]

+ func (r *Router[F]) Broadcast(fn func(F))

+ func (r *Router[F]) FanOut(fn func(F))

+ func (r *Router[F]) FanOutWait(fn func(F))

+ func (r *Router[F]) Len() int

+ func (r *Router[F]) Next() F

+ func (r *Router[F]) Retry(limit int, run func(F) error) error

+ func (r *Router[F]) Sticky(key uint64) F

+ type RouterStrategy uint8

+ const Random

+ const RoundRobin

May 5, 2026

Changes in this version

+ var ErrCallInboxClosed = errors.New("sup: call inbox is closed")

+ var ErrCallInboxFull = errors.New("sup: call inbox is full")

+ var ErrCastInboxClosed = errors.New("sup: cast inbox is closed")

+ var ErrCastInboxFull = errors.New("sup: cast inbox is full")

+ type CallInbox struct

+ func NewCallInbox[T any, R any](size int) *CallInbox[T, R]

+ func (i *CallInbox[T, R]) Call(ctx context.Context, message T) (R, error)

+ func (i *CallInbox[T, R]) Cap() int

+ func (i *CallInbox[T, R]) Close()

+ func (i *CallInbox[T, R]) Len() int

+ func (i *CallInbox[T, R]) Receive() <-chan CallRequest[T, R]

+ type CastInbox struct

+ func NewCastInbox[T any](size int) *CastInbox[T]

+ func (i *CastInbox[T]) Cap() int

+ func (i *CastInbox[T]) Cast(ctx context.Context, message T) error

+ func (i *CastInbox[T]) Close()

+ func (i *CastInbox[T]) Len() int

+ func (i *CastInbox[T]) Receive() <-chan T

+ func (i *CastInbox[T]) TryCast(ctx context.Context, message T) error

+ type Outbox struct

+ func (o *Outbox[T]) Emit(ctx context.Context, message T)

+ func (o *Outbox[T]) Subscribe(handler func(context.Context, T))

May 4, 2026

Changes in this version

type BaseActor

+ func (a *BaseActor) Logger() *slog.Logger

type SupervisorOption

+ func WithLogger(logger *slog.Logger) SupervisorOption

Apr 30, 2026

Changes in this version

+ type SupervisorObserver struct

+ OnActorRegistered func(actor Actor)

+ OnActorRestarting func(actor Actor, restartCount int, lastErr error)

+ OnActorStarted func(actor Actor)

+ OnActorStopped func(actor Actor, err error)

+ OnSupervisorTerminal func(err error)

type SupervisorOption

+ func WithObserver(observer *SupervisorObserver) SupervisorOption

Apr 29, 2026

Changes in this version

+ type Registry struct

+ func GlobalRegistry() *Registry

+ func NewRegistry() *Registry

+ func (r *Registry) Get(name string) (Actor, bool)

+ func (r *Registry) Register(actor Actor)

+ func (r *Registry) Unregister(name string)

Apr 26, 2026

Changes in this version

type Actor

+ Name func() string

+ type BaseActor struct

+ func NewBaseActor(name string) *BaseActor

+ func (a *BaseActor) Name() string

Apr 23, 2026

Changes in this version

type Supervisor

+ func (s *Supervisor) Run(ctx context.Context) error

+ func (s *Supervisor) Spawn(ctx context.Context, actor Actor)

type SupervisorOption

+ func WithActor(a Actor) SupervisorOption

+ func WithActors(actors ...Actor) SupervisorOption

Apr 20, 2026

Changes in this version

+ type Actor interface

+ Run func(context.Context) error

+ type ActorFunc func(context.Context) error

+ func (f ActorFunc) Run(ctx context.Context) error

Apr 20, 2026

Changes in this version

+ type RepliableRequest interface

+ Reply func(value R, err error)

type Request

+ Payload func() T

Apr 16, 2026

Changes in this version

+ func CastContext[T any](ctx context.Context, mb *Mailbox, payload T) error

+ func Cast[T any](mb *Mailbox, payload T) error

+ func TryCastContext[T any](ctx context.Context, mb *Mailbox, payload T) error

+ func TryCast[T any](mb *Mailbox, payload T) error

+ type CallRequest struct

+ func (r CallRequest[T, R]) Payload() T

+ func (r CallRequest[T, R]) Reply(value R, err error)

+ type CastRequest struct

+ func (r CastRequest[T]) Payload() T

Apr 15, 2026

Changes in this version

type Supervisor

+ func NewSupervisor(opts ...SupervisorOption) *Supervisor

+ type SupervisorOption func(*Supervisor)

+ func WithOnError(fn func(error)) SupervisorOption

+ func WithOnRestart(fn func()) SupervisorOption

+ func WithPolicy(p RestartPolicy) SupervisorOption

+ func WithRestartDelay(d time.Duration) SupervisorOption

+ func WithRestartLimit(maxRestarts int, window time.Duration) SupervisorOption

Apr 15, 2026

Changes in this version

+ func TryCallContext[Req any, Res any](ctx context.Context, mb *Mailbox, message Req) (Res, error)

type Request

+ Message Req

Apr 15, 2026

Changes in this version

+ var ErrMaxRestartsExceeded = errors.New("max restarts exceeded")

type Mailbox

+ func (m *Mailbox[T]) IsClosed() bool

type Supervisor

+ OnRestart func()

+ func (s *Supervisor) Running() int

Apr 15, 2026

Changes in this version

type Mailbox

+ func (m *Mailbox[T]) Cap() int

+ func (m *Mailbox[T]) Len() int

Apr 15, 2026

Changes in this version

+ func CallContext[Req any, Res any](ctx context.Context, mb *Mailbox[any], msg Req) (Res, error)

+ func TryCall[Req any, Res any](mb *Mailbox[any], msg Req) (Res, error)

type Mailbox

+ func (m *Mailbox[T]) CastContext(ctx context.Context, msg T) (err error)

+ func (m *Mailbox[T]) TryCast(msg T) (err error)

Apr 15, 2026

Changes in this version

+ var ErrMailboxClosed = errors.New("mailbox is closed")

+ var ErrMailboxFull = errors.New("mailbox is full")

+ func Call[Req any, Res any](ctx context.Context, mb *Mailbox[any], msg Req) (Res, error)

+ type Mailbox struct

+ func NewMailbox[T any](size int) *Mailbox[T]

+ func (m *Mailbox[T]) Cast(msg T) error

+ func (m *Mailbox[T]) Close()

+ func (m *Mailbox[T]) Receive() <-chan T

+ type Request struct

+ Msg Req

+ func (r *Request[Req, Res]) Reply(val Res, err error)

+ type RestartPolicy uint8

+ const Permanent

+ const Temporary

+ const Transient

+ type Supervisor struct

+ MaxRestarts int

+ OnError func(error)

+ Policy RestartPolicy

+ RestartDelay time.Duration

+ RestartWindow time.Duration

+ func (s *Supervisor) Go(ctx context.Context, runFn func(context.Context) error)

+ func (s *Supervisor) Wait()