scheduler

type Storer interface {
	EnqueueTask(task *Task) error
	DequeueTask() (*Task, error)
}

type Task struct {
	Id         uuid.UUID   `json:"id"`
	Name       string      `json:"name"`
	Status     TaskStatus  `json:"status"`
	Details    interface{} `json:"details,omitempty"`
	Error      string      `json:"error,omitempty"`
	EnqueuedAt time.Time   `json:"enqueued_at,omitempty"`
	StartedAt  time.Time   `json:"started_at,omitempty"`
	FinishedAt time.Time   `json:"finished_at,omitempty"`
}

type TaskFunc interface {
	Execute(task *Task) (*Task, error)
}

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

type TaskStatus string