Package org.redisson.transaction
Class TransactionalSetCache<V>
-
- 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, <TransactionalOperation> operations, RSetCache<V> set, transactionId)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description >
addAsync(V value, long ttl, ttlUnit)
protected TransactionalOperation
createAddOperation(V value, long threadId)
protected MoveOperation
destination, V value, long threadId)
protected TransactionalOperation
value, long threadId)
protected RLock
getLock(RCollectionAsync<V> set, V value)
protected <V>>
readAllAsyncSource()
protected >
name, RedisClient client, long startPos, 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, <TransactionalOperation> operations, RSetCache<V> set, transactionId)
-
-
Method Detail
-
scanIteratorSource
protected > scanIteratorSource( name, RedisClient client, long startPos, pattern, int count)
- Specified by:
scanIteratorSource
in classBaseTransactionalSet<V>
-
readAllAsyncSource
protected <V>> readAllAsyncSource()
- Specified by:
readAllAsyncSource
in classBaseTransactionalSet<V>
-
addAsync
public > addAsync(V value, long ttl, ttlUnit)
-
createAddOperation
protected TransactionalOperation createAddOperation(V value, long threadId)
- Specified by:
createAddOperation
in classBaseTransactionalSet<V>
-
createMoveOperation
protected destination, V value, long threadId)
- Specified by:
createMoveOperation
in classBaseTransactionalSet<V>
-
createRemoveOperation
protected value, long threadId)
- Specified by:
createRemoveOperation
in classBaseTransactionalSet<V>
-
getLock
protected RLock getLock(RCollectionAsync<V> set, V value)
- Specified by:
getLock
in classBaseTransactionalSet<V>
-
-