What is this?

An easy to use, non-blocking Scala client library for interacting with Riak.

See the project site for full documentation, examples, scaladocs, and more.

Current Status

The latest version is 0.8.1.1, which is compatible with Akka 2.1.4 and Spray 1.1-M8.

There is also a parallel release for people who have already moved to Akka 2.2. Version 0.8.1.2 is compatible with Akka 2.2-RC1 and Spray 1.2-M8. Please be aware that this version is not compatible with Akka 2.2-RC2 because that version is not backwards compatible with RC1 and therefor not compatible with Spray 1.2-M8.

Features

So far, the following Riak (http) API features are supported:

• Fetch
• Store
• Delete
• Secondary Indexes (2i)
  • Fetching exact matches
  • Fetching ranges
  • Storing with indexes
• Getting/setting bucket properties
• ping

Other features include:

• Completely non-blocking thanks to Scala 2.10 Futures, Akka, and Spray
• Transparent integration with Akka projects through an Akka extension
• An untyped RiakValue class for interacting with raw Riak values and their associated meta data (vclock, etag, content type, last modified time, indexes, etc.)
• A typed RiakMeta[T] class for interacting with deserialized values while retaining their associated meta data (vclock, etag, content type, last modified time, indexes, etc.)
• Customizable and strongly typed conflict resolution on all fetches (and stores when returnbody=true)
• Automatic (de)serialization of Scala (case) classes using type classes
  • builtin spray-json (de)serializers
• Automatic indexing of Scala (case) classes using type classes
• Auto-retry of fetches and stores (a standard feature of the underlying spray-client library)

The following Riak (http) API features are still under construction:

• Link walking
• Map Reduce
• Listing all keys in a bucket
• Listing all buckets
• Conditional fetch/store semantics (i.e. If-None-Match and If-Match for ETags and If-Modified-Since and If-Unmodified-Since for LastModified)
• Node Status

The initial focus is on supporting the Riak HTTP API. Protobuf support might be added later but it has a low priority at the moment.

The riak-scala-client has been tested against Riak versions 1.2.x and 1.3.x.

Current Limitations

• 2i fetches do not use streaming when processing the initial Riak response containing all matching keys. This means that this list of keys matching the specified index is currently read into memory in its entirety. Fetches with large (100k+) result sets can be slow because of this and might potentially cause memory problems. A future release will solve this by streaming the data using Play iteratees.
• 2i index names and index values containing some special characters will not be handled correctly. This is due to the way these have to be encoded for transmission over HTTP. And earlier version did manual double URL encoding/decoding but that was not a sustainable solution. Please avoid using characters like ' ', ',', '?', '&', etc. in index names and index values for now.

Why such a boring name?

It seems all the cool and appropriate names, like riaktive, riakka, riaktor, scalariak, etc. have already been taken by other projects. But there seems to be a common riak-xxx-client naming pattern used by Riak client libraries for other languages so that's what ended up deciding the, admittedly boring, name.

If you come up with a cooler name, please let us know and eternal fame will be yours!

License

The riak-scala-client is licensed under APL 2.0.