Added shard operations collector and optimised node stats collector

Author: nishchay21

src/main/java/org/opensearch/performanceanalyzer/collectors/telemetry/RTFNodeStatsAllShardsMetricsCollector.java

@@ -126,22 +126,14 @@ configOverridesWrapper, getCollectorName())) {
         for (Map.Entry<ShardId, ShardStats> currentShard : currentPerShardStats.entrySet()) {
             ShardId shardId = currentShard.getKey();
             ShardStats currentShardStats = currentShard.getValue();
-            if (prevPerShardStats.isEmpty() || !prevPerShardStats.containsKey(shardId)) {
+            if (prevPerShardStats.isEmpty() || prevPerShardStats.get(shardId) == null) {
                 // Populating value for the first run of shard.
                 recordMetrics(
                         new NodeStatsMetricsAllShardsPerCollectionStatus(currentShardStats),
                         shardId);
                 continue;
             }
             ShardStats prevShardStats = prevPerShardStats.get(shardId);
-            if (prevShardStats == null) {
-                // Populate value for shards which are new and were not present in the previous
-                // run.
-                recordMetrics(
-                        new NodeStatsMetricsAllShardsPerCollectionStatus(currentShardStats),
-                        shardId);
-                continue;
-            }
             NodeStatsMetricsAllShardsPerCollectionStatus prevValue =
                     new NodeStatsMetricsAllShardsPerCollectionStatus(prevShardStats);
             NodeStatsMetricsAllShardsPerCollectionStatus currValue =

src/main/java/org/opensearch/performanceanalyzer/collectors/telemetry/RTFShardOperationCollector.java

@@ -141,11 +141,20 @@ private void processOperations(
 
     // attributes= {index_name="test", shard_id="0"}
     private Tags createTags(ShardId shardId) {
-        return Tags.create()
-                .addTag(RTFMetrics.CommonDimension.INDEX_NAME.toString(), shardId.getIndexName())
-                .addTag(
-                        RTFMetrics.CommonDimension.SHARD_ID.toString(),
-                        String.valueOf(shardId.getId()));
+        Tags shardOperationsMetricsTag =
+                Tags.create()
+                        .addTag(
+                                RTFMetrics.CommonDimension.INDEX_NAME.toString(),
+                                shardId.getIndexName())
+                        .addTag(
+                                RTFMetrics.CommonDimension.SHARD_ID.toString(),
+                                String.valueOf(shardId.getId()));
+
+        if (shardId.getIndex() != null) {
+            shardOperationsMetricsTag.addTag(
+                    RTFMetrics.CommonDimension.INDEX_UUID.toString(), shardId.getIndex().getUUID());
+        }
+        return shardOperationsMetricsTag;
     }
 
     private void initializeMetricsIfNeeded() {
@@ -172,5 +181,5 @@ private void initializeMetricsIfNeeded() {
      * @param indexOps count of index operations.
      * @param searchOps count of search operations
      */
-    public record ShardOperation(long indexOps, long searchOps) {}
+    private record ShardOperation(long indexOps, long searchOps) {}
 }