diff options
| author | George Goldberg <george@gberg.me> | 2017-10-02 12:43:21 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2017-10-02 12:43:21 +0100 |
| commit | 76bd1bb212177824379c485c553e54530a854009 (patch) | |
| tree | f4b3c41ff3ff72c96ab58e944e4254bfca4fd8be /jobs | |
| parent | 9bc7af0c5704bbf73f8240b4569d5ea215352e39 (diff) | |
| download | chat-76bd1bb212177824379c485c553e54530a854009.tar.gz chat-76bd1bb212177824379c485c553e54530a854009.tar.bz2 chat-76bd1bb212177824379c485c553e54530a854009.zip | |
PLT-7705: API to get data retention policy. (#7539)
* PLT-7705: API to get data retention policy.
* Fix review comments.
Diffstat (limited to 'jobs')
| -rw-r--r-- | jobs/schedulers.go | 4 | ||||
| -rw-r--r-- | jobs/server.go | 2 | ||||
| -rw-r--r-- | jobs/workers.go | 4 |
3 files changed, 5 insertions, 5 deletions
diff --git a/jobs/schedulers.go b/jobs/schedulers.go index 2f1ae394f..3d52c969a 100644 --- a/jobs/schedulers.go +++ b/jobs/schedulers.go @@ -35,8 +35,8 @@ func (srv *JobServer) InitSchedulers() *Schedulers { jobs: srv, } - if dataRetentionInterface := srv.DataRetention; dataRetentionInterface != nil { - schedulers.schedulers = append(schedulers.schedulers, dataRetentionInterface.MakeScheduler()) + if srv.DataRetentionJob != nil { + schedulers.schedulers = append(schedulers.schedulers, srv.DataRetentionJob.MakeScheduler()) } if elasticsearchAggregatorInterface := srv.ElasticsearchAggregator; elasticsearchAggregatorInterface != nil { diff --git a/jobs/server.go b/jobs/server.go index 667d6c075..8c5ee807d 100644 --- a/jobs/server.go +++ b/jobs/server.go @@ -17,7 +17,7 @@ type JobServer struct { Workers *Workers Schedulers *Schedulers - DataRetention ejobs.DataRetentionInterface + DataRetentionJob ejobs.DataRetentionJobInterface ElasticsearchAggregator ejobs.ElasticsearchAggregatorInterface ElasticsearchIndexer ejobs.ElasticsearchIndexerInterface LdapSync ejobs.LdapSyncInterface diff --git a/jobs/workers.go b/jobs/workers.go index dfa150ff6..c984a43b8 100644 --- a/jobs/workers.go +++ b/jobs/workers.go @@ -27,8 +27,8 @@ func (srv *JobServer) InitWorkers() *Workers { workers := &Workers{} workers.Watcher = srv.MakeWatcher(workers, DEFAULT_WATCHER_POLLING_INTERVAL) - if dataRetentionInterface := srv.DataRetention; dataRetentionInterface != nil { - workers.DataRetention = dataRetentionInterface.MakeWorker() + if srv.DataRetentionJob != nil { + workers.DataRetention = srv.DataRetentionJob.MakeWorker() } if elasticsearchIndexerInterface := srv.ElasticsearchIndexer; elasticsearchIndexerInterface != nil { |