summaryrefslogtreecommitdiff
path: root/src/mongo/db/commands/run_aggregate.cpp
diff options
context:
space:
mode:
authorWill Buerger <will.buerger@mongodb.com>2023-05-17 11:49:47 +0000
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2023-05-17 12:58:52 +0000
commitae65ecae5514adc99d60b7396137a1acf2b44335 (patch)
tree24169f9a640321bfbbec649e869fe51b273b35e3 /src/mongo/db/commands/run_aggregate.cpp
parent1b4a551a6b8c85611e26857217ce1a1e1363e716 (diff)
downloadmongo-ae65ecae5514adc99d60b7396137a1acf2b44335.tar.gz
SERVER-76427 Rename $telemetry to $queryStats
Diffstat (limited to 'src/mongo/db/commands/run_aggregate.cpp')
-rw-r--r--src/mongo/db/commands/run_aggregate.cpp18
1 files changed, 9 insertions, 9 deletions
diff --git a/src/mongo/db/commands/run_aggregate.cpp b/src/mongo/db/commands/run_aggregate.cpp
index a290ef56713..0bc7d7f6415 100644
--- a/src/mongo/db/commands/run_aggregate.cpp
+++ b/src/mongo/db/commands/run_aggregate.cpp
@@ -76,7 +76,7 @@
#include "mongo/db/query/query_feature_flags_gen.h"
#include "mongo/db/query/query_knobs_gen.h"
#include "mongo/db/query/query_planner_common.h"
-#include "mongo/db/query/telemetry.h"
+#include "mongo/db/query/query_stats.h"
#include "mongo/db/read_concern.h"
#include "mongo/db/repl/oplog.h"
#include "mongo/db/repl/read_concern_args.h"
@@ -836,11 +836,11 @@ Status runAggregate(OperationContext* opCtx,
};
auto registerTelemetry = [&]() -> void {
- // Register telemetry. Exclude queries against collections with encrypted fields.
- // We still collect telemetry on collection-less aggregations.
+ // Register queryStats. Exclude queries against collections with encrypted fields.
+ // We still collect queryStats on collection-less aggregations.
if (!(ctx && ctx->getCollection() &&
ctx->getCollection()->getCollectionOptions().encryptedFieldConfig)) {
- telemetry::registerAggRequest(request, opCtx);
+ query_stats::registerAggRequest(request, opCtx);
}
};
@@ -1051,9 +1051,9 @@ Status runAggregate(OperationContext* opCtx,
request.getEncryptionInformation()->setCrudProcessed(true);
}
- // Set the telemetryStoreKey to none so telemetry isn't collected when we've done a FLE
- // rewrite.
- CurOp::get(opCtx)->debug().telemetryStoreKeyHash = boost::none;
+ // Set the queryStatsStoreKey to none so queryStats isn't collected when we've done a
+ // FLE rewrite.
+ CurOp::get(opCtx)->debug().queryStatsStoreKeyHash = boost::none;
}
pipeline->optimizePipeline();
@@ -1223,9 +1223,9 @@ Status runAggregate(OperationContext* opCtx,
curOp->setEndOfOpMetrics(stats.nReturned);
if (keepCursor) {
- collectTelemetryMongod(opCtx, pins[0]);
+ collectQueryStatsMongod(opCtx, pins[0]);
} else {
- collectTelemetryMongod(opCtx, std::move(curOp->debug().telemetryRequestShapifier));
+ collectQueryStatsMongod(opCtx, std::move(curOp->debug().queryStatsRequestShapifier));
}
// For an optimized away pipeline, signal the cache that a query operation has completed.