Package org.redisson.transaction

Class TransactionalSet<V>

java.lang.Object

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, List<TransactionalOperation> operations, RSet<V> set, String transactionId)

Method Summary

Modifier and Type	Method	Description
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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TransactionalSet

public TransactionalSet(CommandAsyncExecutor commandExecutor,
                        long timeout,
                        List<TransactionalOperation> operations,
                        RSet<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 class BaseTransactionalSet<V>

readAllAsyncSource

protected RFuture<Set<V>> readAllAsyncSource()

Specified by:

readAllAsyncSource in class BaseTransactionalSet<V>

createAddOperation

protected TransactionalOperation createAddOperation(V value,
                                                    long threadId)

Specified by:

createAddOperation in class BaseTransactionalSet<V>

createMoveOperation

protected MoveOperation createMoveOperation(String destination,
                                            V value,
                                            long threadId)

Specified by:

createMoveOperation in class BaseTransactionalSet<V>

createRemoveOperation

protected TransactionalOperation createRemoveOperation(Object value,
                                                       long threadId)

Specified by:

createRemoveOperation in class BaseTransactionalSet<V>

getLock

protected RLock getLock(RCollectionAsync<V> set,
                        V value)

Specified by:

getLock in class BaseTransactionalSet<V>