private void emitMetricsFinish()

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);
    }