Spring Data Key-Value

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

All Known Implementing Classes:
AsyncRiakTemplate

public interface AsyncBucketKeyValueStoreOperations

An asynchronous version of BucketKeyValueStoreOperations.

Author:
J. Brisbin <[email protected]>

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:

Spring Data Key-Value

Copyright © 2010-2011 SpringSource. All Rights Reserved.