bauer-cluster-queue

Plugin for bauer-cluster to add request queue feature.

Usage no npm install needed!

<script type="module">
  import bauerClusterQueue from 'https://cdn.skypack.dev/bauer-cluster-queue';
</script>

README

bauer-cluster

Plugin for bauer-cluster to add request/response queue functionality.

Installation

npm install bauer-cluster-queue

Usage

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

var myCluster = new Cluster();

myCluster.require("bauer-cluster-queue");

myCluster.master(function() {
  
  var worker = this.fork("one","two");

  var request = worker.request({ ping: true });
  
  request.on("response",function(response) {
    
  });

});

myCluster.worker(function(worker) {

  worker.on("request",function(request,response) {
    if (request.ping) {
      response.send({ pong: true });
    }
  });

});

myCluster.start();

API Summary

  • Worker

    • .setupQueue() :void
    • .flush() :void
    • .queue(message Object) :void
    • .request() :Request
    • .request(data Object) :Request
    • .request(data Object, callback Function) :Request

  • Request

    • new Request(worker Worker) :Request
    • .send() :void
    • .send(data Object) :void

  • Response

    • new Response(worker Worker, id String) :Response
    • .send() :void
    • .send(data Object) :void

License

MIT