Package | Description |
---|---|
com.basho.riak.client.bucket |
A bucket is a namespace abstraction provided by Riak, the API uses
Bucket as the primary way to interact
with data stored in Riak. |
com.basho.riak.client.builders |
These builders provide a fluid API for creating instances of some immutable
(or mainly immutable classes) that have a large number of
constructor parameters.
|
com.basho.riak.client.cap |
Classes that are relevant in the face of eventually consistent, fault
tolerant databases (like Riak).
|
com.basho.riak.client.operations |
The interfaces/classes that model the set of operations for talking to Riak.
|
com.basho.riak.client.query.indexes |
Modifier and Type | Method and Description |
---|---|
WriteBucket |
WriteBucket.withRetrier(Retrier retrier)
Specify the retrier to use for this operation.
|
FetchBucket |
FetchBucket.withRetrier(Retrier retrier)
Provide a
Retrier to use for the fetch operation. |
Constructor and Description |
---|
DefaultBucket(String name,
BucketProperties properties,
RawClient client,
Retrier retrier)
|
DomainBucket(Bucket bucket,
ConflictResolver<T> resolver,
Converter<T> converter,
MutationProducer<T> mutationProducer,
StoreMeta storeMeta,
FetchMeta fetchMeta,
DeleteMeta deleteMeta,
Class<T> clazz,
Retrier retrier) |
DomainBucket(Bucket bucket,
ConflictResolver<T> resolver,
Converter<T> converter,
MutationProducer<T> mutationProducer,
StoreMeta storeMeta,
FetchMeta fetchMeta,
DeleteMeta deleteMeta,
Class<T> clazz,
Retrier retrier,
boolean withoutFetch)
Create a new
DomainBucket for clazz Class objects
wrapped around bucket
It is recommended to use the DomainBucketBuilder rather than this
constructor. |
FetchBucket(RawClient client,
String bucket,
Retrier retrier)
Create a FetchBucket that delegates to the provided
RawClient . |
LazyBucketProperties(RawClient client,
Retrier retrier,
String bucket) |
WriteBucket(RawClient client,
Bucket bucket,
Retrier retrier)
|
WriteBucket(RawClient client,
String name,
Retrier retrier)
|
Modifier and Type | Method and Description |
---|---|
DomainBucketBuilder<T> |
DomainBucketBuilder.retrier(Retrier retrier)
The
Retrier to use on operations on the built DomainBucket |
Modifier and Type | Class and Description |
---|---|
class |
DefaultRetrier
A basic retrier implementation that attempts *n* times before throwing a
UnresolvedConflictException . |
Modifier and Type | Method and Description |
---|---|
static Retrier |
DefaultRetrier.attempts(int attempts)
Static factory method to create a default retrier
|
Modifier and Type | Method and Description |
---|---|
StoreObject<T> |
StoreObject.withRetrier(Retrier retrier)
The
Retrier to use for the fetch and store operations. |
MultiFetchObject<T> |
MultiFetchObject.withRetrier(Retrier retrier)
A
Retrier to use |
FetchObject<T> |
FetchObject.withRetrier(Retrier retrier)
A
Retrier to use |
DeleteObject |
DeleteObject.withRetrier(Retrier retrier)
Set
Retrier to use when executing this delete operation |
Constructor and Description |
---|
DeleteObject(RawClient client,
String bucket,
String key,
Retrier retrier)
Create a
DeleteOperation that delegates to
client to delete key from bucket
using retrier to handle failures. |
FetchObject(RawClient client,
String bucket,
String key,
Retrier retrier)
Create a new FetchOperation that delegates to the given
client to fetch the data from bucket at
key using retrier |
FetchObject(RawClient client,
String bucket,
String key,
Retrier retrier,
FetchMeta fetchMeta)
Create a new FetchOperation that delegates to the given
client to fetch the data from bucket at
key using retrier |
MultiFetchObject(RawClient client,
String bucket,
List<String> keys,
Retrier retrier)
Create a new MultiFetchOperation that delegates to the given
client to fetch the data from bucket for
keys using retrier |
StoreObject(RawClient client,
String bucket,
String key,
Retrier retrier)
Create a new StoreObject operation for the object in
bucket
at key . |
Constructor and Description |
---|
FetchIndex(RawClient client,
String bucket,
RiakIndex<T> index,
Retrier retrier) |
Copyright © 2014. All Rights Reserved.