monitor plugin: first version
This commit is contained in:
parent
3a057d5017
commit
a01f70521b
@ -1,4 +1,3 @@
|
||||
module.exports = {
|
||||
|
||||
|
||||
cronTime: '* * * * *', // run each minute
|
||||
};
|
||||
|
||||
@ -2,8 +2,25 @@ var mdb = require('../lib/MessageDb').default();
|
||||
var logger = require('../lib/logger').logger;
|
||||
var preconditions = require('preconditions').singleton();
|
||||
var microtime = require('microtime');
|
||||
var cron = require('cron');
|
||||
var CronJob = cron.CronJob;
|
||||
|
||||
|
||||
module.exports.init = function(config) {
|
||||
logger.info('Using monitor plugin');
|
||||
var cronTime = config.cronTime || '0 * * * *';
|
||||
logger.info('Using monitor plugin with cronTime ' + cronTime);
|
||||
var onTick = function() {
|
||||
mdb.getAll(function(err, messages) {
|
||||
if (err) logger.error(err);
|
||||
else {
|
||||
logger.info('Message db size = ' + messages.length);
|
||||
}
|
||||
});
|
||||
};
|
||||
var job = new CronJob({
|
||||
cronTime: cronTime,
|
||||
onTick: onTick
|
||||
});
|
||||
onTick();
|
||||
job.start();
|
||||
};
|
||||
|
||||
Loading…
Reference in New Issue
Block a user