integration

Documentation

Index

• Variables
• func ConsumeQueItem() (err error)

Variables

var Que = &mock.QueueMock{
	AddFunc: func(job worker.QueJobInterface) error {
		jobInfo, err := job.GetJobInfo()

		if err != nil {
			return err
		}
		if scheduler, ok := jobInfo.Argument.(worker.Scheduler); ok && scheduler.GetScheduleTime() != nil {
			job.SetStatus(worker.JobStatusScheduled)
		}
		items = append(items, job)
		return nil
	},
	KillFunc: func(job worker.QueJobInterface) error {
		return job.SetStatus(worker.JobStatusKilled)
	},
	ListenFunc: func(jobDefs []*worker.QorJobDefinition, getJob func(qorJobID uint) (worker.QueJobInterface, error)) error {
		return nil
	},
	RemoveFunc: func(job worker.QueJobInterface) error {
		return job.SetStatus(worker.JobStatusCancelled)
	},
}

Functions

func ConsumeQueItem

func ConsumeQueItem() (err error)