Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -83,7 +83,11 @@ public class PerformanceAnalyzerApp {

private static final int EXCEPTION_QUEUE_LENGTH = 1;
public static final String QUERY_URL = "/_plugins/_performanceanalyzer/metrics";
public static final String LEGACY_OPENDISTRO_QUERY_URL =
"/_opendistro/_performanceanalyzer/metrics";
public static final String BATCH_METRICS_URL = "/_plugins/_performanceanalyzer/batch";
public static final String LEGACY_OPENDISTRO_BATCH_METRICS_URL =
"/_opendistro/_performanceanalyzer/batch";
private static final Logger LOG = LogManager.getLogger(PerformanceAnalyzerApp.class);
private static final ScheduledMetricCollectorsExecutor METRIC_COLLECTOR_EXECUTOR =
new ScheduledMetricCollectorsExecutor(1, false);
Expand Down Expand Up @@ -347,11 +351,15 @@ public static ClientServers createClientServers(
webServerPort, hostFromSetting, useHttps);

if (metricsRestUtil != null) {
httpServer.createContext(
QUERY_URL,
new QueryMetricsRequestHandler(netClient, metricsRestUtil, appContext));
httpServer.createContext(
BATCH_METRICS_URL, new QueryBatchRequestHandler(netClient, metricsRestUtil));
QueryMetricsRequestHandler queryMetricsRequestHandler =
new QueryMetricsRequestHandler(netClient, metricsRestUtil, appContext);
httpServer.createContext(QUERY_URL, queryMetricsRequestHandler);
httpServer.createContext(LEGACY_OPENDISTRO_QUERY_URL, queryMetricsRequestHandler);

QueryBatchRequestHandler queryBatchRequestHandler =
new QueryBatchRequestHandler(netClient, metricsRestUtil);
httpServer.createContext(BATCH_METRICS_URL, queryBatchRequestHandler);
httpServer.createContext(LEGACY_OPENDISTRO_BATCH_METRICS_URL, queryBatchRequestHandler);
}

return new ClientServers(httpServer, netServer, netClient);
Expand Down