Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- //Trait RiakClient
- def bucket(name: String, resolver: RiakConflictsResolver = DefaultConflictsResolver)(implicit riakBucket: RiakBucketType): RiakBucket
- //class RiakHttpClient(helper: RiakHttpClientHelper, server: RiakServerInfo) extends RiakClient
- def bucket(name: String, resolver: RiakConflictsResolver)(implicit riakBucket: RiakBucketType = new RiakHttpBucketType(helper, server, "default")) = new RiakHttpBucket(helper, server, name, resolver, riakBucket)
- //class RiakHttpBucket
- class RiakHttpBucket(helper: RiakHttpClientHelper, server: RiakServerInfo, val name: String, val resolver: RiakConflictsResolver, bucketType:RiakBucketType) extends RiakBucket
- val connection = RiakClient(system)
- val bucket = connection.bucket("test-basic-interaction")
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement