Package org.redisson.transaction
Class TransactionalSetCache<V>
- java.lang.Object
-
- org.redisson.transaction.BaseTransactionalObject
-
- org.redisson.transaction.BaseTransactionalSet<V>
-
- org.redisson.transaction.TransactionalSetCache<V>
-
- Type Parameters:
V
- value type
public class TransactionalSetCache<V> extends BaseTransactionalSet<V>
- Author:
- Nikita Koksharov
-
-
Constructor Summary
Constructors Constructor Description TransactionalSetCache(CommandAsyncExecutor commandExecutor, long timeout, List<TransactionalOperation> operations, RSetCache<V> set, String transactionId)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description RFuture<Boolean>
addAsync(V value, long ttl, TimeUnit ttlUnit)
protected TransactionalOperation
createAddOperation(V value, long threadId)
protected MoveOperation
createMoveOperation(String destination, V value, long threadId)
protected TransactionalOperation
createRemoveOperation(Object value, long threadId)
protected RLock
getLock(RCollectionAsync<V> set, V value)
protected RFuture<Set<V>>
readAllAsyncSource()
protected ScanResult<Object>
scanIteratorSource(String name, RedisClient client, long startPos, String pattern, int count)
-
Methods inherited from class org.redisson.transaction.BaseTransactionalSet
addAllAsync, addAsync, addAsync, containsAllAsync, containsAsync, deleteAsync, deleteAsync, diffAsync, executeLocked, executeLocked, executeLocked, intersectionAsync, isExistsAsync, moveAsync, readAllAsync, readDiffAsync, readIntersectionAsync, readSortAlphaAsync, readSortAlphaAsync, readSortAlphaAsync, readSortAlphaAsync, readSortAlphaAsync, readSortAlphaAsync, readSortAsync, readSortAsync, readSortAsync, readSortAsync, readUnionAsync, removeAllAsync, removeAsync, removeRandomAsync, removeRandomAsync, retainAllAsync, scanIterator, sortToAsync, touchAsync, unionAsync, unlinkAsync
-
Methods inherited from class org.redisson.transaction.BaseTransactionalObject
clearExpireAsync, expireAsync, expireAtAsync, expireAtAsync, expireAtAsync, migrateAsync, moveAsync
-
-
-
-
Constructor Detail
-
TransactionalSetCache
public TransactionalSetCache(CommandAsyncExecutor commandExecutor, long timeout, List<TransactionalOperation> operations, RSetCache<V> set, String transactionId)
-
-
Method Detail
-
scanIteratorSource
protected ScanResult<Object> scanIteratorSource(String name, RedisClient client, long startPos, String pattern, int count)
- Specified by:
scanIteratorSource
in classBaseTransactionalSet<V>
-
readAllAsyncSource
protected RFuture<Set<V>> readAllAsyncSource()
- Specified by:
readAllAsyncSource
in classBaseTransactionalSet<V>
-
createAddOperation
protected TransactionalOperation createAddOperation(V value, long threadId)
- Specified by:
createAddOperation
in classBaseTransactionalSet<V>
-
createMoveOperation
protected MoveOperation createMoveOperation(String destination, V value, long threadId)
- Specified by:
createMoveOperation
in classBaseTransactionalSet<V>
-
createRemoveOperation
protected TransactionalOperation createRemoveOperation(Object value, long threadId)
- Specified by:
createRemoveOperation
in classBaseTransactionalSet<V>
-
getLock
protected RLock getLock(RCollectionAsync<V> set, V value)
- Specified by:
getLock
in classBaseTransactionalSet<V>
-
-