scheduler

Documentation

Index

• type ScheduleWorker
  • func NewWorker(config config.Config, mq mq.MQ, lock lock.Locker, logger zerolog.Logger, ...) *ScheduleWorker
  • func (worker *ScheduleWorker) CreateTaskStatus(taskOutput *message.TaskOutput) error
  • func (worker *ScheduleWorker) Process(taskOutput *message.TaskOutput) (*message.TaskInput, error)
  • func (worker *ScheduleWorker) UpdateJob(job *dbmodel.Job) error

Types

type ScheduleWorker

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

func NewWorker

func NewWorker(
	config config.Config,
	mq mq.MQ,
	lock lock.Locker,
	logger zerolog.Logger,
	lockTimeout time.Duration,
	tracer *opentracer.ServiceTracer,
) *ScheduleWorker

func (*ScheduleWorker) CreateTaskStatus

func (worker *ScheduleWorker) CreateTaskStatus(
	taskOutput *message.TaskOutput,
) error

func (*ScheduleWorker) Process

func (worker *ScheduleWorker) Process(taskOutput *message.TaskOutput) (*message.TaskInput, error)

func (*ScheduleWorker) UpdateJob

func (worker *ScheduleWorker) UpdateJob(
	job *dbmodel.Job,
) error