core

Aug 19, 2026

Changes in this version

+ func IsUnavailable(err error) bool

+ func Unavailable(reason string, err error) error

type Outcome

+ Deferred bool

+ type RetryLimits struct

+ MaxAttempts int

+ MaxDefer time.Duration

+ type UnavailableError struct

+ Err error

+ Reason string

+ func (e *UnavailableError) Error() string

+ func (e *UnavailableError) Unwrap() error

Aug 19, 2026

Changes in this version

+ var ErrLeaseLost = errors.New("lease lost")

+ var ErrUnknownDriver = errors.New("unknown driver")

+ var ErrUnknownStream = errors.New("unknown stream")

+ func IsPermanent(err error) bool

+ func Permanent(reason string, err error) error

+ type BackoffPolicy struct

+ Base time.Duration

+ Jitter float64

+ Max time.Duration

+ func (p BackoffPolicy) Next(attempts int) time.Duration

+ type Lease struct

+ Owner string

+ Token string

+ Until time.Time

+ type Message struct

+ Attempts int

+ CreatedAt time.Time

+ Headers map[string]string

+ ID string

+ Payload []byte

+ Stream string

+ Target Target

+ Topic string

+ type Outcome struct

+ Delay time.Duration

+ Err error

+ ID string

+ Permanent bool

+ type PermanentError struct

+ Err error

+ Reason string

+ func (e *PermanentError) Error() string

+ func (e *PermanentError) Unwrap() error

+ type Status int16

+ const StatusFailed

+ const StatusPending

+ const StatusProcessing

+ const StatusSent

+ func (s Status) String() string

+ func (s Status) Valid() bool

+ type Target struct

+ Exchange string

+ Key string

+ RoutingKey string

+ Version int