drpcjs

Apache storm DRPC client for Node.js

Install

$ npm i drpcjs

Usage

const Drpcjs = require("drpcjs");
const drpc = new Drpcjs(options);

options

• host: drpc cluster hostname
• port: drpc client port, default to 3772
• timeout: TCP connection timeout time, default to null
• keepAlive: keep connect alive, default to true
• maxConnectCounts: the maximum connect counts, if the param keepAlive is set true, client will reconnect to storm until the connect counts exceed the maxConnectCounts.

events

• error
• close
• connect
• timeout

methods

execute(topologyName, JSON.stringify(args));

Example

const drpcjs = require('drpcjs');
const drpc = new drpcjs({ host: '127.0.0.1' });
 
drpc.execute('reach', JSON.stringify({ a: 'a', b: 7, c: true }).then(console.log).catch(console.error);

Acknowledgements

Based on node-drpc.