drpcjs

1.1.1 • Public • Published

drpcjs

Apache storm DRPC client for Node.js

build npm license

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.

Package Sidebar

Install

npm i drpcjs

Weekly Downloads

5

Version

1.1.1

License

MIT

Unpacked Size

236 kB

Total Files

19

Last publish

Collaborators

  • iamnapo