kemko/nomad
1
0
Fork 0
mirror of https://github.com/kemko/nomad.git synced 2026-01-08 03:15:42 +03:00
Code Issues Packages Projects Releases Wiki Activity

Update stat tracker unit tests

Browse Source
This commit is contained in:
Michael Lange
2018-09-19 19:30:18 -07:00
parent 866f650de8
commit 47ec74eb3a
3 changed files with 91 additions and 61 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
ui/app/utils/classes/abstract-stats-tracker.js
View File

@@ -31,12 +31,16 @@ export default Mixin.create({
// Interrupt any pause attempt
this.get('signalPause').cancelAll();
const url = this.get('url');
assert('Url must be defined', url);
try {
const url = this.get('url');
assert('Url must be defined', url);
yield this.get('fetch')(url)
.then(res => res.json())
.then(frame => this.append(frame));
yield this.get('fetch')(url)
.then(res => res.json())
.then(frame => this.append(frame));
} catch (error) {
throw new Error(error);
}
yield timeout(2000);
}).drop(),

111
ui/tests/unit/utils/allocation-stats-tracker-test.js
View File

@@ -9,7 +9,8 @@ import fetch from 'nomad-ui/utils/fetch';
module('Unit | Util | AllocationStatsTracker');
const refDate = Date.now();
const refDate = Date.now() * 1000000;
const makeDate = ts => new Date(ts / 1000000);
const MockAllocation = overrides =>
assign(
@@ -91,7 +92,7 @@ test('the AllocationStatsTracker constructor expects a fetch definition and an a
const tracker = AllocationStatsTracker.create();
assert.throws(
() => {
tracker.poll();
tracker.fetch();
},
/StatsTrackers need a fetch method/,
'Polling does not work without a fetch method provided'
@@ -159,7 +160,7 @@ test('poll results in requesting the url and calling append with the resulting J
this.get('/v1/client/allocation/:id/stats', () => [200, {}, JSON.stringify(mockFrame)]);
});
tracker.poll();
tracker.get('poll').perform();
assert.equal(server.handledRequests.length, 1, 'Only one request was made');
assert.equal(
@@ -199,12 +200,18 @@ test('append appropriately maps a data frame to the tracked stats for cpu and me
assert.deepEqual(
tracker.get('cpu'),
[{ timestamp: refDate + 1000, used: 101, percent: 101 / 200 }],
[{ timestamp: makeDate(refDate + 1000), used: 101, percent: 101 / 200 }],
'One frame of cpu'
);
assert.deepEqual(
tracker.get('memory'),
[{ timestamp: refDate + 1000, used: 401 * 1024 * 1024, percent: 401 / 512 }],
[
{
timestamp: makeDate(refDate + 1000),
used: 401 * 1024 * 1024,
percent: 401 / 512,
},
],
'One frame of memory'
);
@@ -215,22 +222,40 @@ test('append appropriately maps a data frame to the tracked stats for cpu and me
task: 'service',
reservedCPU: 100,
reservedMemory: 256,
cpu: [{ timestamp: refDate + 1, used: 51, percent: 51 / 100 }],
memory: [{ timestamp: refDate + 1, used: 101 * 1024 * 1024, percent: 101 / 256 }],
cpu: [{ timestamp: makeDate(refDate + 1), used: 51, percent: 51 / 100 }],
memory: [
{
timestamp: makeDate(refDate + 1),
used: 101 * 1024 * 1024,
percent: 101 / 256,
},
],
},
{
task: 'log-shipper',
reservedCPU: 50,
reservedMemory: 128,
cpu: [{ timestamp: refDate + 10, used: 26, percent: 26 / 50 }],
memory: [{ timestamp: refDate + 10, used: 51 * 1024 * 1024, percent: 51 / 128 }],
cpu: [{ timestamp: makeDate(refDate + 10), used: 26, percent: 26 / 50 }],
memory: [
{
timestamp: makeDate(refDate + 10),
used: 51 * 1024 * 1024,
percent: 51 / 128,
},
],
},
{
task: 'sidecar',
reservedCPU: 50,
reservedMemory: 128,
cpu: [{ timestamp: refDate + 100, used: 27, percent: 27 / 50 }],
memory: [{ timestamp: refDate + 100, used: 52 * 1024 * 1024, percent: 52 / 128 }],
cpu: [{ timestamp: makeDate(refDate + 100), used: 27, percent: 27 / 50 }],
memory: [
{
timestamp: makeDate(refDate + 100),
used: 52 * 1024 * 1024,
percent: 52 / 128,
},
],
},
],
'tasks represents the tasks for the allocation, each with one frame of stats'
@@ -241,16 +266,16 @@ test('append appropriately maps a data frame to the tracked stats for cpu and me
assert.deepEqual(
tracker.get('cpu'),
[
{ timestamp: refDate + 1000, used: 101, percent: 101 / 200 },
{ timestamp: refDate + 2000, used: 102, percent: 102 / 200 },
{ timestamp: makeDate(refDate + 1000), used: 101, percent: 101 / 200 },
{ timestamp: makeDate(refDate + 2000), used: 102, percent: 102 / 200 },
],
'Two frames of cpu'
);
assert.deepEqual(
tracker.get('memory'),
[
{ timestamp: refDate + 1000, used: 401 * 1024 * 1024, percent: 401 / 512 },
{ timestamp: refDate + 2000, used: 402 * 1024 * 1024, percent: 402 / 512 },
{ timestamp: makeDate(refDate + 1000), used: 401 * 1024 * 1024, percent: 401 / 512 },
{ timestamp: makeDate(refDate + 2000), used: 402 * 1024 * 1024, percent: 402 / 512 },
],
'Two frames of memory'
);
@@ -263,12 +288,12 @@ test('append appropriately maps a data frame to the tracked stats for cpu and me
reservedCPU: 100,
reservedMemory: 256,
cpu: [
{ timestamp: refDate + 1, used: 51, percent: 51 / 100 },
{ timestamp: refDate + 2, used: 52, percent: 52 / 100 },
{ timestamp: makeDate(refDate + 1), used: 51, percent: 51 / 100 },
{ timestamp: makeDate(refDate + 2), used: 52, percent: 52 / 100 },
],
memory: [
{ timestamp: refDate + 1, used: 101 * 1024 * 1024, percent: 101 / 256 },
{ timestamp: refDate + 2, used: 102 * 1024 * 1024, percent: 102 / 256 },
{ timestamp: makeDate(refDate + 1), used: 101 * 1024 * 1024, percent: 101 / 256 },
{ timestamp: makeDate(refDate + 2), used: 102 * 1024 * 1024, percent: 102 / 256 },
],
},
{
@@ -276,12 +301,12 @@ test('append appropriately maps a data frame to the tracked stats for cpu and me
reservedCPU: 50,
reservedMemory: 128,
cpu: [
{ timestamp: refDate + 10, used: 26, percent: 26 / 50 },
{ timestamp: refDate + 20, used: 27, percent: 27 / 50 },
{ timestamp: makeDate(refDate + 10), used: 26, percent: 26 / 50 },
{ timestamp: makeDate(refDate + 20), used: 27, percent: 27 / 50 },
],
memory: [
{ timestamp: refDate + 10, used: 51 * 1024 * 1024, percent: 51 / 128 },
{ timestamp: refDate + 20, used: 52 * 1024 * 1024, percent: 52 / 128 },
{ timestamp: makeDate(refDate + 10), used: 51 * 1024 * 1024, percent: 51 / 128 },
{ timestamp: makeDate(refDate + 20), used: 52 * 1024 * 1024, percent: 52 / 128 },
],
},
{
@@ -289,12 +314,12 @@ test('append appropriately maps a data frame to the tracked stats for cpu and me
reservedCPU: 50,
reservedMemory: 128,
cpu: [
{ timestamp: refDate + 100, used: 27, percent: 27 / 50 },
{ timestamp: refDate + 200, used: 28, percent: 28 / 50 },
{ timestamp: makeDate(refDate + 100), used: 27, percent: 27 / 50 },
{ timestamp: makeDate(refDate + 200), used: 28, percent: 28 / 50 },
],
memory: [
{ timestamp: refDate + 100, used: 52 * 1024 * 1024, percent: 52 / 128 },
{ timestamp: refDate + 200, used: 53 * 1024 * 1024, percent: 53 / 128 },
{ timestamp: makeDate(refDate + 100), used: 52 * 1024 * 1024, percent: 52 / 128 },
{ timestamp: makeDate(refDate + 200), used: 53 * 1024 * 1024, percent: 53 / 128 },
],
},
],
@@ -323,13 +348,13 @@ test('each stat list has maxLength equal to bufferSize', function(assert) {
);
assert.equal(
tracker.get('cpu')[0].timestamp,
refDate + 11000,
+tracker.get('cpu')[0].timestamp,
+makeDate(refDate + 11000),
'Old frames are removed in favor of newer ones'
);
assert.equal(
tracker.get('memory')[0].timestamp,
refDate + 11000,
+tracker.get('memory')[0].timestamp,
+makeDate(refDate + 11000),
'Old frames are removed in favor of newer ones'
);
@@ -347,35 +372,35 @@ test('each stat list has maxLength equal to bufferSize', function(assert) {
});
assert.equal(
tracker.get('tasks').findBy('task', 'service').cpu[0].timestamp,
refDate + 11,
+tracker.get('tasks').findBy('task', 'service').cpu[0].timestamp,
+makeDate(refDate + 11),
'Old frames are removed in favor of newer ones'
);
assert.equal(
tracker.get('tasks').findBy('task', 'service').memory[0].timestamp,
refDate + 11,
+tracker.get('tasks').findBy('task', 'service').memory[0].timestamp,
+makeDate(refDate + 11),
'Old frames are removed in favor of newer ones'
);
assert.equal(
tracker.get('tasks').findBy('task', 'log-shipper').cpu[0].timestamp,
refDate + 110,
+tracker.get('tasks').findBy('task', 'log-shipper').cpu[0].timestamp,
+makeDate(refDate + 110),
'Old frames are removed in favor of newer ones'
);
assert.equal(
tracker.get('tasks').findBy('task', 'log-shipper').memory[0].timestamp,
refDate + 110,
+tracker.get('tasks').findBy('task', 'log-shipper').memory[0].timestamp,
+makeDate(refDate + 110),
'Old frames are removed in favor of newer ones'
);
assert.equal(
tracker.get('tasks').findBy('task', 'sidecar').cpu[0].timestamp,
refDate + 1100,
+tracker.get('tasks').findBy('task', 'sidecar').cpu[0].timestamp,
+makeDate(refDate + 1100),
'Old frames are removed in favor of newer ones'
);
assert.equal(
tracker.get('tasks').findBy('task', 'sidecar').memory[0].timestamp,
refDate + 1100,
+tracker.get('tasks').findBy('task', 'sidecar').memory[0].timestamp,
+makeDate(refDate + 1100),
'Old frames are removed in favor of newer ones'
);
});

27
ui/tests/unit/utils/node-stats-tracker-test.js
View File

@@ -9,7 +9,8 @@ import fetch from 'nomad-ui/utils/fetch';
module('Unit | Util | NodeStatsTracker');
const refDate = Date.now();
const refDate = Date.now() * 1000000;
const makeDate = ts => new Date(ts / 1000000);
const MockNode = overrides =>
assign(
@@ -35,7 +36,7 @@ test('the NodeStatsTracker constructor expects a fetch definition and a node', f
const tracker = NodeStatsTracker.create();
assert.throws(
() => {
tracker.poll();
tracker.fetch();
},
/StatsTrackers need a fetch method/,
'Polling does not work without a fetch method provided'
@@ -79,7 +80,7 @@ test('poll results in requesting the url and calling append with the resulting J
this.get('/v1/client/stats', () => [200, {}, JSON.stringify(mockFrame)]);
});
tracker.poll();
tracker.get('poll').perform();
assert.equal(server.handledRequests.length, 1, 'Only one request was made');
assert.equal(
@@ -109,13 +110,13 @@ test('append appropriately maps a data frame to the tracked stats for cpu and me
assert.deepEqual(
tracker.get('cpu'),
[{ timestamp: refDate + 1, used: 1001, percent: 1001 / 2000 }],
[{ timestamp: makeDate(refDate + 1), used: 1001, percent: 1001 / 2000 }],
'One frame of cpu'
);
assert.deepEqual(
tracker.get('memory'),
[{ timestamp: refDate + 1, used: 2049 * 1024 * 1024, percent: 2049 / 4096 }],
[{ timestamp: makeDate(refDate + 1), used: 2049 * 1024 * 1024, percent: 2049 / 4096 }],
'One frame of memory'
);
@@ -124,8 +125,8 @@ test('append appropriately maps a data frame to the tracked stats for cpu and me
assert.deepEqual(
tracker.get('cpu'),
[
{ timestamp: refDate + 1, used: 1001, percent: 1001 / 2000 },
{ timestamp: refDate + 2, used: 1002, percent: 1002 / 2000 },
{ timestamp: makeDate(refDate + 1), used: 1001, percent: 1001 / 2000 },
{ timestamp: makeDate(refDate + 2), used: 1002, percent: 1002 / 2000 },
],
'Two frames of cpu'
);
@@ -133,8 +134,8 @@ test('append appropriately maps a data frame to the tracked stats for cpu and me
assert.deepEqual(
tracker.get('memory'),
[
{ timestamp: refDate + 1, used: 2049 * 1024 * 1024, percent: 2049 / 4096 },
{ timestamp: refDate + 2, used: 2050 * 1024 * 1024, percent: 2050 / 4096 },
{ timestamp: makeDate(refDate + 1), used: 2049 * 1024 * 1024, percent: 2049 / 4096 },
{ timestamp: makeDate(refDate + 2), used: 2050 * 1024 * 1024, percent: 2050 / 4096 },
],
'Two frames of memory'
);
@@ -161,13 +162,13 @@ test('each stat list has maxLength equal to bufferSize', function(assert) {
);
assert.equal(
tracker.get('cpu')[0].timestamp,
refDate + 11,
+tracker.get('cpu')[0].timestamp,
+makeDate(refDate + 11),
'Old frames are removed in favor of newer ones'
);
assert.equal(
tracker.get('memory')[0].timestamp,
refDate + 11,
+tracker.get('memory')[0].timestamp,
+makeDate(refDate + 11),
'Old frames are removed in favor of newer ones'
);
});