burstable

burstable.js

Power and simplicity on top of Beanstakd

Setup

import Burstable from 'burstable';

const burstable = new Burstable(host, port, {
  // options
});

Spawning jobs

burstable.spawn(tube, {
  payload: {
    // job payload/values
  },
  wait: Job | [Job...] | [{tube: String, id: Number}] // Wait for jobs before handling this job - Logic on consumer side
});

Handling jobs

burstable.handle(tube, function (payload) {
  // Complete job
  return Promise.resolve();
  // Job error
  return Promise.reject();
  // Spawn child job and wait for completion before completing this job
  return this.child(anotherTube);
});