summaryrefslogtreecommitdiff
path: root/src/mongo/db/pipeline/document_source_change_stream.h
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/pipeline/document_source_change_stream.h')
-rw-r--r--src/mongo/db/pipeline/document_source_change_stream.h17
1 files changed, 6 insertions, 11 deletions
diff --git a/src/mongo/db/pipeline/document_source_change_stream.h b/src/mongo/db/pipeline/document_source_change_stream.h
index 60013e64444..044623335ed 100644
--- a/src/mongo/db/pipeline/document_source_change_stream.h
+++ b/src/mongo/db/pipeline/document_source_change_stream.h
@@ -243,9 +243,13 @@ public:
// Default regex for collections match which prohibits system collections.
static constexpr StringData kRegexAllCollections = R"((?!(\$|system\.)))"_sd;
- // Regex matching all regular collections plus certain system collections.
+
+ // Regex matching all user collections plus collections exposed when 'showSystemEvents' is set.
+ // Does not match a collection named $ or a collection with 'system.' in the name.
+ // However, it will still match collection names starting with system.buckets or a collection
+ // exactly named system.js.
static constexpr StringData kRegexAllCollectionsShowSystemEvents =
- R"((?!(\$|system\.(?!(js$)))))"_sd;
+ R"((?!(\$|system\.(?!(js$|buckets\.)))))"_sd;
static constexpr StringData kRegexAllDBs = R"(^(?!(admin|config|local)\.)[^.]+)"_sd;
static constexpr StringData kRegexCmdColl = R"(\$cmd$)"_sd;
@@ -283,15 +287,6 @@ public:
static void checkValueType(Value v, StringData fieldName, BSONType expectedType);
/**
- * Extracts the resume token from the given spec. If a 'startAtOperationTime' is specified,
- * returns the equivalent high-watermark token. This method should only ever be called on a spec
- * where one of 'resumeAfter', 'startAfter', or 'startAtOperationTime' is populated.
- */
- static ResumeTokenData resolveResumeTokenFromSpec(
- const boost::intrusive_ptr<ExpressionContext>& expCtx,
- const DocumentSourceChangeStreamSpec& spec);
-
- /**
* For a change stream with no resume information supplied by the user, returns the clusterTime
* at which the new stream should begin scanning the oplog.
*/