Versions in this module Expand all Collapse all v5 v5.22.0 Apr 4, 2020 Changes in this version + const CANCEL_WATCHER_POLLING_INTERVAL + var DEFAULT_WATCHER_POLLING_INTERVAL = 15000 + func GenerateNextStartDateTime(now time.Time, nextStartTime time.Time) *time.Time + type JobServer struct + ConfigService configservice.ConfigService + DataRetentionJob ejobs.DataRetentionJobInterface + ElasticsearchAggregator ejobs.ElasticsearchAggregatorInterface + ElasticsearchIndexer ejobs.ElasticsearchIndexerInterface + LdapSync ejobs.LdapSyncInterface + MessageExportJob ejobs.MessageExportJobInterface + Migrations tjobs.MigrationsJobInterface + Plugins tjobs.PluginsJobInterface + Schedulers *Schedulers + Store store.Store + Workers *Workers + 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) StartSchedulers() + func (srv *JobServer) StartWorkers() + func (srv *JobServer) StopSchedulers() + func (srv *JobServer) StopWorkers() + func (srv *JobServer) UpdateInProgressJobData(job *model.Job) *model.AppError + type Schedulers struct + func (schedulers *Schedulers) HandleClusterLeaderChange(isLeader bool) + func (schedulers *Schedulers) Start() *Schedulers + func (schedulers *Schedulers) Stop() *Schedulers + type Watcher struct + func (watcher *Watcher) PollAndNotify() + func (watcher *Watcher) Start() + func (watcher *Watcher) Stop() + type Workers struct + ConfigService configservice.ConfigService + DataRetention model.Worker + ElasticsearchAggregation model.Worker + ElasticsearchIndexing model.Worker + LdapSync model.Worker + MessageExport model.Worker + Migrations model.Worker + Plugins model.Worker + Watcher *Watcher + func (workers *Workers) Start() *Workers + func (workers *Workers) Stop() *Workers Other modules containing this package github.com/vnforks/kid