Package org.redisson.transaction

Class BaseTransactionalSet<V>

org.redisson.transaction.BaseTransactionalObject

org.redisson.transaction.BaseTransactionalSet<V>

Type Parameters:

V - value type

Direct Known Subclasses:

TransactionalSet, TransactionalSetCache

public abstract class BaseTransactionalSet<V>
extends BaseTransactionalObject

Author:

Nikita Koksharov

Constructor Summary

Constructors

Constructor	Description
BaseTransactionalSet(CommandAsyncExecutor commandExecutor, long timeout, <TransactionalOperation> operations, RCollectionAsync<V> set)

Method Summary

Modifier and Type	Method	Description
>	<? extends V> c)
>	addAsync(V value)
>	addAsync(V value, TransactionalOperation operation)
>	<?> c)
>	value)
protected abstract TransactionalOperation	createAddOperation(V value, long threadId)
protected abstract MoveOperation	destination, V value, long threadId)
protected abstract TransactionalOperation	value, long threadId)
>	deleteAsync(CommandAsyncExecutor commandExecutor)
protected >	deleteAsync(CommandAsyncExecutor commandExecutor, TransactionalOperation operation)
>	... names)
protected <R> void	executeLocked(RPromise<R> promise, value, runnable)
protected <R> void	executeLocked(RPromise<R> promise, runnable, <?> values)
protected <R> void	executeLocked(RPromise<R> promise, runnable, RLock lock)
protected abstract RLock	getLock(RCollectionAsync<V> set, V value)
>	... names)
>	isExistsAsync()
>	destination, V value)
<V>>	readAllAsync()
protected abstract <V>>	readAllAsyncSource()
<V>>	... names)
<V>>	... names)
<T> <T>>	byPattern, <> getPatterns, SortOrder order)
<T> <T>>	byPattern, <> getPatterns, SortOrder order, int offset, int count)
<V>>	byPattern, SortOrder order)
<V>>	byPattern, SortOrder order, int offset, int count)
<V>>	readSortAlphaAsync(SortOrder order)
<V>>	readSortAlphaAsync(SortOrder order, int offset, int count)
<T> <T>>	byPattern, <> getPatterns, SortOrder order, int offset, int count)
<V>>	byPattern, SortOrder order)
<V>>	readSortAsync(SortOrder order)
<V>>	readSortAsync(SortOrder order, int offset, int count)
<V>>	... names)
>	<?> c)
>	value)
RFuture<V>	removeRandomAsync()
<V>>	removeRandomAsync(int amount)
>	<?> c)
protected >	name, RedisClient client, long startPos, pattern, int count)
protected abstract >	name, RedisClient client, long startPos, pattern, int count)
>	destName, byPattern, <> getPatterns, SortOrder order, int offset, int count)
>	touchAsync(CommandAsyncExecutor commandExecutor)
>	... names)
>	unlinkAsync(CommandAsyncExecutor commandExecutor)

Methods inherited from class org.redisson.transaction.BaseTransactionalObject

clearExpireAsync, expireAsync, expireAtAsync, expireAtAsync, expireAtAsync, migrateAsync, moveAsync

Methods inherited from class java.lang.

, , , , , , , , , ,

Constructor Detail

BaseTransactionalSet

public BaseTransactionalSet(CommandAsyncExecutor commandExecutor,
                            long timeout,
                            <TransactionalOperation> operations,
                            RCollectionAsync<V> set)

Method Detail

isExistsAsync

public > isExistsAsync()

unlinkAsync

public > unlinkAsync(CommandAsyncExecutor commandExecutor)

touchAsync

public > touchAsync(CommandAsyncExecutor commandExecutor)

deleteAsync

public > deleteAsync(CommandAsyncExecutor commandExecutor)

deleteAsync

protected > deleteAsync(CommandAsyncExecutor commandExecutor,
                                       TransactionalOperation operation)

containsAsync

public > containsAsync( value)

scanIteratorSource

protected abstract > scanIteratorSource( name,
                                                         RedisClient client,
                                                         long startPos,
                                                          pattern,
                                                         int count)

scanIterator

protected > scanIterator( name,
                                          RedisClient client,
                                          long startPos,
                                           pattern,
                                          int count)

readAllAsyncSource

protected abstract <V>> readAllAsyncSource()

readAllAsync

public <V>> readAllAsync()

addAsync

public > addAsync(V value)

addAsync

public > addAsync(V value,
                                 TransactionalOperation operation)

createAddOperation

protected abstract TransactionalOperation createAddOperation(V value,
                                                             long threadId)

removeRandomAsync

public RFuture<V> removeRandomAsync()

removeRandomAsync

public <V>> removeRandomAsync(int amount)

moveAsync

public > moveAsync( destination,
                                  V value)

createMoveOperation

protected abstract  destination,
                                                     V value,
                                                     long threadId)

getLock

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

removeAsync

public > removeAsync( value)

createRemoveOperation

protected abstract  value,
                                                                long threadId)

containsAllAsync

public > containsAllAsync(<?> c)

addAllAsync

public > addAllAsync(<? extends V> c)

retainAllAsync

public > retainAllAsync(<?> c)

removeAllAsync

public > removeAllAsync(<?> c)

unionAsync

public > unionAsync(... names)

diffAsync

public > diffAsync(... names)

intersectionAsync

public > intersectionAsync(... names)

readSortAsync

public <V>> readSortAsync(SortOrder order)

readSortAsync

public <V>> readSortAsync(SortOrder order,
                                     int offset,
                                     int count)

readSortAsync

public < byPattern,
                                     SortOrder order)

readSortAsync

public <T> <T>> readSortAsync( byPattern,
                                                <> getPatterns,
                                                SortOrder order,
                                                int offset,
                                                int count)

readSortAlphaAsync

public <V>> readSortAlphaAsync(SortOrder order)

readSortAlphaAsync

public <V>> readSortAlphaAsync(SortOrder order,
                                          int offset,
                                          int count)

readSortAlphaAsync

public < byPattern,
                                          SortOrder order)

readSortAlphaAsync

public < byPattern,
                                          SortOrder order,
                                          int offset,
                                          int count)

readSortAlphaAsync

public <T> <T>> readSortAlphaAsync( byPattern,
                                                     <> getPatterns,
                                                     SortOrder order)

readSortAlphaAsync

public <T> <T>> readSortAlphaAsync( byPattern,
                                                     <> getPatterns,
                                                     SortOrder order,
                                                     int offset,
                                                     int count)

sortToAsync

public > sortToAsync( destName,
                                     byPattern,
                                    <> getPatterns,
                                    SortOrder order,
                                    int offset,
                                    int count)

readUnionAsync

public <... names)

readDiffAsync

public <... names)

readIntersectionAsync

public <... names)

executeLocked

protected <R> void executeLocked(RPromise<R> promise,
                                  value,
                                  runnable)

executeLocked

protected <R> void executeLocked(RPromise<R> promise,
                                  runnable,
                                 RLock lock)

executeLocked

protected <R> void executeLocked(RPromise<R> promise,
                                  runnable,
                                 <?> values)