Package org.redisson.transaction
Class TransactionalSet<V>
-
- org.redisson.transaction.BaseTransactionalObject
-
- org.redisson.transaction.BaseTransactionalSet<V>
-
- org.redisson.transaction.TransactionalSet<V>
-
- Type Parameters:
V
- value type
public class TransactionalSet<V> extends BaseTransactionalSet<V>
- Author:
- Nikita Koksharov
-
-
Constructor Summary
Constructors Constructor Description TransactionalSet(CommandAsyncExecutor commandExecutor, long timeout, <TransactionalOperation> operations, RSet<V> set, transactionId)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description 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
-
TransactionalSet
public TransactionalSet(CommandAsyncExecutor commandExecutor, long timeout, <TransactionalOperation> operations, RSet<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>
-
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>
-
-