pm2-2.x-rpc v0.1.0

pm2-2.x-rpc

Dnode wrapper for pm2 2.x api

Usage:

Use as a dnode stream

var dnode = require('dnode');
var Server = require('pm2-2.x-rpc').Server;

var server = new Server();
var client = dnode();

// pipe the stream through any transport
client.pipe(server).pipe(client);

client.on('remote', function (pm2) {
    // got the pm2 instance
    // use whatever pm2 api method
    pm2.connect(function (err) {
        assert.ok(!err);
    })
})

Server::listen

var server = new Server();
var client = dnode();
var tcpServer = server.listen(5000);

tcpServer.on('listening', function () {
    client.connect(5000);
    client.on('remote', function (remote) {
        client.end();
        tcpServer.close()
    })
})

Server::connect

var local = new Server();
var distServer = dnode().listen(5000);

distServer.on('listening', function () {
    local.connect(5000);
    distServer.on('remote', function (remote) {
        local.end();
        distServer.close();
    })
})