taskqueue

type QueueType string

type Task struct {
	// ID is the ID of the task.
	ID string `json:"id"`

	// Queue is the queue of the task.
	Queue QueueType `json:"queue"`

	// Payload is the payload of the task.
	Payload map[string]interface{} `json:"payload"`

	// Metadata is the metadata of the task.
	Metadata map[string]interface{} `json:"metadata"`

	// Retries is the number of retries for the task.
	Retries int `json:"retries"`

	// RetryDelay is the delay between retries.
	RetryDelay int `json:"retry_delay"`
}

type TaskQueue interface {
	// AddTask adds a task to the queue. Implementations should ensure that Start().
	AddTask(ctx context.Context, queue QueueType, task *Task) error

	// Subscribe subscribes to the task queue.
	Subscribe(ctx context.Context, queueType QueueType) (<-chan *Task, error)
}