webservices/servicedock
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

stats successfully transfered

Browse Source
This commit is contained in:
Marc Wäckerlin
2016-01-22 07:52:28 +00:00
parent 4546f0e2eb
commit bb3b0ab0ae
3 changed files with 53 additions and 26 deletions
Download Patch File Download Diff File Expand all files Collapse all files

69
nodejs/sockets/index.js
View File

@@ -9,38 +9,53 @@ module.exports = function() {
var proc = require('child_process');
function stats(ids) {
var res = [];
var res = {};
var fs = require('fs');
var async = require('async');
var base = "/sys/fs/cgroup/";
var dataPoints = {
"cpuacct": "stat",
"memory": "usage_in_bytes",
"memory": "max_usage_in_bytes"
"cpuacct": [
"stat"
],
"memory": [
"usage_in_bytes",
"max_usage_in_bytes"
]
};
ids.forEach(function(id) {
async.each(ids, function(id, cb1) {
res[id] = {};
for (key in dataPoints) {
var file = base + key + '/docker/' + id + '/' + dataPoints[key];
res[id][key] = {};
fs.readFile(file, 'utf8', function(err, data) {
if (err) return;
data.trim().split('\n').forEach(function(v, i) {
var vals = v.split(' ');
switch (vals.length) {
case 1:
res[id][dataPoints[key]] = parseInt(vals[0]);
break;
case 2:
res[id][key][dataPoints[key]] = {};
res[id][key][dataPoints[key]][vals[0]] = parseInt(vals[1]);
break;
}
async.forEachOf(dataPoints, function(val1, category, cb2) {
res[id][category] = {};
async.each(val1, function(element, cb3) {
var file = base + category + '/docker/' + id + '/' + category + '.' + element;
res[id][category][element] = {};
fs.readFile(file, 'utf8', function(err, data) {
if (err) {cb3(err); return}
data.trim().split('\n').forEach(function(v, i) {
var vals = v.split(' ');
switch (vals.length) {
case 1:
res[id][category][element] = vals[0];
break;
case 2:
res[id][category][element][vals[0]] = vals[1];
break;
}
});
cb3();
});
}, function(err) {
cb2();
});
}
}, function(err) {
cb1();
});
}, function(err) {
if (err) return;
broadcast("stats", res);
});
}
console.log("new client");
function emit(signal, data, info) {
@@ -82,7 +97,6 @@ module.exports = function() {
error: error, stderr: stderr, stdout: stdout
});
exec("docker inspect "+stdout.trim().replace(/\n/g, " "), containerinspect);
stats(stdout.trim().split('\n'));
}
function updatecontainers(error, stdout, stderr) {
@@ -228,6 +242,13 @@ module.exports = function() {
.on('bash-input', bash_input)
.on('bash-end', bash_end);
setInterval(function() {
exec("docker ps -q --no-trunc ", function(error, stdout, stderr) {
if (error || stderr) return; // ignore
stats(stdout.trim().split('\n'));
})
},
1000);
}