queue

type AttemptListRequest struct {
	Route   string
	Target  string
	EventID string
	Outcome AttemptOutcome
	Limit   int
	Before  time.Time
}

type AttemptListResponse struct {
	Items []DeliveryAttempt
}

type AttemptOutcome string

type BacklogBucket struct {
	Route  string
	Target string
	Queued int

	OldestQueuedReceivedAt time.Time
	EarliestQueuedNextRun  time.Time
	OldestQueuedAge        time.Duration
	ReadyLag               time.Duration
}

type BacklogTrendListRequest struct {
	Route  string
	Target string
	Since  time.Time
	Until  time.Time
	Limit  int
}

type BacklogTrendListResponse struct {
	Items     []BacklogTrendSample
	Truncated bool
}

type BacklogTrendOperatorAction struct {
	ID              string
	Severity        string
	AlertRoutingKey string
	Summary         string
	Playbook        string
	Alerts          []string
	MCPTools        []string
	AdminEndpoints  []string
}

type BacklogTrendSample struct {
	CapturedAt time.Time
	Queued     int
	Leased     int
	Dead       int
}

type BacklogTrendSignalConfig struct {
	Window                  time.Duration
	ExpectedCaptureInterval time.Duration
	StaleGraceFactor        int

	SustainedGrowthConsecutive int
	SustainedGrowthMinSamples  int
	SustainedGrowthMinDelta    int

	RecentSurgeMinTotal int
	RecentSurgeMinDelta int
	RecentSurgePercent  int

	DeadShareHighMinTotal int
	DeadShareHighPercent  int

	QueuedPressureMinTotal         int
	QueuedPressurePercent          int
	QueuedPressureLeasedMultiplier int
}

type BacklogTrendSignalOptions struct {
	Now                     time.Time
	Window                  time.Duration
	ExpectedCaptureInterval time.Duration
	Config                  BacklogTrendSignalConfig
}

type BacklogTrendSignals struct {
	Status                  string
	Window                  time.Duration
	ExpectedCaptureInterval time.Duration
	Since                   time.Time
	Until                   time.Time
	SampleCount             int
	Truncated               bool

	LatestCapturedAt time.Time
	LatestQueued     int
	LatestLeased     int
	LatestDead       int
	LatestTotal      int

	BaselineTotal        int
	DeltaTotal           int
	DeltaPercent         int
	GrowthRatePerMinute  float64
	ConsecutiveIncreases int

	SustainedGrowth bool
	RecentSurge     bool

	DeadSharePercent   int
	DeadShareHigh      bool
	QueuedSharePercent int
	QueuedPressure     bool

	FreshnessSeconds int
	SamplingStale    bool
	ActiveAlerts     []string
}

type BacklogTrendStore interface {
	CaptureBacklogTrendSample(at time.Time) error
	ListBacklogTrend(req BacklogTrendListRequest) (BacklogTrendListResponse, error)
}

type BatchEnqueuer interface {
	EnqueueBatch(items []Envelope) (int, error)
}

type DeadDeleteRequest struct {
	IDs []string
}

type DeadDeleteResponse struct {
	Deleted int
}

type DeadListRequest struct {
	Route          string
	Limit          int
	Before         time.Time
	IncludePayload bool
	IncludeHeaders bool
	IncludeTrace   bool
}

type DeadListResponse struct {
	Items []Envelope
}

type DeadRequeueRequest struct {
	IDs []string
}

type DeadRequeueResponse struct {
	Requeued int
}

type DeliveryAttempt struct {
	ID         string
	EventID    string
	Route      string
	Target     string
	Attempt    int
	StatusCode int
	Error      string
	Outcome    AttemptOutcome
	DeadReason string
	CreatedAt  time.Time
}

type DequeueRequest struct {
	Route       string
	Target      string
	Batch       int
	MaxWait     time.Duration
	LeaseTTL    time.Duration
	Now         time.Time
	AllowLeased bool
}

type DequeueResponse struct {
	Items []Envelope
}

type Envelope struct {
	ID            string
	Route         string
	Target        string
	State         State
	ReceivedAt    time.Time
	Attempt       int
	NextRunAt     time.Time
	Payload       []byte
	Headers       map[string]string
	Trace         map[string]string
	DeadReason    string
	SchemaVersion int
	LeaseID       string
	LeaseUntil    time.Time
}

type HistogramBucket struct {
	Le    float64
	Count int64
}

type HistogramSnapshot struct {
	Buckets []HistogramBucket
	Count   int64
	Sum     float64
}

type LeaseBatchConflict struct {
	LeaseID string
	Expired bool
}

type LeaseBatchResult struct {
	Succeeded int
	Conflicts []LeaseBatchConflict
}

type LeaseBatchStore interface {
	AckBatch(leaseIDs []string) (LeaseBatchResult, error)
	NackBatch(leaseIDs []string, delay time.Duration) (LeaseBatchResult, error)
	MarkDeadBatch(leaseIDs []string, reason string) (LeaseBatchResult, error)
}

type MemoryOption func(*MemoryStore)

type MemoryPressureRuntimeMetrics struct {
	Active             bool
	Reason             string
	RetainedItems      int64
	RetainedBytes      int64
	RetainedItemLimit  int64
	RetainedBytesLimit int64
	RejectTotal        int64
}

type MemoryRuntimeMetrics struct {
	ItemsByState           map[State]int64
	RetainedBytesByState   map[State]int64
	RetainedBytesTotal     int64
	EvictionsTotalByReason map[string]int64
	Pressure               MemoryPressureRuntimeMetrics
}

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

type MessageCancelRequest struct {
	IDs []string
}

type MessageCancelResponse struct {
	Canceled    int
	Matched     int
	PreviewOnly bool
}

type MessageListRequest struct {
	Route          string
	Target         string
	State          State
	Order          string
	Limit          int
	Before         time.Time
	IncludePayload bool
	IncludeHeaders bool
	IncludeTrace   bool
}

type MessageListResponse struct {
	Items []Envelope
}

type MessageLookupItem struct {
	ID    string
	Route string
	State State
}

type MessageLookupRequest struct {
	IDs []string
}

type MessageLookupResponse struct {
	Items []MessageLookupItem
}

type MessageManageFilterRequest struct {
	Route       string
	Target      string
	State       State
	Limit       int
	Before      time.Time
	PreviewOnly bool
}

type MessageRequeueRequest struct {
	IDs []string
}

type MessageRequeueResponse struct {
	Requeued    int
	Matched     int
	PreviewOnly bool
}

type MessageResumeRequest struct {
	IDs []string
}

type MessageResumeResponse struct {
	Resumed     int
	Matched     int
	PreviewOnly bool
}

type PostgresOption func(*PostgresStore)

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

type RuntimeMetricsProvider interface {
	RuntimeMetrics() StoreRuntimeMetrics
}

type SQLiteOption func(*SQLiteStore)

type SQLiteRuntimeMetrics struct {
	WriteDurationSeconds      HistogramSnapshot
	DequeueDurationSeconds    HistogramSnapshot
	CheckpointDurationSeconds HistogramSnapshot
	BusyTotal                 int64
	RetryTotal                int64
	TxCommitTotal             int64
	TxRollbackTotal           int64
	CheckpointTotal           int64
	CheckpointErrorTotal      int64
}

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

type State string

type Stats struct {
	Total   int
	ByState map[State]int

	OldestQueuedReceivedAt time.Time
	EarliestQueuedNextRun  time.Time
	OldestQueuedAge        time.Duration
	ReadyLag               time.Duration

	TopQueued []BacklogBucket
}

type Store interface {
	Enqueue(env Envelope) error
	Dequeue(req DequeueRequest) (DequeueResponse, error)
	Ack(leaseID string) error
	Nack(leaseID string, delay time.Duration) error
	Extend(leaseID string, extendBy time.Duration) error
	MarkDead(leaseID string, reason string) error
	ListDead(req DeadListRequest) (DeadListResponse, error)
	RequeueDead(req DeadRequeueRequest) (DeadRequeueResponse, error)
	DeleteDead(req DeadDeleteRequest) (DeadDeleteResponse, error)
	ListMessages(req MessageListRequest) (MessageListResponse, error)
	LookupMessages(req MessageLookupRequest) (MessageLookupResponse, error)
	CancelMessages(req MessageCancelRequest) (MessageCancelResponse, error)
	RequeueMessages(req MessageRequeueRequest) (MessageRequeueResponse, error)
	ResumeMessages(req MessageResumeRequest) (MessageResumeResponse, error)
	CancelMessagesByFilter(req MessageManageFilterRequest) (MessageCancelResponse, error)
	RequeueMessagesByFilter(req MessageManageFilterRequest) (MessageRequeueResponse, error)
	ResumeMessagesByFilter(req MessageManageFilterRequest) (MessageResumeResponse, error)
	Stats() (Stats, error)
	RecordAttempt(attempt DeliveryAttempt) error
	ListAttempts(req AttemptListRequest) (AttemptListResponse, error)
}

type StoreCommonRuntimeMetrics struct {
	OperationDurationSeconds []StoreOperationDurationRuntimeMetric
	OperationTotal           []StoreOperationCounterRuntimeMetric
	ErrorsTotal              []StoreOperationErrorRuntimeMetric
}

type StoreOperationCounterRuntimeMetric struct {
	Operation string
	Total     int64
}

type StoreOperationDurationRuntimeMetric struct {
	Operation       string
	DurationSeconds HistogramSnapshot
}

type StoreOperationErrorRuntimeMetric struct {
	Operation string
	Kind      string
	Total     int64
}

type StoreRuntimeMetrics struct {
	Backend string
	Common  StoreCommonRuntimeMetrics
	SQLite  *SQLiteRuntimeMetrics
	Memory  *MemoryRuntimeMetrics
}