diff options
author | Drew Paroski <drew.paroski@mongodb.com> | 2021-07-20 20:36:04 +0000 |
---|---|---|
committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2021-07-21 19:41:13 +0000 |
commit | 7cd6beba9999a93f985a99199eb5b824b7f18c75 (patch) | |
tree | 6434861e095d52384bb8df559df826e8c72ab506 /jstests/libs | |
parent | e441b28caa1f8b96df930a84e9271b5cbb6c5c06 (diff) | |
download | mongo-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.js | 11 |
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 |