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.

    Install

    npm i drpcjs

    DownloadsWeekly Downloads

    5

    Version

    1.1.1

    License

    MIT

    Unpacked Size

    236 kB

    Total Files

    19

    Last publish

    Collaborators

    • iamnapo