SearchBackPressure Service Collector added (#483)

* SearchBackPressure Collector added Signed-off-by: CoderJeffrey <[email protected]>
opensearch-project · Jun 24, 2023 · e0ea1da · e0ea1da
1 parent 5428a52
commit e0ea1da
Show file tree

Hide file tree

Showing 4 changed files with 915 additions and 0 deletions.
diff --git a/src/main/java/org/opensearch/performanceanalyzer/PerformanceAnalyzerPlugin.java b/src/main/java/org/opensearch/performanceanalyzer/PerformanceAnalyzerPlugin.java
@@ -53,6 +53,7 @@
 import org.opensearch.performanceanalyzer.collectors.NodeDetailsCollector;
 import org.opensearch.performanceanalyzer.collectors.NodeStatsAllShardsMetricsCollector;
 import org.opensearch.performanceanalyzer.collectors.NodeStatsFixedShardsMetricsCollector;
+import org.opensearch.performanceanalyzer.collectors.SearchBackPressureStatsCollector;
 import org.opensearch.performanceanalyzer.collectors.ShardIndexingPressureMetricsCollector;
 import org.opensearch.performanceanalyzer.collectors.ShardStateCollector;
 import org.opensearch.performanceanalyzer.collectors.ThreadPoolMetricsCollector;
@@ -224,6 +225,10 @@ public PerformanceAnalyzerPlugin(final Settings settings, final java.nio.file.Pa
         scheduledMetricCollectorsExecutor.addScheduledMetricCollector(
                 new ClusterApplierServiceStatsCollector(
                         performanceAnalyzerController, configOverridesWrapper));
+        scheduledMetricCollectorsExecutor.addScheduledMetricCollector(
+                new SearchBackPressureStatsCollector(
+                        performanceAnalyzerController, configOverridesWrapper));
+
         scheduledMetricCollectorsExecutor.addScheduledMetricCollector(
                 new AdmissionControlMetricsCollector());
         scheduledMetricCollectorsExecutor.addScheduledMetricCollector(