drpcjs

Apache storm DRPC client for Node.js

Usage no npm install needed!

<script type="module">
  import drpcjs from 'https://cdn.skypack.dev/drpcjs';
</script>

README

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.