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

Dependents (1)

Package Sidebar

Install

npm i rihawk

Weekly Downloads

1

Version

0.0.12

License

none

Last publish

Collaborators

  • defstream