task

type Manager interface {
	common.Service
	common.Daemon
	Add(tasks ...*Task) error
	Remove(tasks ...*Task)
	Stats(id string) *executor.Stats
}

type Option func(*manager)

type Task struct {
	Job           job.Job         `json:"-"`
	Ctx           context.Context `json:"-"`
	Params        any             `json:"params"`
	Schedule      string          `json:"schedule"`
	Priority      int             `json:"priority"`
	Exclusive     bool            `json:"exclusive"`
	Timeout       time.Duration   `json:"timeout,omitempty"`
	Cooldown      time.Duration   `json:"cooldown,omitempty"`
	Once          bool            `json:"once"`
	RetryAttempts int             `json:"retry_attempts,omitempty"`
	RetryDelay    time.Duration   `json:"retry_delay,omitempty"`
}