void set()

in src/main/java/org/opensearch/performanceanalyzer/transport/PerformanceAnalyzerTransportChannel.java [55:99]


    void set(
            TransportChannel original,
            long startTime,
            String indexName,
            int shardId,
            int itemCount,
            boolean bPrimary) {
        this.original = original;
        this.id = String.valueOf(UNIQUE_ID.getAndIncrement());
        this.indexName = indexName;
        this.shardId = shardId;
        this.primary = bPrimary;
        this.threadID = String.valueOf(ThreadIDUtil.INSTANCE.getNativeCurrentThreadId());

        StringBuilder value =
                new StringBuilder()
                        .append(PerformanceAnalyzerMetrics.getCurrentTimeMetric())
                        .append(PerformanceAnalyzerMetrics.sMetricNewLineDelimitor)
                        .append(ShardBulkMetric.START_TIME.toString())
                        .append(PerformanceAnalyzerMetrics.sKeyValueDelimitor)
                        .append(startTime)
                        .append(PerformanceAnalyzerMetrics.sMetricNewLineDelimitor)
                        .append(ShardBulkMetric.ITEM_COUNT.toString())
                        .append(PerformanceAnalyzerMetrics.sKeyValueDelimitor)
                        .append(itemCount)
                        .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(bPrimary);

        saveMetricValues(
                value.toString(),
                startTime,
                threadID,
                id,
                PerformanceAnalyzerMetrics.START_FILE_NAME);
    }