Advertisement
Guest User

Untitled

a guest
Aug 15th, 2014
211
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Scala 0.76 KB | None | 0 0
  1. //Trait RiakClient
  2. def bucket(name: String, resolver: RiakConflictsResolver = DefaultConflictsResolver)(implicit riakBucket: RiakBucketType): RiakBucket
  3.  
  4. //class RiakHttpClient(helper: RiakHttpClientHelper, server: RiakServerInfo) extends RiakClient
  5. def bucket(name: String, resolver: RiakConflictsResolver)(implicit riakBucket: RiakBucketType = new RiakHttpBucketType(helper, server, "default")) = new RiakHttpBucket(helper, server, name, resolver, riakBucket)
  6.  
  7. //class RiakHttpBucket
  8. class RiakHttpBucket(helper: RiakHttpClientHelper, server: RiakServerInfo, val name: String, val resolver: RiakConflictsResolver, bucketType:RiakBucketType) extends RiakBucket
  9.  
  10.  
  11.       val connection = RiakClient(system)
  12.       val bucket = connection.bucket("test-basic-interaction")
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement