in src/main/java/org/opensearch/performanceanalyzer/transport/PerformanceAnalyzerTransportChannel.java [123:166]
private void emitMetricsFinish(Exception exception) {
long currTime = System.currentTimeMillis();
StringBuilder value =
new StringBuilder()
.append(PerformanceAnalyzerMetrics.getCurrentTimeMetric())
.append(PerformanceAnalyzerMetrics.sMetricNewLineDelimitor)
.append(ShardBulkMetric.FINISH_TIME.toString())
.append(PerformanceAnalyzerMetrics.sKeyValueDelimitor)
.append(currTime)
.append(PerformanceAnalyzerMetrics.sMetricNewLineDelimitor)
.append(ShardBulkDimension.INDEX_NAME.toString())
.append(PerformanceAnalyzerMetrics.sKeyValueDelimitor)
.append(indexName)
.append(PerformanceAnalyzerMetrics.sMetricNewLineDelimitor)
.append(ShardBulkDimension.SHARD_ID.toString())
.append(PerformanceAnalyzerMetrics.sKeyValueDelimitor)
.append(shardId)
.append(PerformanceAnalyzerMetrics.sMetricNewLineDelimitor)
.append(ShardBulkDimension.PRIMARY.toString())
.append(PerformanceAnalyzerMetrics.sKeyValueDelimitor)
.append(primary);
if (exception != null) {
value.append(PerformanceAnalyzerMetrics.sMetricNewLineDelimitor)
.append(ShardBulkDimension.EXCEPTION.toString())
.append(PerformanceAnalyzerMetrics.sKeyValueDelimitor)
.append(exception.getClass().getName());
value.append(PerformanceAnalyzerMetrics.sMetricNewLineDelimitor)
.append(ShardBulkDimension.FAILED.toString())
.append(PerformanceAnalyzerMetrics.sKeyValueDelimitor)
.append(true);
} else {
value.append(PerformanceAnalyzerMetrics.sMetricNewLineDelimitor)
.append(ShardBulkDimension.FAILED.toString())
.append(PerformanceAnalyzerMetrics.sKeyValueDelimitor)
.append(false);
}
saveMetricValues(
value.toString(),
currTime,
threadID,
id,
PerformanceAnalyzerMetrics.FINISH_FILE_NAME);
}