SERVER-48849 Add filtering to the OplogFetcher

1 files changed, 11 insertions, 1 deletions

diff --git a/src/mongo/db/repl/oplog_fetcher.h b/src/mongo/db/repl/oplog_fetcher.h
index 4c3a765a780..0ae2d472cc9 100644
--- a/src/mongo/db/repl/oplog_fetcher.h
+++ b/src/mongo/db/repl/oplog_fetcher.h
@@ -177,7 +177,10 @@ public:
                  EnqueueDocumentsFn enqueueDocumentsFn,
                  OnShutdownCallbackFn onShutdownCallbackFn,
                  const int batchSize,
-                 StartingPoint startingPoint = StartingPoint::kSkipFirstDoc);
+                 StartingPoint startingPoint = StartingPoint::kSkipFirstDoc,
+                 BSONObj filter = BSONObj(),
+                 ReadConcernArgs readConcern = ReadConcernArgs(),
+                 StringData name = "oplog fetcher"_sd);
 
     virtual ~OplogFetcher();
 
@@ -431,6 +434,13 @@ private:
     // Indicates if we want to skip the first document during oplog fetching or not.
     StartingPoint _startingPoint;
 
+    // Predicate with additional filtering to be done on oplog entries.
+    BSONObj _queryFilter;
+
+    // Read concern to use for reading the oplog.  Empty read concern means we use a default
+    // of "afterClusterTime: Timestamp(0,1)".
+    ReadConcernArgs _queryReadConcern;
+
     // Handle to currently scheduled _runQuery task.
     executor::TaskExecutor::CallbackHandle _runQueryHandle;