rihawk

    0.0.12 • Public • Published

    CURRENTLY IN PROGRESS

    Rihawk 0.0.9

    A streaming riakpbc wrapper with advanced features.

    API

    new Rihawk(options)

    Returns a new instance of the Rihawk client.

    parameters:

    returns: a new instance of the Rihawk client.

    var Rihawk = require('rihawk');
     
    var client = new Rihawk({
      host: '127.0.0.1',
      port: 8087,
      connectTimeout: 1000,
      idleTimeout: 30000,
      maxLifetime: 500000,
      minConnections: 3,
      maxConnections: 12,
      parseValues: true
    });

    client.get(bucket, key, options)

    parameters:

    • bucket: A string, or an array of strings containing the bucket to query.
    • key: A string, or an array of strings containing keys to return values for.
    • options: The options for the RiakPBC request.

    returns: a readable stream emitting data events for each found value.

    get(bucket, key, options)

    var request = client.get('nfl_team', 'CHI')
    .on('data', function(data) {
      console.log('#DATA', data);
    })
    .on('error', function(error) {
      console.log('#ERROR', error);
    }).on('end', function() {
      console.log('#END');
    });

    get(bucket, [key], options)

    var request = client.get('nfl_team', ['CHI', 'MIA', 'SD'])
    .on('data', function(data) {
      console.log('#DATA', data);
    })
    .on('error', function(error) {
      console.log('#ERROR', error);
    }).on('end', function() {
      console.log('#END');
    });

    get([bucket], [key], options)

    var request = client.get(['nfl_team', 'baseball_team'], ['CHI', 'MIA', 'SD'])
    .on('data', function(data) {
      console.log('#DATA', data);
    })
    .on('error', function(error) {
      console.log('#ERROR', error);
    }).on('end', function() {
      console.log('#END');
    });

    Keywords

    none

    Install

    npm i rihawk

    DownloadsWeekly Downloads

    2

    Version

    0.0.12

    License

    none

    Last publish

    Collaborators

    • defstream