ganglia
v0.0.2 kinesis aws responsive stream bacon baconjs
ganglia
Relay points for reactive applications
- Amazon Kinesis
- Functional Reactive Programming via Bacon.js
- Trie-based routing via routinton
Installation
$ npm install --save ganglia
Routing
var assert = require('assert');
var app = require('ganglia');
app
.define(route, label)
.define('/action/:id', 'customActions')
var stream = app.customActions;
// Let's say we've just published {"foo": "bar"} to a stream named /action/123
stream.onValue(function (data) {
assert(data.label === 'customActions');
assert(data.param.id === '123');
assert(data.value.foo === 'bar')
});