diff options
Diffstat (limited to 'app/app.go')
| -rw-r--r-- | app/app.go | 21 |
1 files changed, 15 insertions, 6 deletions
diff --git a/app/app.go b/app/app.go index 508c652c1..7974ab44f 100644 --- a/app/app.go +++ b/app/app.go @@ -34,6 +34,7 @@ type App struct { Brand einterfaces.BrandInterface Cluster einterfaces.ClusterInterface Compliance einterfaces.ComplianceInterface + DataRetention einterfaces.DataRetentionInterface Elasticsearch einterfaces.ElasticsearchInterface Ldap einterfaces.LdapInterface Metrics einterfaces.MetricsInterface @@ -103,10 +104,16 @@ func RegisterComplianceInterface(f func(*App) einterfaces.ComplianceInterface) { complianceInterface = f } -var jobsDataRetentionInterface func(*App) ejobs.DataRetentionInterface +var dataRetentionInterface func(*App) einterfaces.DataRetentionInterface -func RegisterJobsDataRetentionInterface(f func(*App) ejobs.DataRetentionInterface) { - jobsDataRetentionInterface = f +func RegisterDataRetentionInterface(f func(*App) einterfaces.DataRetentionInterface) { + dataRetentionInterface = f +} + +var jobsDataRetentionJobInterface func(*App) ejobs.DataRetentionJobInterface + +func RegisterJobsDataRetentionJobInterface(f func(*App) ejobs.DataRetentionJobInterface) { + jobsDataRetentionJobInterface = f } var jobsElasticsearchAggregatorInterface func(*App) ejobs.ElasticsearchAggregatorInterface @@ -183,9 +190,11 @@ func (a *App) initEnterprise() { a.Saml.ConfigureSP() }) } - - if jobsDataRetentionInterface != nil { - a.Jobs.DataRetention = jobsDataRetentionInterface(a) + if dataRetentionInterface != nil { + a.DataRetention = dataRetentionInterface(a) + } + if jobsDataRetentionJobInterface != nil { + a.Jobs.DataRetentionJob = jobsDataRetentionJobInterface(a) } if jobsElasticsearchAggregatorInterface != nil { a.Jobs.ElasticsearchAggregator = jobsElasticsearchAggregatorInterface(a) |