Riak Streaming
Basic riak client that is fully streaming
Installation
# not yet published to npm, install from github for now # npm install -S riak-streaming-node
Usage
var Client = var opts = host: 'localhost' protocol: 'http' port: '8098' var client = opts // stream keys from a bucket (returns a stream)var keyStream = clientkeyStream // stream all bucket names (returns a stream)var bucketStream = clientbucketStream // get value for key (returns a promise)var opts = bucket: 'test_bucket' key: 'test_key'var promise = clientpromise // save value for key (returns a promise)var opts = bucket: 'test_bucket' key: 'test_key' value: 'test_value_here'var promise = clientpromise // deletefor key (returns a promise)var opts = bucket: 'test_bucket' key: 'test_key'var promise = clientpromise
Test
Make sure you have riak running on the default port before running the test suite.
npm installmake test # or npm test