mirror
/
sitespeed.io
mirror of https://github.com/sitespeedio/sitespeed.io.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Only send summary and pageSummary for graphing.

This commit is contained in:
Tobias Lidskog 2016-03-22 23:34:54 +01:00
parent ab0bf26ce2
commit 61adcd8714
2 changed files with 30 additions and 38 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
lib/plugins/graphite/index.js
View File

@ -20,7 +20,9 @@ function isEmpty(o) {
}
module.exports = {
name() { return path.basename(__dirname); },
name() {
return path.basename(__dirname);
},
open(context, options) {
throwIfMissing(options.graphite, ['host', 'port', 'namespace'], 'graphite');
@ -29,26 +31,20 @@ module.exports = {
this.dataGenerator = new DataGenerator(opts.namespace, opts.includeQueryParams);
},
processMessage(message) {
switch (message.type) {
case 'browsertime.pageSummary':
case 'webpagetest.pageSummary':
case 'gpsi.pageSummary':
case 'domains.summary':
case 'coach.summary':
{
message = filterRegistry.filterMessage(message);
if (isEmpty(message.data))
return;
if (!(message.type.endsWith('.summary') || message.type.endsWith('.pageSummary')))
return;
let data = this.dataGenerator.dataFromMessage(message);
message = filterRegistry.filterMessage(message);
if (isEmpty(message.data))
return;
if (data.length > 0) {
return this.sender.send(data);
} else {
return Promise.reject(new Error('No data to send to graphite for message:\n' +
JSON.stringify(message, null, 2)));
}
}
let data = this.dataGenerator.dataFromMessage(message);
if (data.length > 0) {
return this.sender.send(data);
} else {
return Promise.reject(new Error('No data to send to graphite for message:\n' +
JSON.stringify(message, null, 2)));
}
}
};

34
lib/plugins/influxdb/index.js
View File

@ -20,7 +20,9 @@ function isEmpty(o) {
}
module.exports = {
name() { return path.basename(__dirname); },
name() {
return path.basename(__dirname);
},
open(context, options) {
throwIfMissing(options.influxdb, ['host', 'database'], 'influxdb');
@ -29,26 +31,20 @@ module.exports = {
this.dataGenerator = new DataGenerator(opts.includeQueryParams);
},
processMessage(message) {
switch (message.type) {
case 'browsertime.pageSummary':
case 'webpagetest.pageSummary':
case 'gpsi.pageSummary':
case 'domains.summary':
case 'coach.summary':
{
message = filterRegistry.filterMessage(message);
if (isEmpty(message.data))
return;
if (!(message.type.endsWith('.summary') || message.type.endsWith('.pageSummary')))
return;
let data = this.dataGenerator.dataFromMessage(message);
message = filterRegistry.filterMessage(message);
if (isEmpty(message.data))
return;
if (data.length > 0) {
return this.sender.send(data);
} else {
return Promise.reject(new Error('No data to send to influxdb for message:\n' +
JSON.stringify(message, null, 2)));
}
}
let data = this.dataGenerator.dataFromMessage(message);
if (data.length > 0) {
return this.sender.send(data);
} else {
return Promise.reject(new Error('No data to send to influxdb for message:\n' +
JSON.stringify(message, null, 2)));
}
}
};