service

type JobRequest struct {
	TaskType   string         `json:"task_type"`
	Payload    any            `json:"payload"`
	Queue      string         `json:"queue,omitempty"`
	MaxRetries int            `json:"max_retries,omitempty"`
	Timeout    time.Duration  `json:"timeout,omitempty"`
	Metadata   map[string]any `json:"metadata,omitempty"`
}

type JobStatusResponse struct {
	ID             string               `json:"id"`
	TaskType       string               `json:"task_type"`
	Status         repository.JobStatus `json:"status"`
	Queue          string               `json:"queue"`
	ScheduledAt    *time.Time           `json:"scheduled_at,omitempty"`
	StartedAt      *time.Time           `json:"started_at,omitempty"`
	CompletedAt    *time.Time           `json:"completed_at,omitempty"`
	FailedAt       *time.Time           `json:"failed_at,omitempty"`
	RetryCount     int                  `json:"retry_count"`
	MaxRetries     int                  `json:"max_retries"`
	Error          string               `json:"error,omitempty"`
	Result         json.RawMessage      `json:"result,omitempty"`
	CronExpression string               `json:"cron_expression,omitempty"`
	CreatedAt      time.Time            `json:"created_at"`
	UpdatedAt      time.Time            `json:"updated_at"`
}

type QueueStats struct {
	Queue     string `json:"queue"`
	Size      int    `json:"size"`
	Pending   int    `json:"pending"`
	Active    int    `json:"active"`
	Scheduled int    `json:"scheduled"`
	Retry     int    `json:"retry"`
	Archived  int    `json:"archived"`
	Completed int    `json:"completed"`
	Processed int    `json:"processed"`
	Failed    int    `json:"failed"`
}

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