diff options
| author | Lucas de Castro Borges <lucas@gnuabordo.com.br> | 2025-02-11 15:07:35 -0300 |
|---|---|---|
| committer | Lucas de Castro Borges <lucas@gnuabordo.com.br> | 2025-02-11 15:07:35 -0300 |
| commit | 4cb8841196d0625dfa3825aa326f071cd27c7b8b (patch) | |
| tree | 1682a647d4463397c119183369ae6f750d5fdcff /src/mongo/db/pipeline/process_interface/common_mongod_process_interface.h | |
| parent | aa03c6362cbaa767638e6eed9b031d86dd2643d1 (diff) | |
| parent | 8f0827553e09872941945a093b647a4211a9db7f (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.h | 20 |
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, |
