SERVER-73727: Aggregate mongos metrics in ClusterClientCursor

1 files changed, 14 insertions, 0 deletions

diff --git a/src/mongo/s/query/cluster_client_cursor.h b/src/mongo/s/query/cluster_client_cursor.h
index 57c2fa7d100..a83b50f9287 100644
--- a/src/mongo/s/query/cluster_client_cursor.h
+++ b/src/mongo/s/query/cluster_client_cursor.h
@@ -221,6 +221,14 @@ public:
      */
     virtual void incNBatches() = 0;
 
+    void incrementCursorMetrics(OpDebug::AdditiveMetrics newMetrics,
+                                uint64_t newExecutionTime,
+                                uint64_t newDocsReturned) {
+        _metrics.add(newMetrics);
+        _queryExecMicros += newExecutionTime;
+        _docsReturned += newDocsReturned;
+    }
+
     //
     // maxTimeMS support.
     //
@@ -245,6 +253,12 @@ public:
         _leftoverMaxTimeMicros = leftoverMaxTimeMicros;
     }
 
+protected:
+    // Metrics used for telemetry. TODO SERVER-73933 consider merging more into '_metrics'
+    uint64_t _queryExecMicros = 0;
+    uint64_t _docsReturned = 0;
+    OpDebug::AdditiveMetrics _metrics;
+
 private:
     // Unused maxTime budget for this cursor.
     Microseconds _leftoverMaxTimeMicros = Microseconds::max();