summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl
diff options
context:
space:
mode:
authorEnrico Golfieri <enrico.golfieri@mongodb.com>2022-12-12 11:08:44 +0000
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2022-12-12 12:46:40 +0000
commit4fc261005c7726a1b99025d60e6ded3f1ba299ca (patch)
tree69a8e4786a30242b43dae12bcf6c6a14b5edd293 /src/mongo/db/repl
parent21aba5b624e0371869a453f89ad1b3711ee720b0 (diff)
downloadmongo-4fc261005c7726a1b99025d60e6ded3f1ba299ca.tar.gz
SERVER-71754 Define a new remote command to notify the completion of an addShard() operation to other nodes of the cluster
Diffstat (limited to 'src/mongo/db/repl')
-rw-r--r--src/mongo/db/repl/change_stream_oplog_notification.cpp5
-rw-r--r--src/mongo/db/repl/change_stream_oplog_notification.h7
2 files changed, 11 insertions, 1 deletions
diff --git a/src/mongo/db/repl/change_stream_oplog_notification.cpp b/src/mongo/db/repl/change_stream_oplog_notification.cpp
index 531f7af2e57..b1c26353d93 100644
--- a/src/mongo/db/repl/change_stream_oplog_notification.cpp
+++ b/src/mongo/db/repl/change_stream_oplog_notification.cpp
@@ -34,7 +34,6 @@
#include "mongo/db/namespace_string.h"
#include "mongo/db/repl/oplog.h"
#include "mongo/db/repl/oplog_entry.h"
-#include "mongo/logv2/redaction.h"
namespace mongo {
@@ -70,4 +69,8 @@ void notifyChangeStreamsOnShardCollection(OperationContext* opCtx,
wunit.commit();
});
}
+
+void notifyChangeStreamsOnAddShard(OperationContext* opCtx,
+ const ShardId& shardName,
+ const ConnectionString& connStr) {}
} // namespace mongo
diff --git a/src/mongo/db/repl/change_stream_oplog_notification.h b/src/mongo/db/repl/change_stream_oplog_notification.h
index ee746b96167..c999eadc2a8 100644
--- a/src/mongo/db/repl/change_stream_oplog_notification.h
+++ b/src/mongo/db/repl/change_stream_oplog_notification.h
@@ -30,8 +30,10 @@
#pragma once
#include "mongo/bson/bsonobj.h"
+#include "mongo/client/connection_string.h"
#include "mongo/db/namespace_string.h"
#include "mongo/db/operation_context.h"
+#include "mongo/db/shard_id.h"
#include "mongo/util/uuid.h"
namespace mongo {
@@ -44,4 +46,9 @@ void notifyChangeStreamsOnShardCollection(OperationContext* opCtx,
const NamespaceString& nss,
const UUID& uuid,
BSONObj cmd);
+
+void notifyChangeStreamsOnAddShard(OperationContext* opCtx,
+ const ShardId& shardName,
+ const ConnectionString& connStr);
+
} // namespace mongo