Skip to content

Jabis Sev贸n / esm

Go to a project
Toggle navigation
Toggle navigation pinning
a541985e by Rafal Wilinski
Options

:mailbox: Add support for Response Times

1 parent 5837765c
Inline Side-by-side
Showing 2 changed files with 127 additions and 30 deletions
index.html
......@@ -50,33 +50,40 @@
<div class="container">
<div class="stats-column">
<h5>CPU Usage</h5>
<h1 id="cpuStat">0.03%</h1>
<h1 id="cpuStat">- %</h1>
</div>
<canvas id="cpuChart" width="400" height="100"></canvas>
</div>
<div class="container">
<div class="stats-column">
<h5>Memory Usage</h5>
<h1 id="memStat">0.03%</h1>
<h1 id="memStat">- %</h1>
</div>
<canvas id="memChart" width="400" height="100"></canvas>
</div>
<div class="container">
<div class="stats-column">
<h5>Requests per second</h5>
<h1 id="rpsStat">1.45</h1>
<h1 id="rpsStat">-</h1>
</div>
<canvas id="rpsChart" width="400" height="100"></canvas>
</div>
<div class="Status Codes">
<div class="container">
<div class="stats-column">
<h5>Response Time Mean</h5>
<h1 id="responseTimeStat">- ms</h1>
</div>
<canvas id="responseTimeChart" width="400" height="100"></canvas>
</div>
<div class="container">
<div class="stats-column">
<h5>Response status codes</h5>
<h1 id="codeStat">OK</h1>
<h1 id="statusCodeStat">-</h1>
</div>
<canvas id="codeChart" width="400" height="100"></canvas>
<canvas id="statusCodeChart" width="400" height="100"></canvas>
</div>
<div class="footer">
<p>Powered by Socket.io</p>
<p>Powered by Socket.io & Chart.js</p>
</div>
</div>
<script>
......@@ -95,12 +102,35 @@
lineTension: 0.3,
pointRadius: 0,
}];
var memDataset = [{
label: 'Memory Usage in MB',
data: [],
lineTension: 0.6,
pointRadius: 0,
}];
var responseTimeDataset = [{
label: 'Mean Response time',
data: [],
lineTension: 0.6,
pointRadius: 0,
}];
var rpsDataset = [{
label: 'Requests per second',
data: [],
lineTension: 0.6,
pointRadius: 0,
}];
var statusCodesDataset = [{
label: 'Memory Usage in MB',
data: [],
lineTension: 0.6,
pointRadius: 0,
}];
var defaultOptions = {
scales: {
yAxes: [{
......@@ -124,8 +154,14 @@
};
var cpuStat = document.getElementById('cpuStat');
var memStat = document.getElementById('memStat');
var responseTimeStat = document.getElementById('responseTimeStat');
var rpsStat = document.getElementById('rpsStat');
var cpuChartCtx = document.getElementById("cpuChart");
var memChartCtx = document.getElementById("memChart");
var rpsChartCtx = document.getElementById("rpsChart");
var responseTimeChartCtx = document.getElementById("responseTimeChart");
var statusCodeChartCtx = document.getElementById("statusCodeChart");
var cpuChart = new Chart(cpuChartCtx, {
type: 'line',
data: {
......@@ -144,17 +180,55 @@
options: defaultOptions
});
var rpsChart = new Chart(rpsChartCtx, {
type: 'line',
data: {
labels: labels,
datasets: responseTimeDataset,
},
options: defaultOptions
});
var responseTimeChart = new Chart(responseTimeChartCtx, {
type: 'line',
data: {
labels: labels,
datasets: responseTimeDataset,
},
options: defaultOptions
});
var statusCodeChart = new Chart(statusCodeChartCtx, {
type: 'line',
data: {
labels: labels,
datasets: statusCodesDataset,
},
options: defaultOptions
});
socket.on('stats', function (data) {
console.log(data);
cpuStat.textContent = data.osStats[data.osStats.length - 1].cpu.toFixed(1) + '%';
cpuChart.data.datasets[0].data = data.osStats.map((point) => point.cpu);
cpuChart.data.labels = data.osStats.map((point) => point.timestamp);
cpuChart.data.datasets[0].data = data.osStats.map(function(point) { return point.cpu; });
cpuChart.data.labels = data.osStats.map(function(point) { return point.timestamp; });
cpuChart.update();
memStat.textContent = data.osStats[data.osStats.length - 1].memory.toFixed(1) + 'MB';
memChart.data.datasets[0].data = data.osStats.map((point) => point.memory);
memChart.data.labels = data.osStats.map((point) => point.timestamp);
memChart.data.datasets[0].data = data.osStats.map(function(point) { return point.memory; });
memChart.data.labels = data.osStats.map(function(point) { return point.timestamp; });
memChart.update();
if (data.responses.length > 0) {
responseTimeStat.textContent = data.responses[data.responses.length - 1].mean.toFixed(1) + 'ms';
responseTimeChart.data.datasets[0].data = data.responses.map(function (point) {
return point.mean;
});
responseTimeChart.data.labels = data.responses.map(function (point) {
return point.timestamp;
});
responseTimeChart.update();
}
});
</script>
</body>
......
index.js
......@@ -4,33 +4,35 @@
const path = require('path');
const onHeaders = require('on-headers');
const pidusage = require('pidusage');
const responseTimes = [];
const osStats = [];
const defaultConfig = {
socketPort: 41338,
path: '/status',
spans: [{
interval: 1,
retention: 100,
retention: 60
}]
};
const gatherOsMetrics = (io, config) => {
const gatherOsMetrics = (io, span) => {
pidusage.stat(process.pid, (err, stat) => {
stat.timestamp = Date.now();
// Convert from B to MB
stat.memory = stat.memory / 1024 / 1024;
osStats.push(stat);
if (osStats.length >= config.retention) osStats.shift();
span.osStats.push(stat);
if (span.osStats.length >= span.retention) span.osStats.shift();
if (span.responses[0] && span.responses[0].timestamp + (span.interval * span.retention * 1000) < Date.now()) span.responses.shift();
sendMetrics(io);
sendMetrics(io, span);
});
};
const sendMetrics = (io) => {
const sendMetrics = (io, span) => {
io.emit('stats', {
osStats,
responseTimes
osStats: span.osStats,
responses: span.responses,
});
};
......@@ -47,13 +49,21 @@
config.socketPort = defaultConfig.socketPort;
}
if (config.interval === undefined || !config instanceof Number) {
config.interval = defaultConfig.interval;
if (config.spans === undefined || !config instanceof Array) {
config.spans = defaultConfig.span;
}
const io = require('socket.io')(config.socketPort);
setInterval(() => gatherOsMetrics(io, config), config.interval * 1000);
io.on('connection', (socket) => {
console.log('User connected! ' + socket);
});
config.spans.forEach((span) => {
span.osStats = [];
span.responses = [];
setInterval(() => gatherOsMetrics(io, span), span.interval * 1000);
});
return (req, res, next) => {
const startTime = process.hrtime();
......@@ -61,14 +71,27 @@
res.sendFile(path.join(__dirname + '/index.html'));
} else {
onHeaders(res, () => {
var diff = process.hrtime(startTime);
var responseTime = diff[0] * 1e3 + diff[1] * 1e-6;
responseTimes.push({
endpoint: req.path,
responseTime,
const diff = process.hrtime(startTime);
const responseTime = diff[0] * 1e3 + diff[1] * 1e-6;
const category = Math.floor(res.statusCode / 100);
config.spans.forEach((span) => {
if (span.responses[span.responses.length - 1] !== undefined &&
span.responses[span.responses.length - 1].timestamp / 1000 + span.interval > Date.now() / 1000) {
span.responses[span.responses.length - 1][category]++;
span.responses[span.responses.length - 1].count++;
} else {
span.responses.push({
'2': category === 2 ? 1 : 0,
'3': category === 3 ? 1 : 0,
'4': category === 4 ? 1 : 0,
'5': category === 5 ? 1 : 0,
count: 1,
mean: responseTime,
timestamp: Date.now()
});
}
});
});
next();
......
Styling with Markdown is supported
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!