ctq

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

type DB struct {
	*alfredo.DatabaseStruct
}

type Task struct {
	ID              int64             `json:"id"`
	Name            string            `json:"name"`
	Enabled         bool              `json:"enabled"`
	Priority        int               `json:"priority"`
	CooldownSeconds int               `json:"cooldown_seconds"`
	MaxRetries      int               `json:"max_retries"`
	Requeue         bool              `json:"requeue"`
	TaskType        string            `json:"task_type"`
	Args            string            `json:"args"` // JSON string
	CreatedAt       alfredo.EpochTime `json:"created_at"`
	UpdatedAt       alfredo.EpochTime `json:"updated_at"`
}

type TaskExecution struct {
	ID           int64      `json:"id"`
	TaskID       int64      `json:"task_id"`
	StartedAt    *time.Time `json:"started_at"`
	FinishedAt   *time.Time `json:"finished_at"`
	Status       string     `json:"status"`
	ErrorMessage *string    `json:"error_message"`
	RetryCount   int        `json:"retry_count"`
	WorkerID     *string    `json:"worker_id"`
	DurationMs   *int64     `json:"duration_ms"`
}

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

type TaskWithExecution struct {
	Task          Task
	LastExecution *TaskExecution
}

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