Riak Protocol Buffer Stream
A Riak Protocol Buffer stream for Node.JS.
var RiakSocket = ;var socket = ; socket; socket;
Install
npm install riakjs2-protobuf
Writing to the socket
The socket accepts a data object and a message type:
// send ping requestsocket; // send get requestsocket;
Reading from the socket
The socket emits response data:
// process responsesocket;
Implementation notes
These message types have not yet been tested and the socket will return data from Riak as-is:
27,RpbSearchQueryReq,riak_search28,RpbSearchQueryResp,riak_search29,RpbResetBucketReq,riak30,RpbResetBucketResp,riak31,RpbGetBucketTypeReq,riak32,RpbSetBucketTypeReq,riak40,RpbCSBucketReq,riak_kv41,RpbCSBucketResp,riak_kv54,RpbYokozunaIndexGetReq,riak_yokozuna55,RpbYokozunaIndexGetResp,riak_yokozuna56,RpbYokozunaIndexPutReq,riak_yokozuna57,RpbYokozunaIndexDeleteReq,riak_yokozuna58,RpbYokozunaSchemaGetReq,riak_yokozuna59,RpbYokozunaSchemaGetResp,riak_yokozuna60,RpbYokozunaSchemaPutReq,riak_yokozuna253,RpbAuthReq,riak254,RpbAuthResp,riak255,RpbStartTls,riak
License
MIT