summaryrefslogtreecommitdiff
path: root/jstests/libs
diff options
context:
space:
mode:
authorDrew Paroski <drew.paroski@mongodb.com>2021-07-20 20:36:04 +0000
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2021-07-21 19:41:13 +0000
commit7cd6beba9999a93f985a99199eb5b824b7f18c75 (patch)
tree6434861e095d52384bb8df559df826e8c72ab506 /jstests/libs
parente441b28caa1f8b96df930a84e9271b5cbb6c5c06 (diff)
downloadmongo-7cd6beba9999a93f985a99199eb5b824b7f18c75.tar.gz
SERVER-58511 Create feature flag for change stream oplog rewrites
Diffstat (limited to 'jstests/libs')
-rw-r--r--jstests/libs/change_stream_util.js11
1 files changed, 10 insertions, 1 deletions
diff --git a/jstests/libs/change_stream_util.js b/jstests/libs/change_stream_util.js
index c7176c7f112..8daa0e8be29 100644
--- a/jstests/libs/change_stream_util.js
+++ b/jstests/libs/change_stream_util.js
@@ -17,13 +17,22 @@ const ChangeStreamWatchMode = Object.freeze({
/**
* Returns true if feature flag 'featureFlagChangeStreamsOptimization' is enabled, false otherwise.
*/
-function isChangeStreamOptimizationEnabled(db) {
+function isChangeStreamsOptimizationEnabled(db) {
const getParam = db.adminCommand({getParameter: 1, featureFlagChangeStreamsOptimization: 1});
return getParam.hasOwnProperty("featureFlagChangeStreamsOptimization") &&
getParam.featureFlagChangeStreamsOptimization.value;
}
/**
+ * Returns true if feature flag 'featureFlagChangeStreamsRewrite' is enabled, false otherwise.
+ */
+function isChangeStreamsRewriteEnabled(db) {
+ const getParam = db.adminCommand({getParameter: 1, featureFlagChangeStreamsRewrite: 1});
+ return getParam.hasOwnProperty("featureFlagChangeStreamsRewrite") &&
+ getParam.featureFlagChangeStreamsRewrite.value;
+}
+
+/**
* Helper function used internally by ChangeStreamTest. If no passthrough is active, it is exactly
* the same as calling db.runCommand. If a passthrough is active and has defined a function
* 'changeStreamPassthroughAwareRunCommand', then this method will be overridden to allow individual