queue

type ClaimedOutboxEntry struct {
	ID         string
	Message    *job.ExecutionMessage
	Attempts   int
	Status     string
	LeaseOwner string
	LeaseToken string
	LeaseUntil time.Time
	RetryAt    time.Time
	CreatedAt  time.Time
	LastError  string
}

type Delivery interface {
	Message() *job.ExecutionMessage
	Ack(ctx context.Context) error
	Nack(ctx context.Context, opts NackOptions) error
}

type Dequeuer interface {
	Dequeue(ctx context.Context) (Delivery, error)
}

type DispatchState string

type DispatchStatus struct {
	DispatchID     string
	State          DispatchState
	Attempt        int
	EnqueuedAt     *time.Time
	UpdatedAt      *time.Time
	NextRunAt      *time.Time
	TerminalReason string
}

type DispatchStatusReader interface {
	GetDispatchStatus(ctx context.Context, dispatchID string) (DispatchStatus, error)
}

type EnqueueReceipt struct {
	DispatchID string
	EnqueuedAt time.Time
}

type Enqueuer interface {
	Enqueue(ctx context.Context, msg *job.ExecutionMessage) (EnqueueReceipt, error)
}

type LeaseExtender interface {
	ExtendLease(ctx context.Context, ttl time.Duration) error
}

type LeaseStorage interface {
	ExtendLease(ctx context.Context, receipt Receipt, ttl time.Duration) error
}

type NackDisposition string

type NackOptions struct {
	Disposition NackDisposition
	Delay       time.Duration
	Reason      string
}

type OutboxStore interface {
	ClaimPending(ctx context.Context, workerID string, limit int, leaseTTL time.Duration) ([]ClaimedOutboxEntry, error)
	MarkCompleted(ctx context.Context, id, leaseToken string) error
	MarkFailed(ctx context.Context, id, leaseToken string, retryAt time.Time, reason string) error
	ExtendLease(ctx context.Context, id, leaseToken string, leaseTTL time.Duration) error
}

type Receipt struct {
	ID          string
	Token       string
	Attempts    int
	LeasedAt    time.Time
	AvailableAt time.Time
	CreatedAt   time.Time
	LastError   string
}

type ScheduledEnqueuer interface {
	Enqueuer
	EnqueueAt(ctx context.Context, msg *job.ExecutionMessage, at time.Time) (EnqueueReceipt, error)
	EnqueueAfter(ctx context.Context, msg *job.ExecutionMessage, delay time.Duration) (EnqueueReceipt, error)
}

type ScheduledStorage interface {
	EnqueueAt(ctx context.Context, msg *job.ExecutionMessage, at time.Time) (EnqueueReceipt, error)
	EnqueueAfter(ctx context.Context, msg *job.ExecutionMessage, delay time.Duration) (EnqueueReceipt, error)
}

type Storage interface {
	Enqueue(ctx context.Context, msg *job.ExecutionMessage) (EnqueueReceipt, error)
	Dequeue(ctx context.Context) (*job.ExecutionMessage, Receipt, error)
	Ack(ctx context.Context, receipt Receipt) error
	Nack(ctx context.Context, receipt Receipt, opts NackOptions) error
}

type StorageOutboxAdapter struct {
	// contains filtered or unexported fields
}

type StorageOutboxOption func(*StorageOutboxAdapter)