in src/main/java/org/opensearch/performanceanalyzer/reader/MetricPropertiesConfig.java [174:335]
private MetricPropertiesConfig() {
metricPathMap = new HashMap<>();
metricPathMap.put(MetricName.CACHE_CONFIG, PerformanceAnalyzerMetrics.sCacheConfigPath);
metricPathMap.put(
MetricName.CIRCUIT_BREAKER, PerformanceAnalyzerMetrics.sCircuitBreakerPath);
metricPathMap.put(MetricName.HEAP_METRICS, PerformanceAnalyzerMetrics.sHeapPath);
metricPathMap.put(MetricName.DISK_METRICS, PerformanceAnalyzerMetrics.sDisksPath);
metricPathMap.put(MetricName.TCP_METRICS, PerformanceAnalyzerMetrics.sTCPPath);
metricPathMap.put(MetricName.IP_METRICS, PerformanceAnalyzerMetrics.sIPPath);
metricPathMap.put(MetricName.THREAD_POOL, PerformanceAnalyzerMetrics.sThreadPoolPath);
metricPathMap.put(MetricName.SHARD_STATS, PerformanceAnalyzerMetrics.sIndicesPath);
metricPathMap.put(MetricName.MASTER_PENDING, PerformanceAnalyzerMetrics.sPendingTasksPath);
metricPathMap.put(
MetricName.MOUNTED_PARTITION_METRICS,
PerformanceAnalyzerMetrics.sMountedPartitionMetricsPath);
metricPathMap.put(
MetricName.CLUSTER_APPLIER_SERVICE,
PerformanceAnalyzerMetrics.sClusterApplierService);
metricPathMap.put(MetricName.ELECTION_TERM, PerformanceAnalyzerMetrics.sElectionTermPath);
metricPathMap.put(
MetricName.ADMISSION_CONTROL_METRICS,
PerformanceAnalyzerMetrics.sAdmissionControlMetricsPath);
metricPathMap.put(
MetricName.SHARD_INDEXING_PRESSURE,
PerformanceAnalyzerMetrics.sShardIndexingPressurePath);
metricPathMap.put(
MetricName.MASTER_CLUSTER_UPDATE_STATS,
PerformanceAnalyzerMetrics.sMasterClusterUpdate);
eventKeyToMetricNameMap = new HashMap<>();
eventKeyToMetricNameMap.put(
PerformanceAnalyzerMetrics.sCacheConfigPath, MetricName.CACHE_CONFIG);
eventKeyToMetricNameMap.put(
PerformanceAnalyzerMetrics.sCircuitBreakerPath, MetricName.CIRCUIT_BREAKER);
eventKeyToMetricNameMap.put(PerformanceAnalyzerMetrics.sHeapPath, MetricName.HEAP_METRICS);
eventKeyToMetricNameMap.put(PerformanceAnalyzerMetrics.sDisksPath, MetricName.DISK_METRICS);
eventKeyToMetricNameMap.put(PerformanceAnalyzerMetrics.sTCPPath, MetricName.TCP_METRICS);
eventKeyToMetricNameMap.put(PerformanceAnalyzerMetrics.sIPPath, MetricName.IP_METRICS);
eventKeyToMetricNameMap.put(
PerformanceAnalyzerMetrics.sThreadPoolPath, MetricName.THREAD_POOL);
eventKeyToMetricNameMap.put(
PerformanceAnalyzerMetrics.sIndicesPath, MetricName.SHARD_STATS);
eventKeyToMetricNameMap.put(
PerformanceAnalyzerMetrics.sPendingTasksPath, MetricName.MASTER_PENDING);
eventKeyToMetricNameMap.put(
PerformanceAnalyzerMetrics.sMountedPartitionMetricsPath,
MetricName.MOUNTED_PARTITION_METRICS);
eventKeyToMetricNameMap.put(
PerformanceAnalyzerMetrics.sMasterClusterUpdate,
MetricName.MASTER_CLUSTER_UPDATE_STATS);
eventKeyToMetricNameMap.put(
PerformanceAnalyzerMetrics.sClusterApplierService,
MetricName.CLUSTER_APPLIER_SERVICE);
eventKeyToMetricNameMap.put(
PerformanceAnalyzerMetrics.sElectionTermPath, MetricName.ELECTION_TERM);
eventKeyToMetricNameMap.put(
PerformanceAnalyzerMetrics.sAdmissionControlMetricsPath,
MetricName.ADMISSION_CONTROL_METRICS);
eventKeyToMetricNameMap.put(
PerformanceAnalyzerMetrics.sShardIndexingPressurePath,
MetricName.SHARD_INDEXING_PRESSURE);
metricName2Property = new HashMap<>();
metricName2Property.put(
MetricName.CACHE_CONFIG,
new MetricProperties(
CacheConfigDimension.values(),
CacheConfigValue.values(),
createFileHandler(metricPathMap.get(MetricName.CACHE_CONFIG))));
metricName2Property.put(
MetricName.CIRCUIT_BREAKER,
new MetricProperties(
CircuitBreakerDimension.values(),
CircuitBreakerValue.values(),
createFileHandler(metricPathMap.get(MetricName.CIRCUIT_BREAKER))));
metricName2Property.put(
MetricName.HEAP_METRICS,
new MetricProperties(
HeapDimension.values(),
HeapValue.values(),
createFileHandler(metricPathMap.get(MetricName.HEAP_METRICS))));
metricName2Property.put(
MetricName.DISK_METRICS,
new MetricProperties(
DiskDimension.values(),
DiskValue.values(),
createFileHandler(metricPathMap.get(MetricName.DISK_METRICS))));
metricName2Property.put(
MetricName.TCP_METRICS,
new MetricProperties(
TCPDimension.values(),
TCPValue.values(),
createFileHandler(metricPathMap.get(MetricName.TCP_METRICS))));
metricName2Property.put(
MetricName.IP_METRICS,
new MetricProperties(
IPDimension.values(),
IPValue.values(),
createFileHandler(metricPathMap.get(MetricName.IP_METRICS))));
metricName2Property.put(
MetricName.THREAD_POOL,
new MetricProperties(
ThreadPoolDimension.values(),
ThreadPoolValue.values(),
createFileHandler(metricPathMap.get(MetricName.THREAD_POOL))));
metricName2Property.put(
MetricName.SHARD_STATS,
new MetricProperties(
ShardStatsDerivedDimension.values(),
MetricProperties.EMPTY_DIMENSION,
ShardStatsValue.values(),
new ShardStatFileHandler()));
metricName2Property.put(
MetricName.MASTER_PENDING,
new MetricProperties(
MasterPendingTaskDimension.values(),
MasterPendingValue.values(),
createFileHandler(
metricPathMap.get(MetricName.MASTER_PENDING),
PerformanceAnalyzerMetrics.MASTER_CURRENT,
PerformanceAnalyzerMetrics.MASTER_META_DATA)));
metricName2Property.put(
MetricName.MOUNTED_PARTITION_METRICS,
new MetricProperties(
DevicePartitionDimension.values(),
DevicePartitionValue.values(),
createFileHandler(
metricPathMap.get(MetricName.MOUNTED_PARTITION_METRICS))));
metricName2Property.put(
MetricName.CLUSTER_APPLIER_SERVICE,
new MetricProperties(
MetricProperties.EMPTY_DIMENSION,
AllMetrics.ClusterApplierServiceStatsValue.values(),
createFileHandler(metricPathMap.get(MetricName.CLUSTER_APPLIER_SERVICE))));
metricName2Property.put(
MetricName.ELECTION_TERM,
new MetricProperties(
MetricProperties.EMPTY_DIMENSION,
ElectionTermValue.values(),
createFileHandler(metricPathMap.get(MetricName.ELECTION_TERM))));
metricName2Property.put(
MetricName.ADMISSION_CONTROL_METRICS,
new MetricProperties(
AdmissionControlDimension.values(),
AdmissionControlValue.values(),
createFileHandler(
metricPathMap.get(MetricName.ADMISSION_CONTROL_METRICS))));
metricName2Property.put(
MetricName.SHARD_INDEXING_PRESSURE,
new MetricProperties(
AllMetrics.ShardIndexingPressureDimension.values(),
AllMetrics.ShardIndexingPressureValue.values(),
createFileHandler(metricPathMap.get(MetricName.SHARD_INDEXING_PRESSURE))));
metricName2Property.put(
MetricName.MASTER_CLUSTER_UPDATE_STATS,
new MetricProperties(
MetricProperties.EMPTY_DIMENSION,
AllMetrics.MasterClusterUpdateStatsValue.values(),
createFileHandler(
metricPathMap.get(MetricName.MASTER_CLUSTER_UPDATE_STATS))));
}