1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
|
/**
* Tests that the cluster collStats command returns timeseries statistics in the expected format.
*
* {
* ....,
* "ns" : ...,
* ....,
* "timeseries" : {
* .... (sums the shards' field values)
* }
* ....,
* "shards" : {
* <shardName> {
* "timeseries" : {
* .... (single shard's field values)
* }
* ....
* }
* }
* ....
* }
*
* @tags: [
* requires_fcv_50,
* ]
*/
(function() {
load("jstests/core/timeseries/libs/timeseries.js");
// Sharded timeseries collections are not yet supported. Therefore, the cluster will not possess the
// same collections/indexes.
TestData.skipCheckingIndexesConsistentAcrossCluster = true;
const st = new ShardingTest({shards: 2});
if (!TimeseriesTest.timeseriesCollectionsEnabled(st.shard0)) {
jsTestLog("Skipping test because the time-series collection feature flag is disabled");
st.stop();
return;
}
const dbName = 'testDB';
const mongosDB = st.s.getDB(dbName);
const collName = 'testColl';
const mongosColl = mongosDB.getCollection(collName);
// Create a timeseries collection.
assert.commandWorked(
mongosDB.createCollection(collName, {timeseries: {timeField: 'tm', metaField: 'xx'}}));
// Populate the timeseries collection with some data. More interesting test case, and populates the
// statistics results.
const numberDoc = 20;
for (let i = 0; i < numberDoc; i++) {
assert.commandWorked(mongosColl.insert({'tm': ISODate(), 'xx': i}));
}
assert.eq(mongosColl.count(), numberDoc);
// The cluster collStats command should pull the shard's 'timeseries' data to the top level of the
// command results.
const clusterCollStatsResult = assert.commandWorked(mongosDB.runCommand({collStats: collName}));
jsTestLog("Cluster collStats command result: " + tojson(clusterCollStatsResult));
assert(clusterCollStatsResult.timeseries,
"Expected a top-level 'timeseries' field but didn't find one: " +
tojson(clusterCollStatsResult));
// Check that the top-level 'timeseries' fields match the shard's, that the stats were correctly
// pulled up.
assert(
clusterCollStatsResult.shards["timeseries_cluster_collstats-rs1"].timeseries,
"Expected a shard 'timeseries' field but didn't find one: " + tojson(clusterCollStatsResult));
assert.docEq(clusterCollStatsResult.timeseries,
clusterCollStatsResult.shards["timeseries_cluster_collstats-rs1"].timeseries);
st.stop();
})();
|
