bauer-cluster

bauer-cluster

Multi-process development library.

Installation

npm install bauer-cluster

Usage

var Cluster = require("bauer-cluster").Cluster;

var myCluster = new Cluster();

// executed when in main process
myCluster.master(function() {
  
  this === myCluster // true
  
  this.isMaster; // true
  this.isWorker; // false

  var worker = this.fork("one","two");

  worker.args; // ["one","two"]
  worker.process; // child process produced by fork
  
  worker.on("message",function(message) {
    if (message.pong) {
      worker.send({ ping: true });
    }
  });
  
  worker.send({ ping: true });

});

// executed when in child process
myCluster.worker(function(worker) {

  this === myCluster // true
  
  this.isMaster; // false
  this.isWorker; // true

  worker.args; // ["one","two"]
  worker.process; // global process object
  
  worker.on("message",function(message) {
    if (message.ping) {
      worker.send({ pong: true });
    }
  });

});

myCluster.start();

API Summary

• Cluster

  • new Cluster() :Cluster
  • .getWorkerArgsOffset() :Number
  • .require(name String) :void
  • .master(callback Function) :void
  • .worker(callback Function) :void
  • .start() :void
  • .fork(arg0, arg1, ...) :Worker
  • .removeWorker(worker Worker) :void
  • .createWorker(uuid String, args Array) :Worker
  • .createWorker(uuid String, args Array, process Object) :Worker

• Worker

  • new Worker(cluster Cluster, uuid String, args Array, process Object) :Worker
  • .setupProcess(proc) :void
  • .require(name String) :void
  • .kill(signal Number) :void
  • .die(reason Number|Error) :void
  • .send(message Object) :void
  • .receive(message Object) :void

License

MIT