Package org.redisson.transaction

Class BaseTransactionalSet<V>

java.lang.Object

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, List<TransactionalOperation> operations, RCollectionAsync<V> set)

Method Summary

Modifier and Type	Method	Description
RFuture<Boolean>	addAllAsync(Collection<? extends V> c)
RFuture<Boolean>	addAsync(V value)
RFuture<Boolean>	addAsync(V value, TransactionalOperation operation)
RFuture<Boolean>	containsAllAsync(Collection<?> c)
RFuture<Boolean>	containsAsync(Object value)
protected abstract TransactionalOperation	createAddOperation(V value, long threadId)
protected abstract MoveOperation	createMoveOperation(String destination, V value, long threadId)
protected abstract TransactionalOperation	createRemoveOperation(Object value, long threadId)
RFuture<Boolean>	deleteAsync(CommandAsyncExecutor commandExecutor)
protected RFuture<Boolean>	deleteAsync(CommandAsyncExecutor commandExecutor, TransactionalOperation operation)
RFuture<Integer>	diffAsync(String... names)
protected <R> RFuture<R>	executeLocked(Object value, Supplier<CompletionStage<R>> runnable)
protected <R> RFuture<R>	executeLocked(Supplier<CompletionStage<R>> runnable, Collection<?> values)
protected abstract RLock	getLock(RCollectionAsync<V> set, V value)
RFuture<Integer>	intersectionAsync(String... names)
RFuture<Boolean>	isExistsAsync()
RFuture<Boolean>	moveAsync(String destination, V value)
RFuture<Set<V>>	readAllAsync()
protected abstract RFuture<Set<V>>	readAllAsyncSource()
RFuture<Set<V>>	readDiffAsync(String... names)
RFuture<Set<V>>	readIntersectionAsync(String... names)
<T> RFuture<Collection<T>>	readSortAlphaAsync(String byPattern, List<String> getPatterns, SortOrder order)
<T> RFuture<Collection<T>>	readSortAlphaAsync(String byPattern, List<String> getPatterns, SortOrder order, int offset, int count)
RFuture<Set<V>>	readSortAlphaAsync(String byPattern, SortOrder order)
RFuture<Set<V>>	readSortAlphaAsync(String byPattern, SortOrder order, int offset, int count)
RFuture<Set<V>>	readSortAlphaAsync(SortOrder order)
RFuture<Set<V>>	readSortAlphaAsync(SortOrder order, int offset, int count)
<T> RFuture<Collection<T>>	readSortAsync(String byPattern, List<String> getPatterns, SortOrder order, int offset, int count)
RFuture<Set<V>>	readSortAsync(String byPattern, SortOrder order)
RFuture<Set<V>>	readSortAsync(SortOrder order)
RFuture<Set<V>>	readSortAsync(SortOrder order, int offset, int count)
RFuture<Set<V>>	readUnionAsync(String... names)
RFuture<Boolean>	removeAllAsync(Collection<?> c)
RFuture<Boolean>	removeAsync(Object value)
RFuture<V>	removeRandomAsync()
RFuture<Set<V>>	removeRandomAsync(int amount)
RFuture<Boolean>	retainAllAsync(Collection<?> c)
protected ScanResult<Object>	scanIterator(String name, RedisClient client, long startPos, String pattern, int count)
protected abstract ScanResult<Object>	scanIteratorSource(String name, RedisClient client, long startPos, String pattern, int count)
RFuture<Integer>	sortToAsync(String destName, String byPattern, List<String> getPatterns, SortOrder order, int offset, int count)
RFuture<Boolean>	touchAsync(CommandAsyncExecutor commandExecutor)
RFuture<Integer>	unionAsync(String... names)
RFuture<Boolean>	unlinkAsync(CommandAsyncExecutor commandExecutor)

Methods inherited from class org.redisson.transaction.BaseTransactionalObject

clearExpireAsync, executeLocked, executeLocked, 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 Details

BaseTransactionalSet

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

Method Details

isExistsAsync

public RFuture<Boolean> isExistsAsync()

unlinkAsync

public RFuture<Boolean> unlinkAsync(CommandAsyncExecutor commandExecutor)

touchAsync

public RFuture<Boolean> touchAsync(CommandAsyncExecutor commandExecutor)

deleteAsync

public RFuture<Boolean> deleteAsync(CommandAsyncExecutor commandExecutor)

deleteAsync

protected RFuture<Boolean> deleteAsync(CommandAsyncExecutor commandExecutor,
 TransactionalOperation operation)

containsAsync

public RFuture<Boolean> containsAsync(Object value)

scanIteratorSource

protected abstract ScanResult<Object> scanIteratorSource(String name,
 RedisClient client,
 long startPos,
 String pattern,
 int count)

scanIterator

protected ScanResult<Object> scanIterator(String name,
 RedisClient client,
 long startPos,
 String pattern,
 int count)

readAllAsyncSource

protected abstract RFuture<Set<V>> readAllAsyncSource()

readAllAsync

public RFuture<Set<V>> readAllAsync()

addAsync

public RFuture<Boolean> addAsync(V value)

addAsync

public RFuture<Boolean> addAsync(V value,
 TransactionalOperation operation)

createAddOperation

protected abstract TransactionalOperation createAddOperation(V value,
 long threadId)

removeRandomAsync

public RFuture<V> removeRandomAsync()

removeRandomAsync

public RFuture<Set<V>> removeRandomAsync(int amount)

moveAsync

public RFuture<Boolean> moveAsync(String destination,
 V value)

createMoveOperation

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

getLock

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

removeAsync

public RFuture<Boolean> removeAsync(Object value)

createRemoveOperation

protected abstract TransactionalOperation createRemoveOperation(Object value,
 long threadId)

containsAllAsync

public RFuture<Boolean> containsAllAsync(Collection<?> c)

addAllAsync

public RFuture<Boolean> addAllAsync(Collection<? extends V> c)

retainAllAsync

public RFuture<Boolean> retainAllAsync(Collection<?> c)

removeAllAsync

public RFuture<Boolean> removeAllAsync(Collection<?> c)

unionAsync

public RFuture<Integer> unionAsync(String... names)

diffAsync

public RFuture<Integer> diffAsync(String... names)

intersectionAsync

public RFuture<Integer> intersectionAsync(String... names)

readSortAsync

public RFuture<Set<V>> readSortAsync(SortOrder order)

readSortAsync

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

readSortAsync

public RFuture<Set<V>> readSortAsync(String byPattern,
 SortOrder order)

readSortAsync

public <T> RFuture<Collection<T>> readSortAsync(String byPattern,
 List<String> getPatterns,
 SortOrder order,
 int offset,
 int count)

readSortAlphaAsync

public RFuture<Set<V>> readSortAlphaAsync(SortOrder order)

readSortAlphaAsync

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

readSortAlphaAsync

public RFuture<Set<V>> readSortAlphaAsync(String byPattern,
 SortOrder order)

readSortAlphaAsync

public RFuture<Set<V>> readSortAlphaAsync(String byPattern,
 SortOrder order,
 int offset,
 int count)

readSortAlphaAsync

public <T> RFuture<Collection<T>> readSortAlphaAsync(String byPattern,
 List<String> getPatterns,
 SortOrder order)

readSortAlphaAsync

public <T> RFuture<Collection<T>> readSortAlphaAsync(String byPattern,
 List<String> getPatterns,
 SortOrder order,
 int offset,
 int count)

sortToAsync

public RFuture<Integer> sortToAsync(String destName,
 String byPattern,
 List<String> getPatterns,
 SortOrder order,
 int offset,
 int count)

readUnionAsync

public RFuture<Set<V>> readUnionAsync(String... names)

readDiffAsync

public RFuture<Set<V>> readDiffAsync(String... names)

readIntersectionAsync

public RFuture<Set<V>> readIntersectionAsync(String... names)

executeLocked

protected <R> RFuture<R> executeLocked(Object value,
 Supplier<CompletionStage<R>> runnable)

executeLocked

protected <R> RFuture<R> executeLocked(Supplier<CompletionStage<R>> runnable,
 Collection<?> values)