Skip to content

Commit d625b23

Browse files
committed
adds periodic cleanup job to delete doc level monitor percolate query indices
Signed-off-by: Surya Sashank Nistala <snistala@amazon.com>
1 parent c39caca commit d625b23

File tree

5 files changed

+851
-0
lines changed

5 files changed

+851
-0
lines changed

alerting/src/main/kotlin/org/opensearch/alerting/AlertingPlugin.kt

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -180,6 +180,7 @@ internal class AlertingPlugin : PainlessExtension, ActionPlugin, ScriptPlugin, R
180180
lateinit var docLevelMonitorQueries: DocLevelMonitorQueries
181181
lateinit var threadPool: ThreadPool
182182
lateinit var alertIndices: AlertIndices
183+
lateinit var queryIndexCleanup: QueryIndexCleanup
183184
lateinit var clusterService: ClusterService
184185
lateinit var destinationMigrationCoordinator: DestinationMigrationCoordinator
185186
var monitorTypeToMonitorRunners: MutableMap<String, RemoteMonitorRegistry> = mutableMapOf()
@@ -285,6 +286,7 @@ internal class AlertingPlugin : PainlessExtension, ActionPlugin, ScriptPlugin, R
285286
val settings = environment.settings()
286287
val lockService = LockService(client, clusterService)
287288
alertIndices = AlertIndices(settings, client, threadPool, clusterService)
289+
queryIndexCleanup = QueryIndexCleanup(settings, client, threadPool, clusterService)
288290
val alertService = AlertService(client, xContentRegistry, alertIndices)
289291
val triggerService = TriggerService(scriptService)
290292
runner = MonitorRunnerService
@@ -348,6 +350,7 @@ internal class AlertingPlugin : PainlessExtension, ActionPlugin, ScriptPlugin, R
348350
scheduledJobIndices,
349351
commentsIndices,
350352
docLevelMonitorQueries,
353+
queryIndexCleanup,
351354
destinationMigrationCoordinator,
352355
lockService,
353356
alertService,
@@ -422,6 +425,8 @@ internal class AlertingPlugin : PainlessExtension, ActionPlugin, ScriptPlugin, R
422425
AlertingSettings.FINDING_HISTORY_INDEX_MAX_AGE,
423426
AlertingSettings.FINDING_HISTORY_ROLLOVER_PERIOD,
424427
AlertingSettings.FINDING_HISTORY_RETENTION_PERIOD,
428+
AlertingSettings.QUERY_INDEX_CLEANUP_ENABLED,
429+
AlertingSettings.QUERY_INDEX_CLEANUP_PERIOD,
425430
AlertingSettings.FINDINGS_INDEXING_BATCH_SIZE,
426431
AlertingSettings.CROSS_CLUSTER_MONITORING_ENABLED,
427432
AlertingSettings.ALERTING_COMMENTS_ENABLED,

0 commit comments

Comments
 (0)