jobs

Documentation

Index

• Constants
• Variables
• func GenerateNextStartDateTime(now time.Time, nextStartTime time.Time) *time.Time
• type JobServer
  • func NewJobServer(configService configservice.ConfigService, store store.Store, ...) *JobServer
  • func (srv *JobServer) CancellationWatcher(ctx context.Context, jobId string, cancelChan chan interface{})
  • func (srv *JobServer) CheckForPendingJobsByType(jobType string) (bool, *model.AppError)
  • func (srv *JobServer) ClaimJob(job *model.Job) (bool, *model.AppError)
  • func (srv *JobServer) Config() *model.Config
  • func (srv *JobServer) CreateJob(jobType string, jobData map[string]string) (*model.Job, *model.AppError)
  • func (srv *JobServer) GetJob(id string) (*model.Job, *model.AppError)
  • func (srv *JobServer) GetLastSuccessfulJobByType(jobType string) (*model.Job, *model.AppError)
  • func (srv *JobServer) InitSchedulers() *Schedulers
  • func (srv *JobServer) InitWorkers() *Workers
  • func (srv *JobServer) MakeWatcher(workers *Workers, pollingInterval int) *Watcher
  • func (srv *JobServer) RequestCancellation(jobId string) *model.AppError
  • func (srv *JobServer) SetJobCanceled(job *model.Job) *model.AppError
  • func (srv *JobServer) SetJobError(job *model.Job, jobError *model.AppError) *model.AppError
  • func (srv *JobServer) SetJobProgress(job *model.Job, progress int64) *model.AppError
  • func (srv *JobServer) SetJobSuccess(job *model.Job) *model.AppError
  • func (srv *JobServer) SetJobWarning(job *model.Job) *model.AppError
  • func (srv *JobServer) StartSchedulers()
  • func (srv *JobServer) StartWorkers()
  • func (srv *JobServer) StopSchedulers()
  • func (srv *JobServer) StopWorkers()
  • func (srv *JobServer) UpdateInProgressJobData(job *model.Job) *model.AppError
• type Schedulers
  • func (schedulers *Schedulers) HandleClusterLeaderChange(isLeader bool)
  • func (schedulers *Schedulers) Start() *Schedulers
  • func (schedulers *Schedulers) Stop() *Schedulers
• type Watcher
  • func (watcher *Watcher) PollAndNotify()
  • func (watcher *Watcher) Start()
  • func (watcher *Watcher) Stop()
• type Workers
  • func (workers *Workers) Start() *Workers
  • func (workers *Workers) Stop() *Workers

Constants

const (
	CancelWatcherPollingInterval = 5000
)

Variables

var DefaultWatcherPollingInterval = 15000

Default polling interval for jobs termination. (Defining as `var` rather than `const` allows tests to lower the interval.)

Functions

func GenerateNextStartDateTime

func GenerateNextStartDateTime(now time.Time, nextStartTime time.Time) *time.Time

Types

type JobServer

type JobServer struct {
	ConfigService configservice.ConfigService
	Store         store.Store

	Workers    *Workers
	Schedulers *Schedulers

	DataRetentionJob        ejobs.DataRetentionJobInterface
	MessageExportJob        ejobs.MessageExportJobInterface
	ElasticsearchAggregator ejobs.ElasticsearchAggregatorInterface
	ElasticsearchIndexer    tjobs.IndexerJobInterface
	LdapSync                ejobs.LdapSyncInterface
	Migrations              tjobs.MigrationsJobInterface
	Plugins                 tjobs.PluginsJobInterface
	BleveIndexer            tjobs.IndexerJobInterface
	ExpiryNotify            tjobs.ExpiryNotifyJobInterface
	ProductNotices          tjobs.ProductNoticesJobInterface
	ActiveUsers             tjobs.ActiveUsersJobInterface
	ImportProcess           tjobs.ImportProcessInterface
	ImportDelete            tjobs.ImportDeleteInterface
	ExportProcess           tjobs.ExportProcessInterface
	ExportDelete            tjobs.ExportDeleteInterface
	Cloud                   ejobs.CloudJobInterface
	// contains filtered or unexported fields
}

func NewJobServer

func NewJobServer(configService configservice.ConfigService, store store.Store, metrics einterfaces.MetricsInterface) *JobServer

func (*JobServer) CancellationWatcher

func (srv *JobServer) CancellationWatcher(ctx context.Context, jobId string, cancelChan chan interface{})

func (*JobServer) CheckForPendingJobsByType

func (srv *JobServer) CheckForPendingJobsByType(jobType string) (bool, *model.AppError)

func (*JobServer) ClaimJob

func (srv *JobServer) ClaimJob(job *model.Job) (bool, *model.AppError)

func (*JobServer) Config

func (srv *JobServer) Config() *model.Config

func (*JobServer) CreateJob

func (srv *JobServer) CreateJob(jobType string, jobData map[string]string) (*model.Job, *model.AppError)

func (*JobServer) GetJob

func (srv *JobServer) GetJob(id string) (*model.Job, *model.AppError)

func (*JobServer) GetLastSuccessfulJobByType

func (srv *JobServer) GetLastSuccessfulJobByType(jobType string) (*model.Job, *model.AppError)

func (*JobServer) InitSchedulers

func (srv *JobServer) InitSchedulers() *Schedulers

func (*JobServer) InitWorkers

func (srv *JobServer) InitWorkers() *Workers

func (*JobServer) MakeWatcher

func (srv *JobServer) MakeWatcher(workers *Workers, pollingInterval int) *Watcher

func (*JobServer) RequestCancellation

func (srv *JobServer) RequestCancellation(jobId string) *model.AppError

func (*JobServer) SetJobCanceled

func (srv *JobServer) SetJobCanceled(job *model.Job) *model.AppError

func (*JobServer) SetJobError

func (srv *JobServer) SetJobError(job *model.Job, jobError *model.AppError) *model.AppError

func (*JobServer) SetJobProgress

func (srv *JobServer) SetJobProgress(job *model.Job, progress int64) *model.AppError

func (*JobServer) SetJobSuccess

func (srv *JobServer) SetJobSuccess(job *model.Job) *model.AppError

func (*JobServer) SetJobWarning

func (srv *JobServer) SetJobWarning(job *model.Job) *model.AppError

func (*JobServer) StartSchedulers

func (srv *JobServer) StartSchedulers()

func (*JobServer) StartWorkers

func (srv *JobServer) StartWorkers()

func (*JobServer) StopSchedulers

func (srv *JobServer) StopSchedulers()

func (*JobServer) StopWorkers

func (srv *JobServer) StopWorkers()

func (*JobServer) UpdateInProgressJobData

func (srv *JobServer) UpdateInProgressJobData(job *model.Job) *model.AppError

type Schedulers

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

func (*Schedulers) HandleClusterLeaderChange

func (schedulers *Schedulers) HandleClusterLeaderChange(isLeader bool)

func (*Schedulers) Start

func (schedulers *Schedulers) Start() *Schedulers

func (*Schedulers) Stop

func (schedulers *Schedulers) Stop() *Schedulers

type Watcher

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

func (*Watcher) PollAndNotify

func (watcher *Watcher) PollAndNotify()

func (*Watcher) Start

func (watcher *Watcher) Start()

func (*Watcher) Stop

func (watcher *Watcher) Stop()

type Workers

type Workers struct {
	ConfigService configservice.ConfigService
	Watcher       *Watcher

	DataRetention            model.Worker
	MessageExport            model.Worker
	ElasticsearchIndexing    model.Worker
	ElasticsearchAggregation model.Worker
	LdapSync                 model.Worker
	Migrations               model.Worker
	Plugins                  model.Worker
	BleveIndexing            model.Worker
	ExpiryNotify             model.Worker
	ProductNotices           model.Worker
	ActiveUsers              model.Worker
	ImportProcess            model.Worker
	ImportDelete             model.Worker
	ExportProcess            model.Worker
	ExportDelete             model.Worker
	Cloud                    model.Worker
	// contains filtered or unexported fields
}

func (*Workers) Start

func (workers *Workers) Start() *Workers

func (*Workers) Stop

func (workers *Workers) Stop() *Workers