diff options
Diffstat (limited to 'src/mongo/db/op_observer.h')
| -rw-r--r-- | src/mongo/db/op_observer.h | 11 |
1 files changed, 9 insertions, 2 deletions
diff --git a/src/mongo/db/op_observer.h b/src/mongo/db/op_observer.h index 682a6f0311d..b0f187adb4f 100644 --- a/src/mongo/db/op_observer.h +++ b/src/mongo/db/op_observer.h @@ -287,18 +287,25 @@ public: * If the transaction was prepared, then 'commitOplogEntryOpTime' is passed in to be used as the * OpTime of the oplog entry. The 'commitTimestamp' is the timestamp at which the multi-document * transaction was committed. Either these fields should both be 'none' or neither should. + * + * The 'statements' are the list of CRUD operations to be applied in this transaction. */ virtual void onTransactionCommit(OperationContext* opCtx, boost::optional<OplogSlot> commitOplogEntryOpTime, - boost::optional<Timestamp> commitTimestamp) = 0; + boost::optional<Timestamp> commitTimestamp, + std::vector<repl::ReplOperation>& statements) = 0; /** * The onTransactionPrepare method is called when an atomic transaction is prepared. It must be * called when a transaction is active. * * The 'prepareOpTime' is passed in to be used as the OpTime of the oplog entry. + * + * The 'statements' are the list of CRUD operations to be applied in this transaction. */ - virtual void onTransactionPrepare(OperationContext* opCtx, const OplogSlot& prepareOpTime) = 0; + virtual void onTransactionPrepare(OperationContext* opCtx, + const OplogSlot& prepareOpTime, + std::vector<repl::ReplOperation>& statements) = 0; /** * The onTransactionAbort method is called when an atomic transaction aborts, before the |