mirror of
https://github.com/mattermost/mattermost.git
synced 2025-02-25 18:55:24 -06:00
577ed27f1b
* Added initial job server * Added job server to be ran as part of platform * Added test job to the enterprise repo * Fixed job server not loading license * Renamed job package to jobs * Fixed TE not being buildable * Added JobStatus table to database * Changed fields used by JobStatus * Added APIs to query job status * Added config change listener to server * Added option to run job server from Makefile * Added ability to enable/disable jobs from config * Commented out placeholder for search indexing job * Fixed govet * Removed debug messages and fixed job api init message
75 lines
1.7 KiB
Go
75 lines
1.7 KiB
Go
// Copyright (c) 2017-present Mattermost, Inc. All Rights Reserved.
|
|
// See License.txt for license information.
|
|
|
|
package jobs
|
|
|
|
import (
|
|
"sync"
|
|
|
|
l4g "github.com/alecthomas/log4go"
|
|
ejobs "github.com/mattermost/platform/einterfaces/jobs"
|
|
"github.com/mattermost/platform/model"
|
|
"github.com/mattermost/platform/store"
|
|
"github.com/mattermost/platform/utils"
|
|
)
|
|
|
|
type Jobs struct {
|
|
startOnce sync.Once
|
|
|
|
DataRetention model.Job
|
|
// SearchIndexing model.Job
|
|
|
|
listenerId string
|
|
}
|
|
|
|
func InitJobs(s store.Store) *Jobs {
|
|
jobs := &Jobs{
|
|
// SearchIndexing: MakeTestJob(s, "SearchIndexing"),
|
|
}
|
|
|
|
if dataRetentionInterface := ejobs.GetDataRetentionInterface(); dataRetentionInterface != nil {
|
|
jobs.DataRetention = dataRetentionInterface.MakeJob(s)
|
|
}
|
|
|
|
return jobs
|
|
}
|
|
|
|
func (jobs *Jobs) Start() *Jobs {
|
|
l4g.Info("Starting jobs")
|
|
|
|
jobs.startOnce.Do(func() {
|
|
if jobs.DataRetention != nil && *utils.Cfg.DataRetentionSettings.Enable {
|
|
go jobs.DataRetention.Run()
|
|
}
|
|
|
|
// go jobs.SearchIndexing.Run()
|
|
})
|
|
|
|
jobs.listenerId = utils.AddConfigListener(jobs.handleConfigChange)
|
|
|
|
return jobs
|
|
}
|
|
|
|
func (jobs *Jobs) handleConfigChange(oldConfig *model.Config, newConfig *model.Config) {
|
|
if jobs.DataRetention != nil {
|
|
if !*oldConfig.DataRetentionSettings.Enable && *newConfig.DataRetentionSettings.Enable {
|
|
go jobs.DataRetention.Run()
|
|
} else if *oldConfig.DataRetentionSettings.Enable && !*newConfig.DataRetentionSettings.Enable {
|
|
jobs.DataRetention.Stop()
|
|
}
|
|
}
|
|
}
|
|
|
|
func (jobs *Jobs) Stop() *Jobs {
|
|
utils.RemoveConfigListener(jobs.listenerId)
|
|
|
|
if jobs.DataRetention != nil && *utils.Cfg.DataRetentionSettings.Enable {
|
|
jobs.DataRetention.Stop()
|
|
}
|
|
// jobs.SearchIndexing.Stop()
|
|
|
|
l4g.Info("Stopped jobs")
|
|
|
|
return jobs
|
|
}
|