Package org.redisson.transaction
Class BaseTransactionalMap<K,V>
- java.lang.Object
-
- org.redisson.transaction.BaseTransactionalMap<K,V>
-
- Type Parameters:
K
- key typeV
- value type
- Direct Known Subclasses:
BaseTransactionalMapCache
public class BaseTransactionalMap<K,V> extends Object
- Author:
- Nikita Koksharov
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
BaseTransactionalMap.MapEntry
-
Constructor Summary
Constructors Constructor Description BaseTransactionalMap(CommandAsyncExecutor commandExecutor, long timeout, List<TransactionalOperation> operations, RMap<K,V> map, String transactionId)
-
Method Summary
-
-
-
Constructor Detail
-
BaseTransactionalMap
public BaseTransactionalMap(CommandAsyncExecutor commandExecutor, long timeout, List<TransactionalOperation> operations, RMap<K,V> map, String transactionId)
-
-
Method Detail
-
unlinkAsync
public RFuture<Boolean> unlinkAsync(CommandAsyncExecutor commandExecutor)
-
touchAsync
public RFuture<Boolean> touchAsync(CommandAsyncExecutor commandExecutor)
-
deleteAsync
public RFuture<Boolean> deleteAsync(CommandAsyncExecutor commandExecutor)
-
deleteAsync
protected RFuture<Boolean> deleteAsync(CommandAsyncExecutor commandExecutor, TransactionalOperation operation)
-
scanIterator
protected ScanResult<Map.Entry<Object,Object>> scanIterator(String name, RedisClient client, long startPos, String pattern, int count)
-
putIfExistsOperationAsync
protected RFuture<V> putIfExistsOperationAsync(K key, V value, MapOperation mapOperation)
-
putIfAbsentOperationAsync
protected RFuture<V> putIfAbsentOperationAsync(K key, V value, MapOperation mapOperation)
-
putOperationAsync
protected RFuture<V> putOperationAsync(K key, V value, MapOperation operation)
-
fastPutIfExistsOperationAsync
protected RFuture<Boolean> fastPutIfExistsOperationAsync(K key, V value)
-
fastPutIfExistsOperationAsync
protected RFuture<Boolean> fastPutIfExistsOperationAsync(K key, V value, MapOperation mapOperation)
-
fastPutIfAbsentOperationAsync
protected RFuture<Boolean> fastPutIfAbsentOperationAsync(K key, V value)
-
fastPutIfAbsentOperationAsync
protected RFuture<Boolean> fastPutIfAbsentOperationAsync(K key, V value, MapOperation mapOperation)
-
fastPutOperationAsync
protected RFuture<Boolean> fastPutOperationAsync(K key, V value, MapOperation operation)
-
readAllValuesAsync
public RFuture<Collection<V>> readAllValuesAsync()
-
putAllOperationAsync
protected RFuture<Void> putAllOperationAsync(Map<? extends K,? extends V> entries)
-
replaceOperationAsync
protected RFuture<Boolean> replaceOperationAsync(K key, V oldValue, V newValue)
-
executeLocked
protected <R> void executeLocked(RPromise<R> promise, Runnable runnable, Collection<K> keys)
-
-