workstack

Summary

A massively scalable work queue implemented in Node.js (currently in alpha state)

Example Usage

$3

``
npm install workstack
`

$3

`
const { Router } = require("workstack");

var router = new Router({});
router.start();
`

$3


`
const { Worker } = require("workstack");

async function work(data)
{
console.log(${new Date()}: working.);
console.log("Data received: ", data);
console.log(${new Date()}: done.);

return (new Date()).toString();

}

( async()=>
{
var worker = new Worker(
{ pingInterval: 5000,
queue: "test-queue",
work: ()=>{console.log("doing work")}
});
worker.start();

}
)()
`

$3


`
const { Producer } = require("workstack");

var producer = new Producer({});
producer.enqueue(
{ queue: "test-queue",
command: "execWork",
data: {vals: ["1", "2"]}
});
`

$3


`
const { Producer } = require("workstack");

var producer = new Producer({});

(
async()=>
{
var output = await producer.enqueue(
{ queue: "test-queue",
command: "execWork",
data: {vals: ["1", "2"]}
}, true);

console.log(JSON.stringify(output));

}

)()
`

$3

Currently shared key authentication is available. To enable this, start the tiers (Router, Worker and Producer) with the following additional parameters:

#### Router
`
var router = new Router({authMethod: "sharedKey", authKey: "aequooLohkoa3ar2phee4sheeToxo6"});
`

#### Worker
`
var worker = new Worker(
{ authKey: "aequooLohkoa3ar2phee4sheeToxo6",
pingInterval: 30000, queue: "test-queue",
work: ()=>{console.log("doing work")}
});
`

#### Producer
`
var producer = new Producer({authKey: "aequooLohkoa3ar2phee4sheeToxo6"});
`

$3


Messages can be encrypted by setting the following parameter during initialization of each component (router, producer, worker):
`
encrypt: true
`
For example, to enable encryption for the router:
`
var router = new Router({encrypt: true});
``
If encryption is enabled on one of the components, it must then be enabled on all of the components (router, producer, worker).