node package manager
Love JavaScript? Your insights can make it even better. Take the 2017 JavaScript Ecosystem Survey »



Stability: 1 - Experimental

NPM version

Peer Server HTTP module for AllData, a distributed master-less write-once immutable event store database implementing "All Data" part of Lambda Architecture.


var AllDataPeerServer = require('alldata-peer-server-http');
var allDataPeerServer = new AllDataPeerServer({
    hostname: 'localhost',
    port: 8080
allDataPeerServer.on('_put', function (key, event, callback) {
    console.log('received request to _put: ' + key + ' ' + event);
    // process the _put 
    callback(); // indicate success 
allDataPeerServer.listen(function () {
    console.log('server listening...'); 


npm test


AllDataPeerServer will listen to HTTP POST requests containing the _put request key and event encoded as a JSON string in the POST body.



Public API

AllDataPeerServer.listen(options, [callback])

  • options: See new AllDataPeerServer(options) options.
  • callback: See allDataPeerServer.listen(callback) callback.
  • Return: Object An instance of AllDataPeerServer with server running.

Creates new AllDataPeerServer and starts the server.

new AllDataPeerServer(options)

  • options: Object
    • hostname: String (Default: undefined) Hostname for the server to listen on. If not specified, the server will accept connections directed to any IPv4 address (INADDR_ANY).
    • port: Integer (Default: 8080) Port number for the server to listen on.

Creates a new AllDataPeerServer instance.


  • callback: Function (Default: undefined) function () {} Optional callback to call once the server is stopped.

Stops the server from accepting new connections.


  • callback: Function (Default: undefined) function () {} Optional callback to call once the server is up.

Starts the server to listen to new connections.

Event _put

  • function (key, event, callback) {}
    • key: String AllData key generated for the event.
    • event: Object JavaScript object representation of the event to _put.
    • callback: Function function (error) {} The callback to call with an error or success of the _put operation.

Emitted when the server receives a new _put request from a peer client.

Signal error via callback(true) and success via callback().

allDataPeerServer.on('_put', function (key, event, callback) {
    console.log('received request to put: ' + key + ' ' + event); 
    // ... process the put