scheduler

Documentation

Index

• func MakeScheduler(jobServer *jobs.JobServer) model.Scheduler
• func MakeWorker(jobServer *jobs.JobServer, app AppIface) model.Worker
• type AppIface
• type Worker
  • func (worker *Worker) DoJob(job *model.Job)
  • func (worker *Worker) IsEnabled(cfg *model.Config) bool
  • func (worker *Worker) JobChannel() chan<- model.Job
  • func (worker *Worker) Run()
  • func (worker *Worker) Stop()

Functions

func MakeScheduler

func MakeScheduler(jobServer *jobs.JobServer) model.Scheduler

func MakeWorker

func MakeWorker(jobServer *jobs.JobServer, app AppIface) model.Worker

Types

type AppIface

type AppIface interface {
	DeleteAllExpiredPluginKeys() *model.AppError
}

type Worker

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

func (*Worker) DoJob

func (worker *Worker) DoJob(job *model.Job)

func (*Worker) IsEnabled

func (worker *Worker) IsEnabled(cfg *model.Config) bool

func (*Worker) JobChannel

func (worker *Worker) JobChannel() chan<- model.Job

func (*Worker) Run

func (worker *Worker) Run()

func (*Worker) Stop

func (worker *Worker) Stop()