Nemcio/NodeBB
1
0
Fork 0
mirror of https://github.com/NodeBB/NodeBB.git synced 2025-11-17 11:11:04 +01:00
Code Issues Packages Projects Releases Wiki Activity

display both redis/mongo info if available

Browse Source
This commit is contained in:
barisusakli
2015-05-08 15:36:06 -04:00
parent 0083d4ff1c
commit 7b550b13b9
6 changed files with 96 additions and 54 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
src/database/mongo.js
View File

@@ -158,6 +158,24 @@
});
};
module.info = function(db, callback) {
db.stats({scale:1024}, function(err, stats) {
if(err) {
return callback(err);
}
stats.avgObjSize = (stats.avgObjSize / 1024).toFixed(2);
stats.dataSize = (stats.dataSize / 1024).toFixed(2);
stats.storageSize = (stats.storageSize / 1024).toFixed(2);
stats.fileSize = (stats.fileSize / 1024).toFixed(2);
stats.indexSize = (stats.indexSize / 1024).toFixed(2);
stats.raw = JSON.stringify(stats, null, 4);
stats.mongo = true;
callback(null, stats);
});
};
module.close = function() {
db.close();
};

18
src/database/mongo/main.js
View File

@@ -79,24 +79,6 @@ module.exports = function(db, module) {
db.dropDatabase(callback);
};
module.info = function(callback) {
db.stats({scale:1024}, function(err, stats) {
if(err) {
return callback(err);
}
stats.avgObjSize = (stats.avgObjSize / 1024).toFixed(2);
stats.dataSize = (stats.dataSize / 1024).toFixed(2);
stats.storageSize = (stats.storageSize / 1024).toFixed(2);
stats.fileSize = (stats.fileSize / 1024).toFixed(2);
stats.indexSize = (stats.indexSize / 1024).toFixed(2);
stats.raw = JSON.stringify(stats, null, 4);
stats.mongo = true;
callback(null, stats);
});
};
module.exists = function(key, callback) {
if (!key) {
return callback();

22
src/database/redis.js
View File

@@ -115,6 +115,28 @@
redisClient.quit();
};
module.info = function(cxn, callback) {
cxn.info(function (err, data) {
if (err) {
return callback(err);
}
var lines = data.toString().split("\r\n").sort();
var redisData = {};
lines.forEach(function (line) {
var parts = line.split(':');
if (parts[1]) {
redisData[parts[0]] = parts[1];
}
});
redisData.raw = JSON.stringify(redisData, null, 4);
redisData.redis = true;
callback(null, redisData);
});
};
module.helpers = module.helpers || {};
module.helpers.redis = require('./redis/helpers');
}(exports));

20
src/database/redis/main.js
View File

@@ -35,27 +35,7 @@ module.exports = function(redisClient, module) {
});
};
module.info = function(callback) {
redisClient.info(function (err, data) {
if(err) {
return callback(err);
}
var lines = data.toString().split("\r\n").sort();
var redisData = {};
lines.forEach(function (line) {
var parts = line.split(':');
if (parts[1]) {
redisData[parts[0]] = parts[1];
}
});
redisData.raw = JSON.stringify(redisData, null, 4);
redisData.redis = true;
callback(null, redisData);
});
};
module.exists = function(key, callback) {
redisClient.exists(key, function(err, exists) {