diff options
Diffstat (limited to 'app/app.go')
| -rw-r--r-- | app/app.go | 19 |
1 files changed, 19 insertions, 0 deletions
diff --git a/app/app.go b/app/app.go index 7bd4c561b..fd313c9c9 100644 --- a/app/app.go +++ b/app/app.go @@ -48,6 +48,7 @@ type App struct { Elasticsearch einterfaces.ElasticsearchInterface Emoji einterfaces.EmojiInterface Ldap einterfaces.LdapInterface + MessageExport einterfaces.MessageExportInterface Metrics einterfaces.MetricsInterface Mfa einterfaces.MfaInterface Saml einterfaces.SamlInterface @@ -198,6 +199,12 @@ func RegisterJobsDataRetentionJobInterface(f func(*App) ejobs.DataRetentionJobIn jobsDataRetentionJobInterface = f } +var jobsMessageExportJobInterface func(*App) ejobs.MessageExportJobInterface + +func RegisterJobsMessageExportJobInterface(f func(*App) ejobs.MessageExportJobInterface) { + jobsMessageExportJobInterface = f +} + var jobsElasticsearchAggregatorInterface func(*App) ejobs.ElasticsearchAggregatorInterface func RegisterJobsElasticsearchAggregatorInterface(f func(*App) ejobs.ElasticsearchAggregatorInterface) { @@ -222,6 +229,12 @@ func RegisterLdapInterface(f func(*App) einterfaces.LdapInterface) { ldapInterface = f } +var messageExportInterface func(*App) einterfaces.MessageExportInterface + +func RegisterMessageExportInterface(f func(*App) einterfaces.MessageExportInterface) { + messageExportInterface = f +} + var metricsInterface func(*App) einterfaces.MetricsInterface func RegisterMetricsInterface(f func(*App) einterfaces.MetricsInterface) { @@ -267,6 +280,9 @@ func (a *App) initEnterprise() { } }) } + if messageExportInterface != nil { + a.MessageExport = messageExportInterface(a) + } if metricsInterface != nil { a.Metrics = metricsInterface(a) } @@ -289,6 +305,9 @@ func (a *App) initJobs() { if jobsDataRetentionJobInterface != nil { a.Jobs.DataRetentionJob = jobsDataRetentionJobInterface(a) } + if jobsMessageExportJobInterface != nil { + a.Jobs.MessageExportJob = jobsMessageExportJobInterface(a) + } if jobsElasticsearchAggregatorInterface != nil { a.Jobs.ElasticsearchAggregator = jobsElasticsearchAggregatorInterface(a) } |