queue

type Config struct {
	// Redis configuration
	RedisAddr     string
	RedisPassword string
	RedisDB       int

	// Server configuration
	Concurrency int
	Queues      map[string]int // queue name -> priority

	// Retry configuration
	MaxRetry       int
	RetryDelayFunc func(n int, err error, task Task) time.Duration

	// Shutdown configuration
	ShutdownTimeout time.Duration
}

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

type RetryPolicy struct {
	MaxRetries   int
	InitialDelay time.Duration
	MaxDelay     time.Duration
	Multiplier   float64
	RetryOnError func(err error) bool
}

type Task struct {
	// Type is the task type identifier.
	Type string

	// Payload is the task payload data.
	Payload json.RawMessage

	// Queue is the queue name (defaults to "default").
	Queue string

	// MaxRetry is the maximum number of retries (defaults to 3).
	MaxRetry int

	// Timeout is the task execution timeout.
	Timeout time.Duration

	// Deadline is the absolute time by which the task must be processed.
	Deadline time.Time

	// Retention is how long to keep the completed task.
	Retention time.Duration

	// UniqueKey prevents duplicate tasks with the same key.
	UniqueKey string

	// UniqueTTL is how long to enforce uniqueness.
	UniqueTTL time.Duration

	// Group is used for task grouping.
	Group string
}