Versions in this module Expand all Collapse all v2 v2.0.1 Jul 7, 2026 v2.0.0 Jul 7, 2026 Changes in this version + var ErrActorNotFound = actorlayer.ErrActorNotFound + type AddressResolver func(envelope any) (string, error) + type Config struct + LaneIdleTTL time.Duration + Resolver Resolver + Retry RetryPolicy + Sink EventSink + type Delivery interface + Ack func(ctx context.Context) error + Attempt func() int + DeadLetter func(ctx context.Context, reason string) error + Envelope func() any + InProgress func(ctx context.Context) error + MaxAttempts func() int + Retry func(ctx context.Context, delay time.Duration, reason string) error + type DispatchRuntime struct + func NewDispatchRuntime(cfg RuntimeConfig) (*DispatchRuntime, error) + func (r *DispatchRuntime) Handle(ctx context.Context, delivery Delivery) error + func (r *DispatchRuntime) LaneStatus() LaneStatus + func (r *DispatchRuntime) Run(ctx context.Context, source Source) error + type Event struct + Attempt int + MaxAttempts int + Reason string + RetryDelay time.Duration + Type EventType + type EventSink interface + Publish func(ctx context.Context, event Event) + type EventType string + const EventAcked + const EventDeadLettered + const EventInProgress + const EventRetrying + const EventRunning + type Handler func(ctx context.Context, delivery Delivery) error + type LaneKeyResolver func(envelope any) string + type LaneStatus struct + Active int + Keys []string + type ResolveError struct + Address string + func (e *ResolveError) Error() string + func (e *ResolveError) Unwrap() error + type Resolver interface + LaneKey func(delivery Delivery) string + type RetryPolicy struct + Backoff func(attempt int) time.Duration + IsRetryable func(error) bool + RetryExhausted func(delivery Delivery) bool + type Runtime struct + func New(cfg Config) (*Runtime, error) + func (r *Runtime) EmitInProgress(ctx context.Context, delivery Delivery) + func (r *Runtime) Handle(ctx context.Context, delivery Delivery, handler Handler) error + func (r *Runtime) LaneStatus() LaneStatus + func (r *Runtime) Run(ctx context.Context, src Source, handler Handler) error + type RuntimeConfig struct + AddressOf AddressResolver + LaneIdleTTL time.Duration + LaneKey LaneKeyResolver + Registry dispatch.Registry + Retry RetryPolicy + Sink EventSink + type Source interface + Run func(ctx context.Context, handler Handler) error Other modules containing this package github.com/normahq/norma
Go to main page