scheduler

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

type ClusterScheduler struct {
	*Scheduler
	// contains filtered or unexported fields
}

type ClusterTaskState struct {
	TaskName     string    `json:"task_name"`
	LastRun      time.Time `json:"last_run"`
	NextRun      time.Time `json:"next_run"`
	LastNodeID   string    `json:"last_node_id"`
	LastHostname string    `json:"last_hostname"`
	UpdatedAt    time.Time `json:"updated_at"`
}

type NotifyFunc func(notification *TaskFailureNotification)

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

type Task struct {
	ID          TaskID
	Name        string
	Description string
	Schedule    string   // Cron expression or @every interval
	TaskType    TaskType // Global or Local
	Run         func(ctx context.Context) error
	Skippable   bool // Can admin disable this task?
	RunOnStart  bool // Run immediately on scheduler start?

	// Retry policy per AI.md PART 19
	// Default: max_retries=3, retry_delay=5m, backoff=exponential (5m, 10m, 20m)
	MaxRetries int           // Maximum retry attempts (default: 3)
	RetryDelay time.Duration // Base delay between retries (default: 5m)

	// Runtime state (persisted to database)
	LastRun    time.Time
	LastStatus TaskStatus
	LastError  string
	NextRun    time.Time
	RunCount   int64
	FailCount  int64
	Enabled    bool

	// Retry state
	RetryCount int       // Current retry attempt (0 = first run)
	NextRetry  time.Time // Scheduled retry time (if retrying)

	// Cluster locking
	LockedBy string
	LockedAt time.Time
}

type TaskExecution struct {
	ID          int64     `json:"id"`
	TaskName    string    `json:"task_name"`
	NodeID      string    `json:"node_id"`
	Hostname    string    `json:"hostname"`
	Status      string    `json:"status"` // running, completed, failed
	StartedAt   time.Time `json:"started_at"`
	CompletedAt time.Time `json:"completed_at,omitempty"`
	Error       string    `json:"error,omitempty"`
	ScheduledAt time.Time `json:"scheduled_at"`
}

type TaskFailureNotification struct {
	TaskID    string
	TaskName  string
	Error     string
	Attempts  int
	LastRun   time.Time
	FailCount int64
}

type TaskHandlers struct {
	SSLRenewal       func(ctx context.Context) error
	GeoIPUpdate      func(ctx context.Context) error
	BlocklistUpdate  func(ctx context.Context) error
	CVEUpdate        func(ctx context.Context) error
	SessionCleanup   func(ctx context.Context) error
	TokenCleanup     func(ctx context.Context) error
	LogRotation      func(ctx context.Context) error
	BackupDaily      func(ctx context.Context) error
	BackupHourly     func(ctx context.Context) error
	HealthcheckSelf  func(ctx context.Context) error
	TorHealth        func(ctx context.Context) error
	ClusterHeartbeat func(ctx context.Context) error
}

type TaskID string

type TaskInfo struct {
	ID          string    `json:"id"`
	Name        string    `json:"name"`
	Description string    `json:"description"`
	Schedule    string    `json:"schedule"`
	TaskType    string    `json:"task_type"`
	LastRun     time.Time `json:"last_run"`
	LastStatus  string    `json:"last_status"`
	LastError   string    `json:"last_error,omitempty"`
	NextRun     time.Time `json:"next_run"`
	RunCount    int64     `json:"run_count"`
	FailCount   int64     `json:"fail_count"`
	Enabled     bool      `json:"enabled"`
	Skippable   bool      `json:"skippable"`

	// Retry state per AI.md PART 19
	RetryCount int       `json:"retry_count"`
	NextRetry  time.Time `json:"next_retry,omitempty"`
	MaxRetries int       `json:"max_retries"`
}

type TaskLock struct {
	TaskName   string    `json:"task_name"`
	NodeID     string    `json:"node_id"`
	Hostname   string    `json:"hostname"`
	AcquiredAt time.Time `json:"acquired_at"`
	ExpiresAt  time.Time `json:"expires_at"`
}

type TaskState struct {
	TaskID     string
	TaskName   string
	Schedule   string
	LastRun    time.Time
	LastStatus string
	LastError  string
	NextRun    time.Time
	RunCount   int64
	FailCount  int64
	Enabled    bool
	LockedBy   string
	LockedAt   time.Time
}

type TaskStatus string

type TaskType string