hubiquitus-core/lib/monitoring.js

/**
 * @module monitoring api
 */

var EventEmitter = require('events').EventEmitter;
var _ = require('lodash');

var application = require('./application');
var properties = require('./properties');
var logger = require('./logger')('hubiquitus:core:monitoring');
var actors = require('./actors');
var discovery = require('./discovery');
var adapters = {
  inproc: require('./adapters/inproc'),
  remote: require('./adapters/remote')
};

exports.__proto__ = new EventEmitter();
exports.setMaxListeners(0);

/*
 * Listeners setup
 */

actors.on('actor added', function (aid, scope) {
  exports.emit('actor added', aid, scope);
});

actors.on('actor removed', function (aid, scope) {
  exports.emit('actor removed', aid, scope);
});

discovery.on('discovery started', function (aid) {
  exports.emit('discovery started', aid);
});

discovery.on('discovery stopped', function (aid) {
  exports.emit('discovery stopped', aid);
});

discovery.on('discovery', function (aid) {
  exports.emit('discovery', aid);
});

_.forEach(adapters, function (adapter) {
  adapter.on('req sent', function (req) {
    exports.emit('req sent', req);
  });

  adapter.on('req received', function (req) {
    exports.emit('req received', req);
  });

  adapter.on('res sent', function (res) {
    exports.emit('res sent', res);
  });

  adapter.on('res received', function (res) {
    exports.emit('res received', res);
  });
});

/**
 * Returns actors in the given scope
 * @param {string} [scope]
 * @returns {Array} actors
 */
exports.actors = function (scope) {
  return actors.all(scope);
};

/**
 * Returns current discoveries with the last research date for each of them
 * @returns {Object} discoveries
 */
exports.discoveries = function () {
  return discovery.discoveries();
};

/*
 * Ping management
 */

application.addActor(properties.ID + '_ping', function (req) {
  logger.makeLog('trace', 'hub-51', 'ping', {req: req});
  req.reply();
});

/**
 *
 * @param cid {String} target container id
 * @param cb {Function} callback
 */
exports.pingContainer = function (cid, cb) {
  application.send(properties.ID, cid + '_ping', 'PING', properties.containerPingTimeout, function (err) {
    cb(err);
  });
};