PLT-7705: API to get data retention policy. (#7539)

* PLT-7705: API to get data retention policy.

* Fix review comments.

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 {

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

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 {