A Riak client for Rust.
Full documentation available on docs.rs.
When this client was originally written I was working at Basho technologies (we were the the original developers of Riak). Shortly after I started this client the company ended up having significant problems and I ended up leaving the company. I shelved and archived this repository uncertain of Riak's future and otherwise not having a reason to continue developing it. 6 years later it came to my attention that there is some active usage and interest in the continuation of this client, so it was un-archived and made available for forking. Where it goes from here depends on interest: if you're interested in contributing and helping move it forward I'm open to new issues, discussions and PRs. If contributions and interest keeps coming in I will consider quantifying and organizing a v1 release of the client. Otherwise if there's not much engagement in the coming year I'll likely archive it once again.
This client allows you to connect to the Protocol Buffers API of a Riak Node and use the functionality provided to send data, retrieve data, and otherwise communicate with Riak.
This client communicates directly with the Protocol Buffer API on a specified Riak node, and does not provide any abstractions around a cluster of nodes.
-
This client is tested against Rust's stable, beta, and nightly branches. It should work with any modern Rust.
-
Intended to work with Riak KV 2.1.4+
Add riak as a Cargo.toml dependency to your project:
[dependencies]
riak = "*"
Select a specific version.
Storing an object:
use riak::Client;
use riak::object::{ObjectContent, StoreObjectReq};
// connect to Riak and ping the server
let mut riak = Client::new("10.0.0.2:8087").unwrap();
riak.ping().unwrap();
// prepare the object contents
let contents = ObjectContent::new("This is test data!".as_bytes());
// build a request to store the object
let mut store_request = StoreObjectReq::new("testbucket", contents);
store_request.set_key("testkey");
// store the object
riak.store_object(store_request).unwrap();