native

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

type ExecutorProvider interface {
	// GetExecutor returns an executor for the given app and agent.
	GetExecutor(ctx context.Context, appID, agentName string) (a2asrv.AgentExecutor, error)
}

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

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

type Queue interface {
	// Enqueue adds a task to the queue for processing.
	// Returns immediately - task will be processed by a worker.
	Enqueue(ctx context.Context, item *QueueItem) error

	// Dequeue retrieves the next task for processing.
	// The item is atomically marked as "processing".
	// Blocks until a task is available or context is cancelled.
	Dequeue(ctx context.Context) (*QueueItem, error)

	// Ack acknowledges successful task completion.
	// The task is marked as completed.
	Ack(ctx context.Context, itemID string) error

	// Nack negatively acknowledges - task failed, may retry.
	// If retry_count >= max_retries, task moves to dead-letter queue.
	Nack(ctx context.Context, itemID string, err error) error

	// Requeue moves a dead-letter item back to pending queue.
	Requeue(ctx context.Context, itemID string) error

	// RecoverStale finds items stuck in "processing" state and resets them.
	// Called on startup to handle items from crashed workers.
	RecoverStale(ctx context.Context, staleThreshold time.Duration) error

	// Stats returns queue statistics for an app.
	Stats(ctx context.Context, appName string) (*QueueStats, error)

	// ListDLQ returns items in dead-letter queue.
	ListDLQ(ctx context.Context, appName string, limit int) ([]*QueueItem, error)

	// Close gracefully shuts down the queue.
	Close() error
}

type QueueItem struct {
	// ID is the unique identifier for this queue item.
	ID string `json:"id"`

	// TaskID links to the a2a_tasks table for result storage.
	TaskID string `json:"task_id"`

	// AppName identifies the app (multi-tenant isolation).
	AppName string `json:"app_name"`

	// AgentName is the agent to invoke.
	AgentName string `json:"agent_name"`

	// Input is the user input/prompt for the agent.
	Input string `json:"input"`

	// ContextID is the session ID for conversation continuity.
	ContextID string `json:"context_id"`

	// UserID is the user identifier.
	UserID string `json:"user_id"`

	// Metadata contains additional task data.
	Metadata map[string]any `json:"metadata,omitempty"`

	// Priority affects dequeue order (higher = sooner).
	Priority int `json:"priority"`

	// MaxRetries is the maximum number of retry attempts.
	MaxRetries int `json:"max_retries"`

	// RetryCount is the current number of retry attempts.
	RetryCount int `json:"retry_count"`

	// Status is the current state of the queue item.
	Status QueueItemStatus `json:"status"`

	// EnqueuedAt is when the item was added to the queue.
	EnqueuedAt time.Time `json:"enqueued_at"`

	// ScheduledFor is when the item should be processed (for delayed execution).
	ScheduledFor time.Time `json:"scheduled_for"`

	// DeadlineAt is the deadline for task completion.
	DeadlineAt time.Time `json:"deadline_at"`

	// StartedAt is when processing started.
	StartedAt *time.Time `json:"started_at,omitempty"`

	// CompletedAt is when processing completed.
	CompletedAt *time.Time `json:"completed_at,omitempty"`

	// LastError is the most recent error message.
	LastError string `json:"last_error,omitempty"`

	// WorkerID is the ID of the worker processing this item.
	WorkerID string `json:"worker_id,omitempty"`
}

type QueueItemStatus string

type QueueStats struct {
	// Pending is the count of items waiting to be processed.
	Pending int64 `json:"pending"`

	// Processing is the count of items currently being processed.
	Processing int64 `json:"processing"`

	// Completed is the count of successfully completed items.
	Completed int64 `json:"completed"`

	// Failed is the count of failed items (may be retried).
	Failed int64 `json:"failed"`

	// DeadLetter is the count of items in dead-letter queue.
	DeadLetter int64 `json:"dead_letter"`

	// OldestPending is the age of the oldest pending item.
	OldestPending time.Duration `json:"oldest_pending"`

	// AvgProcessingTime is the average processing time for completed items.
	AvgProcessingTime time.Duration `json:"avg_processing_time"`
}

type RetryPolicy struct {
	// MaxRetries is the maximum number of retry attempts.
	MaxRetries int `yaml:"max_retries" json:"max_retries"`

	// InitialDelay is the delay before the first retry.
	InitialDelay time.Duration `yaml:"initial_delay" json:"initial_delay"`

	// MaxDelay is the maximum delay between retries.
	MaxDelay time.Duration `yaml:"max_delay" json:"max_delay"`

	// BackoffFactor is the multiplier for exponential backoff.
	BackoffFactor float64 `yaml:"backoff_factor" json:"backoff_factor"`
}

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

type SQLQueueOption func(*SQLQueue)

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

type WorkerPoolOptions struct {
	// NumWorkers is the number of concurrent workers.
	// Default: 4
	NumWorkers int

	// ShutdownTimeout is how long to wait for in-flight tasks during shutdown.
	// Default: 30 seconds
	ShutdownTimeout time.Duration

	// StaleRecoveryInterval is how often to check for stale "processing" items.
	// Default: 1 minute
	StaleRecoveryInterval time.Duration

	// StaleThreshold is how old a "processing" item must be to be considered stale.
	// Default: 5 minutes
	StaleThreshold time.Duration
}

type WorkerPoolStats struct {
	WorkerID   string `json:"worker_id"`
	NumWorkers int    `json:"num_workers"`
	Started    bool   `json:"started"`
	Stopped    bool   `json:"stopped"`
}