SearchBackPressure Service Collector added (#483) (#558)

* SearchBackPressure Collector added Signed-off-by: CoderJeffrey <[email protected]> (cherry picked from commit e0ea1da) Co-authored-by: Jeffrey Liu <[email protected]>
opensearch-project · Oct 5, 2023 · 348b0bc · 348b0bc
1 parent e5a4a3d
commit 348b0bc
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(