diff options
| author | Charlie Swanson <charlie.swanson@mongodb.com> | 2018-05-15 15:20:37 -0400 |
|---|---|---|
| committer | Charlie Swanson <charlie.swanson@mongodb.com> | 2018-05-17 10:28:26 -0400 |
| commit | 664e1d9b01dccddeec072b7746d7d4c62931716d (patch) | |
| tree | 1a79d178e84cb9a378726e3256f18f1799ba78c8 /jstests/multiVersion | |
| parent | f3439006a717ea1c8b1598b0e68935816e150564 (diff) | |
| download | mongo-664e1d9b01dccddeec072b7746d7d4c62931716d.tar.gz | |
SERVER-34818 Rename startAtClusterTime to startAtOperationTime
Also changes the type of the argument from an object with a single 'ts'
field to just a Timestamp.
Diffstat (limited to 'jstests/multiVersion')
| -rw-r--r-- | jstests/multiVersion/change_streams_feature_compatibility_version.js | 9 |
1 files changed, 4 insertions, 5 deletions
diff --git a/jstests/multiVersion/change_streams_feature_compatibility_version.js b/jstests/multiVersion/change_streams_feature_compatibility_version.js index 470b534aafa..a4b77fb350b 100644 --- a/jstests/multiVersion/change_streams_feature_compatibility_version.js +++ b/jstests/multiVersion/change_streams_feature_compatibility_version.js @@ -68,8 +68,7 @@ assert.commandFailedWithCode(testDB.runCommand({ aggregate: coll.getName(), - pipeline: - [{$changeStream: {startAtClusterTime: {ts: failedResponse.$clusterTime.clusterTime}}}], + pipeline: [{$changeStream: {startAtOperationTime: failedResponse.operationTime}}], cursor: {} }), 40415); @@ -102,7 +101,7 @@ // response to use later. const startTime = assert.commandWorked(adminDB.runCommand({setFeatureCompatibilityVersion: "4.0"})) - .$clusterTime.clusterTime; + .operationTime; // Test that we can now use 4.0 features to open a stream. const wholeDbCursor = @@ -110,7 +109,7 @@ const wholeClusterCursor = adminCST.startWatchingChanges( {pipeline: [{$changeStream: {allChangesForCluster: true}}], collection: 1}); const cursorStartedWithTime = cst.startWatchingChanges({ - pipeline: [{$changeStream: {startAtClusterTime: {ts: startTime}}}], + pipeline: [{$changeStream: {startAtOperationTime: startTime}}], collection: coll.getName() }); @@ -197,7 +196,7 @@ assert.commandFailedWithCode(testDB.runCommand({ aggregate: coll.getName(), - pipeline: [{$changeStream: {startAtClusterTime: {ts: startTime}}}], + pipeline: [{$changeStream: {startAtOperationTime: startTime}}], cursor: {} }), ErrorCodes.QueryFeatureNotAllowed); |