model

type CduleRepository interface {
	CreateWorker(worker *Worker) (*Worker, error)
	UpdateWorker(worker *Worker) (*Worker, error)
	GetWorker(workerID string) (*Worker, error)
	GetWorkers() ([]Worker, error)
	DeleteWorker(workerID string) (*Worker, error)

	CreateJob(job *Job) (*Job, error)
	UpdateJob(job *Job) (*Job, error)
	GetJob(jobID int64) (*Job, error)
	GetJobByName(name string) (*Job, error)
	DeleteJob(jobID int64) (*Job, error)

	CreateJobHistory(jobHistory *JobHistory) (*JobHistory, error)
	UpdateJobHistory(jobHistory *JobHistory) (*JobHistory, error)
	GetJobHistory(jobID int64) ([]JobHistory, error)
	GetJobHistoryWithLimit(jobID int64, limit int) ([]JobHistory, error)
	GetJobHistoryForSchedule(scheduleID int64) (*JobHistory, error)
	DeleteJobHistory(jobID int64) ([]JobHistory, error)

	CreateSchedule(schedule *Schedule) (*Schedule, error)
	UpdateSchedule(schedule *Schedule) (*Schedule, error)
	GetSchedule(scheduleID int64) (*Schedule, error)
	GetScheduleBetween(scheduleStart, scheduleEnd int64, workerID string) ([]Schedule, error)
	GetSchedulesForJob(jobID int64) ([]Schedule, error)
	GetSchedulesForWorker(workerID string) ([]Schedule, error)
	DeleteScheduleForJob(jobID int64) ([]Schedule, error)
	DeleteScheduleForWorker(workerID string) ([]Schedule, error)
}

type Job struct {
	Model
	JobName        string `json:"job_name"`
	GroupName      string `json:"group_name"`
	CronExpression string `json:"cron"`
	Expired        bool   `json:"expired"`
	JobData        string `json:"job_data"`
}

type JobHistory struct {
	Model
	JobID       int64          `json:"job_id"`
	ExecutionID int64          `json:"execution_id"`
	DeletedAt   gorm.DeletedAt `gorm:"index"`
	Status      JobStatus      `json:"status"`
	WorkerID    string         `json:"worker_id"`
	RetryCount  int            `json:"retry_count"`
}

type JobStatus string

type Model struct {
	ID        int64 `gorm:"primarykey"`
	CreatedAt time.Time
	UpdatedAt time.Time
	DeletedAt gorm.DeletedAt `gorm:"index"`
}

type Repositories struct {
	CduleRepository CduleRepository
	DB              *gorm.DB
}

type Schedule struct {
	ExecutionID int64 `gorm:"primaryKey",json:"execution_id"`
	JobID       int64 `gorm:"primaryKey",json:"job_id"`
	CreatedAt   time.Time
	UpdatedAt   time.Time
	DeletedAt   gorm.DeletedAt `gorm:"index"`
	WorkerID    string         `json:"worker_id"`
	JobData     string         `json:"job_data"`
}

type Worker struct {
	WorkerID  string `gorm:"primaryKey",json:"worker_id"`
	CreatedAt time.Time
	UpdatedAt time.Time
	DeletedAt gorm.DeletedAt `gorm:"index"`
}