Skip to content
🍬 Apache storm DRPC client for Node.js.
JavaScript
Branch: master
Clone or download
Fetching latest commit…
Cannot retrieve the latest commit at this time.
Permalink
Type Name Latest commit message Commit time
Failed to load latest commit information.
.github/workflows
src
.editorconfig
.eslintignore
.eslintrc
.gitattributes
.gitignore
.markdownlint.json
.ncurc.json
.npmrc
LICENSE
README.md
index.js
package.json

README.md

drpcjs

Apache storm DRPC client for Node.js

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);

License

MIT © Napoleon-Christos Oikonomou


Acknowledgements

Based on node-drpc.

You can’t perform that action at this time.