Versions in this module Expand all Collapse all v1 v1.2.0 Sep 3, 2026 v1.1.0 Sep 2, 2026 v1.0.1 Aug 29, 2026 v1.0.0 Aug 29, 2026 Changes in this version + const EnvelopeVersion + const KindReport + var ErrLocked = errors.New("queue is locked") + func NewEnvelopeID(now time.Time) string + func Permanent(err error) error + func RegistryObservation(report Report) registry.Observation + func RegistryReport(report Report) registry.Observation + func RootForStore(storePath string) string + type DrainOptions struct + LeaseTimeout time.Duration + MaxItems int + Now func() time.Time + Processor Processor + type DrainResult struct + Dead int + Locked bool + Processed int + Recovered int + Retried int + Succeeded int + type EnqueueOptions struct + Now func() time.Time + type EnqueueResult struct + ID string + Path string + type Envelope struct + Attempt int + CachedTmux registry.TmuxContext + CreatedAt time.Time + ID string + Kind string + LastError string + NextAttemptAt time.Time + NoTmux bool + ProcessingStartedAt time.Time + RawPayloadSet bool + Report Report + Runtime RuntimeContext + StorePath string + Version int + WorkerPID int + type PermanentError struct + Err error + func (e PermanentError) Error() string + func (e PermanentError) Unwrap() error + type Processor func(context.Context, Envelope) error + type Queue struct + func New(storePath string) Queue + func (q Queue) Drain(ctx context.Context, options DrainOptions) (DrainResult, error) + func (q Queue) Enqueue(ctx context.Context, envelope Envelope, options EnqueueOptions) (EnqueueResult, error) + func (q Queue) LookupTmuxContext(reference registry.TmuxContext, now time.Time, ttl time.Duration) (registry.TmuxContext, bool) + func (q Queue) Root() string + func (q Queue) Status(ctx context.Context) (StatusResult, error) + func (q Queue) StoreTmuxContext(ctx context.Context, tmux registry.TmuxContext, now time.Time) error + type Report = registry.Observation + func ReportFromRegistry(observation registry.Observation) Report + type RuntimeContext struct + CWD string + Env map[string]string + ParentArgs []string + type StatusResult struct + Dead int + Deferred int + Invalid int + NextRetryAt time.Time + OldestBacklogAt time.Time + OldestDeadAt time.Time + OldestPendingAt time.Time + OldestProcessingAt time.Time + Pending int + Processing int + Ready int + Retries int + Root string + StaleLeases int
Go to main page