summaryrefslogtreecommitdiff
path: root/src/mongo/db/pipeline/process_interface/common_mongod_process_interface.h
diff options
context:
space:
mode:
authorLucas de Castro Borges <lucas@gnuabordo.com.br>2025-02-11 15:07:35 -0300
committerLucas de Castro Borges <lucas@gnuabordo.com.br>2025-02-11 15:07:35 -0300
commit4cb8841196d0625dfa3825aa326f071cd27c7b8b (patch)
tree1682a647d4463397c119183369ae6f750d5fdcff /src/mongo/db/pipeline/process_interface/common_mongod_process_interface.h
parentaa03c6362cbaa767638e6eed9b031d86dd2643d1 (diff)
parent8f0827553e09872941945a093b647a4211a9db7f (diff)
Update upstream source from tag 'upstream/6.0.0'master
Update to upstream version '6.0.0' with Debian dir 5604a80ec1c96ca76f25f40d78e6ef855abec322
Diffstat (limited to 'src/mongo/db/pipeline/process_interface/common_mongod_process_interface.h')
-rw-r--r--src/mongo/db/pipeline/process_interface/common_mongod_process_interface.h20
1 files changed, 18 insertions, 2 deletions
diff --git a/src/mongo/db/pipeline/process_interface/common_mongod_process_interface.h b/src/mongo/db/pipeline/process_interface/common_mongod_process_interface.h
index 62edd6ca7d9..4a02ecce883 100644
--- a/src/mongo/db/pipeline/process_interface/common_mongod_process_interface.h
+++ b/src/mongo/db/pipeline/process_interface/common_mongod_process_interface.h
@@ -60,8 +60,7 @@ public:
std::deque<BSONObj> listCatalog(OperationContext* opCtx) const final;
boost::optional<BSONObj> getCatalogEntry(OperationContext* opCtx,
- const NamespaceString& ns,
- const boost::optional<UUID>& collUUID) const final;
+ const NamespaceString& ns) const final;
void appendLatencyStats(OperationContext* opCtx,
const NamespaceString& nss,
@@ -143,6 +142,23 @@ protected:
const Document& documentKey,
MakePipelineOptions opts);
+ /**
+ * Builds an ordered insert op on namespace 'nss' and documents to be written 'objs'.
+ */
+ write_ops::InsertCommandRequest buildInsertOp(const NamespaceString& nss,
+ std::vector<BSONObj>&& objs,
+ bool bypassDocValidation);
+
+ /**
+ * Builds an ordered update op on namespace 'nss' with update entries contained in 'batch'.
+ */
+ write_ops::UpdateCommandRequest buildUpdateOp(
+ const boost::intrusive_ptr<ExpressionContext>& expCtx,
+ const NamespaceString& nss,
+ BatchedObjects&& batch,
+ UpsertType upsert,
+ bool multi);
+
BSONObj _reportCurrentOpForClient(OperationContext* opCtx,
Client* client,
CurrentOpTruncateMode truncateOps,