sql_job_dispatcher

func (*Job) AfterFind ¶

func (wj *Job) AfterFind(*gorm.DB) (err error)

func (*Job) BeforeSave ¶

func (wj *Job) BeforeSave(*gorm.DB) (err error)

func (*SqlService) BulkNew ¶

func (m *SqlService) BulkNew(newJobs []*job_dispatcher.Job) (err error)

BulkNew creates multiple new jobs

func (*SqlService) Clean ¶

func (m *SqlService) Clean() (err error)

Clean cleans all stalled jobs

func (*SqlService) Complete ¶

func (m *SqlService) Complete(job *job_dispatcher.Job) (err error)

Complete marks the job as completed

func (*SqlService) GetCurrentJobOfWorker ¶

func (m *SqlService) GetCurrentJobOfWorker(
	workerInstances []string,
	currentWorkerUID uuid.UUID,
) (job *job_dispatcher.Job, found bool, err error)

GetCurrentJobOfWorker retrieves the job of the worker if one exists in the database

func (*SqlService) GetJobByUUID ¶

func (m *SqlService) GetJobByUUID(uid uuid.UUID) (job *job_dispatcher.Job, err error)

GetJobByUUID returns a job by its unique identifier

func (*SqlService) GetLatestJob ¶

func (m *SqlService) GetLatestJob(workerInstances []string,
	currentWorkerUID uuid.UUID) (job *job_dispatcher.Job, err error)

GetLatestJob returns the latest job

func (*SqlService) GetStats ¶

func (m *SqlService) GetStats() (results []job_dispatcher.Stats, err error)

GetStats returns the statistics of each job instance

func (*SqlService) HeartBeat ¶

func (m *SqlService) HeartBeat(job *job_dispatcher.Job, status map[string]interface{}) (err error)

HeartBeat marks a job as alive

func (*SqlService) New ¶

func (m *SqlService) New(job *job_dispatcher.Job) (err error)

func (*SqlService) Release ¶

func (m *SqlService) Release(job *job_dispatcher.Job) (err error)

Release releases the job

func (*SqlService) Start ¶

func (m *SqlService) Start(job *job_dispatcher.Job) (err error)

Start marks a job as started