tasks

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

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

type QueueStats struct {
	TasksCount      int64
	OldestTaskAge   time.Duration
	ExecutedLastMin int64
	ConcurrentTasks int64
}

type RetryConfig struct {
	MaxAttempts      int           // Maximum number of attempts
	MaxRetryDuration time.Duration // Maximum time to retry
	MinBackoff       time.Duration // Minimum backoff duration
	MaxBackoff       time.Duration // Maximum backoff duration
	MaxDoublings     int           // Maximum number of backoff doublings
}

type Task struct {
	Name        string            // Task name (optional, will be generated if empty)
	Queue       string            // Queue name
	URL         string            // Target URL for HTTP tasks
	Method      string            // HTTP method (GET, POST, etc.)
	Headers     map[string]string // HTTP headers
	Payload     interface{}       // Task payload (will be JSON encoded)
	ScheduleAt  time.Time         // When to execute the task
	RetryConfig *RetryConfig      // Retry configuration
}

type TaskQueue interface {
	// CreateTask creates a new task in the queue
	CreateTask(ctx context.Context, task *Task) error

	// CreateHTTPTask creates an HTTP task
	CreateHTTPTask(ctx context.Context, queueName string, url string, payload interface{}) error

	// DeleteTask deletes a task from the queue
	DeleteTask(ctx context.Context, queueName string, taskName string) error

	// PurgeQueue purges all tasks from a queue
	PurgeQueue(ctx context.Context, queueName string) error

	// GetQueueStats returns statistics for a queue
	GetQueueStats(ctx context.Context, queueName string) (*QueueStats, error)
}