org.springframework.data.keyvalue.riak.core
Interface AsyncBucketKeyValueStoreOperations

All Known Implementing Classes:

AsyncRiakTemplate

public interface AsyncBucketKeyValueStoreOperations

An asynchronous version of BucketKeyValueStoreOperations.

Author:

J. Brisbin

Method Summary

<B,K,R> Future<?>	containsKey(B bucket, K key, AsyncKeyValueStoreOperation<Boolean,R> callback)
<B,K,R> Future<?>	delete(B bucket, K key, AsyncKeyValueStoreOperation<Boolean,R> callback) Delete a specific entry from this data store.
<B,K,V,R> Future<?>	get(B bucket, K key, AsyncKeyValueStoreOperation<V,R> callback)
<B,K,V,R> Future<?>	getAndSet(B bucket, K key, V value, AsyncKeyValueStoreOperation<V,R> callback)
<B,K,R> Future<?>	getAndSetAsBytes(B bucket, K key, byte[] value, AsyncKeyValueStoreOperation<byte[],R> callback)
<B,K,V,T,R> Future<?>	getAndSetAsType(B bucket, K key, V value, Class<T> requiredType, AsyncKeyValueStoreOperation<T,R> callback)
<B,K,R> Future<?>	getAsBytes(B bucket, K key, AsyncKeyValueStoreOperation<byte[],R> callback)
<B,K,T,R> Future<?>	getAsType(B bucket, K key, Class<T> requiredType, AsyncKeyValueStoreOperation<T,R> callback)
<B,K,V,R> Future<?>	set(B bucket, K key, V value, AsyncKeyValueStoreOperation<V,R> callback) Put an object in Riak at a specific bucket and key and invoke callback with the value pulled back out of Riak after the update, which contains full headers and metadata.
<B,K,V,R> Future<?>	set(B bucket, K key, V value, QosParameters qosParams, AsyncKeyValueStoreOperation<V,R> callback)
<B,K,R> Future<?>	setAsBytes(B bucket, K key, byte[] value, AsyncKeyValueStoreOperation<byte[],R> callback)
<B,K,R> Future<?>	setAsBytes(B bucket, K key, byte[] value, QosParameters qosParams, AsyncKeyValueStoreOperation<byte[],R> callback)
<B,K,V,R> Future<?>	setIfKeyNonExistent(B bucket, K key, V value, AsyncKeyValueStoreOperation<V,R> callback)
<B,K,R> Future<?>	setIfKeyNonExistentAsBytes(B bucket, K key, byte[] value, AsyncKeyValueStoreOperation<byte[],R> callback)
<B,K,V,R> Future<?>	setWithMetaData(B bucket, K key, V value, Map<String,String> metaData, AsyncKeyValueStoreOperation<V,R> callback)
<B,K,V,R> Future<?>	setWithMetaData(B bucket, K key, V value, Map<String,String> metaData, QosParameters qosParams, AsyncKeyValueStoreOperation<V,R> callback)

Method Detail

set

<B,K,V,R> Future<?> set(B bucket,
                        K key,
                        V value,
                        AsyncKeyValueStoreOperation<V,R> callback)

Put an object in Riak at a specific bucket and key and invoke callback with the value pulled back out of Riak after the update, which contains full headers and metadata.

Parameters:

bucket -

key -

value -

callback - Called with the update value pulled from Riak

set

<B,K,V,R> Future<?> set(B bucket,
                        K key,
                        V value,
                        QosParameters qosParams,
                        AsyncKeyValueStoreOperation<V,R> callback)

Parameters:

bucket -

key -

value -

qosParams -

Returns:

setAsBytes

<B,K,R> Future<?> setAsBytes(B bucket,
                             K key,
                             byte[] value,
                             AsyncKeyValueStoreOperation<byte[],R> callback)

Parameters:

bucket -

key -

value -

Returns:

setAsBytes

<B,K,R> Future<?> setAsBytes(B bucket,
                             K key,
                             byte[] value,
                             QosParameters qosParams,
                             AsyncKeyValueStoreOperation<byte[],R> callback)

Parameters:

bucket -

key -

value -

qosParams -

Returns:

setWithMetaData

<B,K,V,R> Future<?> setWithMetaData(B bucket,
                                    K key,
                                    V value,
                                    Map<String,String> metaData,
                                    AsyncKeyValueStoreOperation<V,R> callback)

Parameters:

bucket -

key -

value -

metaData -

Returns:

setWithMetaData

<B,K,V,R> Future<?> setWithMetaData(B bucket,
                                    K key,
                                    V value,
                                    Map<String,String> metaData,
                                    QosParameters qosParams,
                                    AsyncKeyValueStoreOperation<V,R> callback)

Parameters:

bucket -

key -

value -

metaData -

qosParams -

Returns:

get

<B,K,V,R> Future<?> get(B bucket,
                        K key,
                        AsyncKeyValueStoreOperation<V,R> callback)

Parameters:

bucket -

key -

Returns:

getAsBytes

<B,K,R> Future<?> getAsBytes(B bucket,
                             K key,
                             AsyncKeyValueStoreOperation<byte[],R> callback)

Parameters:

bucket -

key -

Returns:

getAsType

<B,K,T,R> Future<?> getAsType(B bucket,
                              K key,
                              Class<T> requiredType,
                              AsyncKeyValueStoreOperation<T,R> callback)

Parameters:

bucket -

key -

requiredType -

Returns:

getAndSet

<B,K,V,R> Future<?> getAndSet(B bucket,
                              K key,
                              V value,
                              AsyncKeyValueStoreOperation<V,R> callback)

Parameters:

bucket -

key -

value -

Returns:

getAndSetAsBytes

<B,K,R> Future<?> getAndSetAsBytes(B bucket,
                                   K key,
                                   byte[] value,
                                   AsyncKeyValueStoreOperation<byte[],R> callback)

Parameters:

bucket -

key -

value -

Returns:

getAndSetAsType

<B,K,V,T,R> Future<?> getAndSetAsType(B bucket,
                                      K key,
                                      V value,
                                      Class<T> requiredType,
                                      AsyncKeyValueStoreOperation<T,R> callback)

Parameters:

bucket -

key -

value -

requiredType -

Returns:

setIfKeyNonExistent

<B,K,V,R> Future<?> setIfKeyNonExistent(B bucket,
                                        K key,
                                        V value,
                                        AsyncKeyValueStoreOperation<V,R> callback)

Parameters:

bucket -

key -

value -

Returns:

setIfKeyNonExistentAsBytes

<B,K,R> Future<?> setIfKeyNonExistentAsBytes(B bucket,
                                             K key,
                                             byte[] value,
                                             AsyncKeyValueStoreOperation<byte[],R> callback)

Parameters:

bucket -

key -

value -

Returns:

containsKey

<B,K,R> Future<?> containsKey(B bucket,
                              K key,
                              AsyncKeyValueStoreOperation<Boolean,R> callback)

Parameters:

bucket -

key -

Returns:

delete

<B,K,R> Future<?> delete(B bucket,
                         K key,
                         AsyncKeyValueStoreOperation<Boolean,R> callback)

Delete a specific entry from this data store.

Parameters:

bucket -

key -

Returns: