cron

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

type Job struct {
	ID                string        `json:"id"`
	Name              string        `json:"name"`
	Description       string        `json:"description,omitempty"`
	Enabled           bool          `json:"enabled"`
	Schedule          Schedule      `json:"schedule"`
	SessionTarget     SessionTarget `json:"session_target"`
	Payload           string        `json:"payload"`
	DeleteAfterRun    bool          `json:"delete_after_run,omitempty"`
	ConsecutiveErrors int           `json:"consecutive_errors"`
	LastRunAt         *time.Time    `json:"last_run_at,omitempty"`
	LastStatus        RunStatus     `json:"last_status,omitempty"`
	NextRunAt         *time.Time    `json:"next_run_at,omitempty"`
	MaxRetries        int           `json:"max_retries"`
	CreatedAt         time.Time     `json:"created_at"`
}

type JobHandler func(job *Job) error

type RunRecord struct {
	Timestamp  time.Time `json:"timestamp"`
	JobID      string    `json:"job_id"`
	Status     RunStatus `json:"status"`
	DurationMs int64     `json:"duration_ms"`
	Error      string    `json:"error,omitempty"`
}

type RunStatus string

type Schedule struct {
	Kind  ScheduleKind  `json:"kind"`
	At    *time.Time    `json:"at,omitempty"`
	Every time.Duration `json:"every,omitempty"`
}

type ScheduleKind string

type SessionTarget string