xjm

type Job struct {
	ID        int64     `gorm:"not null;primaryKey;autoIncrement" json:"id,omitempty"`
	RID       int64     `gorm:"column:rid;not null" json:"rid,omitempty"`
	Name      string    `gorm:"size:250;not null;index" json:"name,omitempty"`
	Status    string    `gorm:"size:1;not null" json:"status,omitempty"`
	File      string    `gorm:"not null" json:"file,omitempty"`
	Param     string    `gorm:"not null" json:"param,omitempty"`
	State     string    `gorm:"not null" form:"state" json:"state,omitempty"`
	Result    string    `gorm:"not null" json:"result,omitempty"`
	Error     string    `gorm:"not null" json:"error,omitempty"`
	CreatedAt time.Time `gorm:"not null;<-:create" json:"created_at,omitempty"`
	UpdatedAt time.Time `gorm:"not null" json:"updated_at,omitempty"`
}

type JobChain struct {
	ID        int64     `gorm:"not null;primaryKey;autoIncrement" form:"id" json:"id"`
	Name      string    `gorm:"size:250;not null" form:"title,strip" json:"title"`
	Status    string    `gorm:"size:1;not null" form:"status,strip" json:"status"`
	States    string    `gorm:"not null" form:"states" json:"states,omitempty"`
	CreatedAt time.Time `gorm:"not null;<-:create" json:"created_at"`
	UpdatedAt time.Time `gorm:"not null" json:"updated_at"`
}

type JobChainer interface {
	// GetJobChain get a job chain
	GetJobChain(cid int64) (*JobChain, error)

	// FindJobChain find a job chain
	// name: name to filter (optional)
	// status: status to filter (optional)
	FindJobChain(name string, asc bool, status ...string) (*JobChain, error)

	// FindJobChains find job chains
	// name: name to filter (optional)
	// status: status to filter (optional)
	FindJobChains(name string, start, limit int, asc bool, status ...string) ([]*JobChain, error)

	// IterJobChains find job chains and iterate
	// name: name to filter (optional)
	// status: status to filter (optional)
	IterJobChains(it func(*JobChain) error, name string, start, limit int, asc bool, status ...string) error

	// CreateJobChain create a job chain
	CreateJobChain(name, states string) (int64, error)

	// UpcateJobChain update the job chain, ignore empty status, states
	UpdateJobChain(cid int64, status string, states ...string) error

	// DeleteJobChains delete job chains
	DeleteJobChains(cids ...int64) (int64, error)

	// CleanOutdatedJobChains delete outdated job chains
	CleanOutdatedJobChains(before time.Time) (int64, error)
}

type JobLog struct {
	ID      int64     `gorm:"not null;primaryKey;autoIncrement" json:"id,omitempty"`
	JID     int64     `gorm:"column:jid;not null;index:idx_job_logs_jid" json:"jid,omitempty"`
	Time    time.Time `gorm:"not null" json:"time,omitempty"`
	Level   string    `gorm:"size:1;not null" json:"level,omitempty"`
	Message string    `gorm:"not null" json:"message,omitempty"`
}

type JobLogWriter struct {
	log.LogFilter
	log.BatchWriter
	// contains filtered or unexported fields
}

type JobManager interface {
	// CountJobLogs count job logs
	CountJobLogs(jid int64, levels ...string) (int64, error)

	// GetJobLogs get job logs
	// set levels to ("I", "W", "E", "F") to filter DEBUG/TRACE logs
	GetJobLogs(jid int64, min, max int64, asc bool, limit int, levels ...string) ([]*JobLog, error)

	// AddJobLogs append job logs
	AddJobLogs([]*JobLog) error

	// AddJobLog append a job log
	AddJobLog(jid int64, time time.Time, level string, message string) error

	// GetJob get a job
	GetJob(jid int64) (*Job, error)

	// FindJob find a job
	// name: name to filter (optional)
	// status: status to filter (optional)
	FindJob(name string, asc bool, status ...string) (*Job, error)

	// FindJobs find jobs
	// name: name to filter (optional)
	// status: status to filter (optional)
	FindJobs(name string, start, limit int, asc bool, status ...string) ([]*Job, error)

	// IterJobs find jobs and iterate
	// name: name to filter (optional)
	// status: status to filter (optional)
	IterJobs(it func(job *Job) error, name string, start, limit int, asc bool, status ...string) error

	// AppendJob append a pendding job
	AppendJob(name, file, param string) (int64, error)

	// AbortJob abort the job
	AbortJob(jid int64, reason string) error

	// CompleteJob update job status to completed
	CompleteJob(jid int64) error

	// CheckoutJob change job status from pending to running
	CheckoutJob(jid, rid int64) error

	// PingJob update the job updated_at to now
	PingJob(jid, rid int64) error

	// SetJobState update the running job state
	SetJobState(jid, rid int64, state string) error

	// AddJobResult append result to the running job
	AddJobResult(jid, rid int64, result string) error

	// ReappendJobs reappend the interrupted runnings job to the pennding status
	ReappendJobs(before time.Time) (int64, error)

	// StartJobs start to run jobs
	StartJobs(limit int, run func(*Job)) error

	// DeleteJobs delete jobs
	DeleteJobs(jids ...int64) (int64, int64, error)

	// CleanOutdatedJobs delete outdated jobs
	CleanOutdatedJobs(before time.Time) (int64, int64, error)
}

type JobRunner struct {
	Log *log.Log

	PingAfter time.Duration // Ping after duration
	// contains filtered or unexported fields
}