SERVER-32335 add DataReplicatorExternalState::makeOplogApplier()

1 files changed, 17 insertions, 1 deletions

diff --git a/src/mongo/db/repl/data_replicator_external_state_impl.cpp b/src/mongo/db/repl/data_replicator_external_state_impl.cpp
index 3890e6848f6..f6e90096b73 100644
--- a/src/mongo/db/repl/data_replicator_external_state_impl.cpp
+++ b/src/mongo/db/repl/data_replicator_external_state_impl.cpp
@@ -37,7 +37,6 @@
 #include "mongo/db/repl/oplog_buffer_blocking_queue.h"
 #include "mongo/db/repl/oplog_buffer_collection.h"
 #include "mongo/db/repl/oplog_buffer_proxy.h"
-#include "mongo/db/repl/replication_consistency_markers.h"
 #include "mongo/db/repl/replication_coordinator.h"
 #include "mongo/db/repl/replication_coordinator_external_state.h"
 #include "mongo/db/repl/replication_process.h"
@@ -147,6 +146,23 @@ std::unique_ptr<OplogBuffer> DataReplicatorExternalStateImpl::makeInitialSyncOpl
     }
 }
 
+std::unique_ptr<OplogApplier> DataReplicatorExternalStateImpl::makeOplogApplier(
+    OplogBuffer* oplogBuffer,
+    OplogApplier::Observer* observer,
+    ReplicationConsistencyMarkers* consistencyMarkers,
+    StorageInterface* storageInterface,
+    const OplogApplier::Options& options,
+    ThreadPool* writerPool) {
+    return std::make_unique<OplogApplierImpl>(getTaskExecutor(),
+                                              oplogBuffer,
+                                              observer,
+                                              _replicationCoordinator,
+                                              consistencyMarkers,
+                                              storageInterface,
+                                              options,
+                                              writerPool);
+}
+
 StatusWith<OplogApplier::Operations> DataReplicatorExternalStateImpl::getNextApplierBatch(
     OperationContext* opCtx, OplogBuffer* oplogBuffer) {
     OplogApplierImpl oplogApplier(