Package org.redisson.reactive
Class RedissonBatchReactive
-
- org.redisson.reactive.RedissonBatchReactive
-
- All Implemented Interfaces:
RBatchReactive
public class RedissonBatchReactive extends implements RBatchReactive
- Author:
- Nikita Koksharov
-
-
Constructor Summary
Constructors Constructor Description RedissonBatchReactive(EvictionScheduler evictionScheduler, ConnectionManager connectionManager, CommandReactiveExecutor commandExecutor, BatchOptions options)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description reactor.core.publisher.Mono<>
discard()
Discard batched commands and release allocated buffers used for parameters encoding.reactor.core.publisher.Mono<BatchResult<?>>
execute()
Executes all operations accumulated during Reactive methods invocations Reactivehronously.RAtomicDoubleReactive
name)
Returns atomicDouble instance by name.RAtomicLongReactive
name)
Returns "atomic long" instance by name.RBitSetReactive
name)
Returns bitSet instance by name.<V> RBlockingDequeReactive<V>
name)
Returns blocking deque instance by name.<V> RBlockingDequeReactive<V>
name, Codec codec)
<V> RBlockingQueueReactive<V>
name)
Returns blocking queue instance by name.<V> RBlockingQueueReactive<V>
name, Codec codec)
<V> RBucketReactive<V>
name)
Returns object holder by name<V> RBucketReactive<V>
name, Codec codec)
<V> RDequeReactive<V>
name)
Returns deque instance by name.<V> RDequeReactive<V>
name, Codec codec)
<V> RGeoReactive<V>
name)
Returns geospatial items holder instance byname
.<V> RGeoReactive<V>
name, Codec codec)
Returns geospatial items holder instance byname
using provided codec for geospatial members.<V> RHyperLogLogReactive<V>
name)
Returns HyperLogLog object by name<V> RHyperLogLogReactive<V>
name, Codec codec)
RKeysReactive
getKeys()
Returns keys operations.RLexSortedSetReactive
name)
Returns String based Redis Sorted Set instance by name All elements are inserted with the same score during addition, in order to force lexicographical ordering<V> RListReactive<V>
name)
Returns list instance by name.<V> RListReactive<V>
name, Codec codec)
<K,V>
RListMultimapReactive<K,V>name)
Returns List based MultiMap instance by name.<K,V>
RListMultimapReactive<K,V>name, Codec codec)
Returns List based MultiMap instance by name using provided codec for both map keys and values.<K,V>
RMapReactive<K,V>name)
Returns map instance by name.<K,V>
RMapReactive<K,V>name, Codec codec)
<K,V>
RMapCacheReactive<K,V>name)
Returns map-based cache instance byname
.<K,V>
RMapCacheReactive<K,V>name, Codec codec)
Returns map-based cache instance byname
using providedcodec
for both cache keys and values.<V> RQueueReactive<V>
name)
Returns queue instance by name.<V> RQueueReactive<V>
name, Codec codec)
<V> RScoredSortedSetReactive<V>
name)
Returns Redis Sorted Set instance by name<V> RScoredSortedSetReactive<V>
name, Codec codec)
RScriptReactive
getScript()
Returns script operations objectRScriptReactive
getScript(Codec codec)
Returns script operations object using provided codec.<V> RSetReactive<V>
name)
Returns set instance by name.<V> RSetReactive<V>
name, Codec codec)
<V> RSetCacheReactive<V>
name)
Returns set-based cache instance byname
.<V> RSetCacheReactive<V>
name, Codec codec)
Returns set-based cache instance byname
using providedcodec
for values.<K,V>
RSetMultimapReactive<K,V>name)
Returns Set based Multimap instance by name.<K,V>
RSetMultimapReactive<K,V>name, Codec codec)
Returns Set based Multimap instance by name using provided codec for both map keys and values.<K,V>
RStreamReactive<K,V>name)
Returns stream instance byname
<K,V>
RStreamReactive<K,V>name, Codec codec)
Returns stream instance byname
using providedcodec
for entries.RTopicReactive
name)
Returns topic instance by name.RTopicReactive
name, Codec codec)
-
-
-
Constructor Detail
-
RedissonBatchReactive
public RedissonBatchReactive(EvictionScheduler evictionScheduler, ConnectionManager connectionManager, CommandReactiveExecutor commandExecutor, BatchOptions options)
-
-
Method Detail
-
getStream
public <K,V> name)
Description copied from interface:RBatchReactive
Returns stream instance byname
Requires Redis 5.0.0 and higher.
- Specified by:
getStream
in interfaceRBatchReactive
- Type Parameters:
K
- type of keyV
- type of value- Parameters:
name
- of stream- Returns:
- RStream object
-
getStream
public <K,V> name, Codec codec)
Description copied from interface:RBatchReactive
Returns stream instance byname
using providedcodec
for entries.Requires Redis 5.0.0 and higher.
- Specified by:
getStream
in interfaceRBatchReactive
- Type Parameters:
K
- type of keyV
- type of value- Parameters:
name
- - name of streamcodec
- - codec for entry- Returns:
- RStream object
-
getBucket
public <V> name)
Description copied from interface:RBatchReactive
Returns object holder by name- Specified by:
getBucket
in interfaceRBatchReactive
- Type Parameters:
V
- type of value- Parameters:
name
- - name of object- Returns:
- Bucket object
-
getBucket
public <V> name, Codec codec)
- Specified by:
getBucket
in interfaceRBatchReactive
-
getHyperLogLog
public <V> name)
Description copied from interface:RBatchReactive
Returns HyperLogLog object by name- Specified by:
getHyperLogLog
in interfaceRBatchReactive
- Type Parameters:
V
- type of value- Parameters:
name
- - name of object- Returns:
- HyperLogLog object
-
getHyperLogLog
public <V> name, Codec codec)
- Specified by:
getHyperLogLog
in interfaceRBatchReactive
-
getList
public <V> name)
Description copied from interface:RBatchReactive
Returns list instance by name.- Specified by:
getList
in interfaceRBatchReactive
- Type Parameters:
V
- type of value- Parameters:
name
- - name of object- Returns:
- List object
-
getList
public <V> name, Codec codec)
- Specified by:
getList
in interfaceRBatchReactive
-
getMap
public <K,V> name)
Description copied from interface:RBatchReactive
Returns map instance by name.- Specified by:
getMap
in interfaceRBatchReactive
- Type Parameters:
K
- type of keyV
- type of value- Parameters:
name
- - name of object- Returns:
- Map object
-
getMap
public <K,V> name, Codec codec)
- Specified by:
getMap
in interfaceRBatchReactive
-
getMapCache
public <K,V> name, Codec codec)
Description copied from interface:RBatchReactive
Returns map-based cache instance byname
using providedcodec
for both cache keys and values. Supports entry eviction with a given TTL value.If eviction is not required then it's better to use regular map
RBatchReactive.getMap(String, Codec)
.- Specified by:
getMapCache
in interfaceRBatchReactive
- Type Parameters:
K
- type of keyV
- type of value- Parameters:
name
- - name of objectcodec
- - codec for keys and values- Returns:
- MapCache object
-
getMapCache
public <K,V> name)
Description copied from interface:RBatchReactive
Returns map-based cache instance byname
. Supports entry eviction with a given TTL value.If eviction is not required then it's better to use regular map
RBatchReactive.getMap(String)
.- Specified by:
getMapCache
in interfaceRBatchReactive
- Type Parameters:
K
- type of keyV
- type of value- Parameters:
name
- - name of object- Returns:
- MapCache object
-
getSet
public <V> name)
Description copied from interface:RBatchReactive
Returns set instance by name.- Specified by:
getSet
in interfaceRBatchReactive
- Type Parameters:
V
- type of value- Parameters:
name
- - name of object- Returns:
- Set object
-
getSet
public <V> name, Codec codec)
- Specified by:
getSet
in interfaceRBatchReactive
-
getTopic
public name)
Description copied from interface:RBatchReactive
Returns topic instance by name.- Specified by:
getTopic
in interfaceRBatchReactive
- Parameters:
name
- - name of object- Returns:
- Topic object
-
getTopic
public name, Codec codec)
- Specified by:
getTopic
in interfaceRBatchReactive
-
getQueue
public <V> name)
Description copied from interface:RBatchReactive
Returns queue instance by name.- Specified by:
getQueue
in interfaceRBatchReactive
- Type Parameters:
V
- type of value- Parameters:
name
- - name of object- Returns:
- Queue object
-
getQueue
public <V> name, Codec codec)
- Specified by:
getQueue
in interfaceRBatchReactive
-
getBlockingQueue
public <V> name)
Description copied from interface:RBatchReactive
Returns blocking queue instance by name.- Specified by:
getBlockingQueue
in interfaceRBatchReactive
- Type Parameters:
V
- type of value- Parameters:
name
- - name of object- Returns:
- BlockingQueue object
-
getBlockingQueue
public <V> name, Codec codec)
- Specified by:
getBlockingQueue
in interfaceRBatchReactive
-
getDeque
public <V> name)
Description copied from interface:RBatchReactive
Returns deque instance by name.- Specified by:
getDeque
in interfaceRBatchReactive
- Type Parameters:
V
- type of value- Parameters:
name
- - name of object- Returns:
- Deque object
-
getDeque
public <V> name, Codec codec)
- Specified by:
getDeque
in interfaceRBatchReactive
-
getAtomicLong
public name)
Description copied from interface:RBatchReactive
Returns "atomic long" instance by name.- Specified by:
getAtomicLong
in interfaceRBatchReactive
- Parameters:
name
- - name of object- Returns:
- AtomicLong object
-
getSetCache
public <V> name)
Description copied from interface:RBatchReactive
Returns set-based cache instance byname
. Uses map (value_hash, value) under the hood for minimal memory consumption. Supports value eviction with a given TTL value.If eviction is not required then it's better to use regular map
RBatchReactive.getSet(String, Codec)
.- Specified by:
getSetCache
in interfaceRBatchReactive
- Type Parameters:
V
- type of value- Parameters:
name
- - name of object- Returns:
- SetCache object
-
getSetCache
public <V> name, Codec codec)
Description copied from interface:RBatchReactive
Returns set-based cache instance byname
using providedcodec
for values. Uses map (value_hash, value) under the hood for minimal memory consumption. Supports value eviction with a given TTL value.If eviction is not required then it's better to use regular map
RBatchReactive.getSet(String, Codec)
.- Specified by:
getSetCache
in interfaceRBatchReactive
- Type Parameters:
V
- type of value- Parameters:
name
- - name of objectcodec
- - codec for values- Returns:
- SetCache object
-
getScoredSortedSet
public <V> name)
Description copied from interface:RBatchReactive
Returns Redis Sorted Set instance by name- Specified by:
getScoredSortedSet
in interfaceRBatchReactive
- Type Parameters:
V
- type of value- Parameters:
name
- - name of object- Returns:
- ScoredSortedSet object
-
getScoredSortedSet
public <V> name, Codec codec)
- Specified by:
getScoredSortedSet
in interfaceRBatchReactive
-
getLexSortedSet
public name)
Description copied from interface:RBatchReactive
Returns String based Redis Sorted Set instance by name All elements are inserted with the same score during addition, in order to force lexicographical ordering- Specified by:
getLexSortedSet
in interfaceRBatchReactive
- Parameters:
name
- - name of object- Returns:
- LexSortedSet object
-
getBitSet
public name)
Description copied from interface:RBatchReactive
Returns bitSet instance by name.- Specified by:
getBitSet
in interfaceRBatchReactive
- Parameters:
name
- of bitSet- Returns:
- BitSet object
-
getScript
public RScriptReactive getScript()
Description copied from interface:RBatchReactive
Returns script operations object- Specified by:
getScript
in interfaceRBatchReactive
- Returns:
- Script object
-
getScript
public RScriptReactive getScript(Codec codec)
Description copied from interface:RBatchReactive
Returns script operations object using provided codec.- Specified by:
getScript
in interfaceRBatchReactive
- Parameters:
codec
- - codec for params and result- Returns:
- Script object
-
getKeys
public RKeysReactive getKeys()
Description copied from interface:RBatchReactive
Returns keys operations. Each of Redis/Redisson object associated with own key- Specified by:
getKeys
in interfaceRBatchReactive
- Returns:
- Keys object
-
execute
public reactor.core.publisher.Mono<BatchResult<?>> execute()
Description copied from interface:RBatchReactive
Executes all operations accumulated during Reactive methods invocations Reactivehronously. In cluster configurations operations grouped by slot ids so may be executed on different servers. Thus command execution order could be changed- Specified by:
execute
in interfaceRBatchReactive
- Returns:
- List with result object for each command
-
discard
public reactor.core.publisher.Mono<> discard()
Description copied from interface:RBatchReactive
Discard batched commands and release allocated buffers used for parameters encoding.- Specified by:
discard
in interfaceRBatchReactive
- Returns:
- void
-
getGeo
public <V> name)
Description copied from interface:RBatchReactive
Returns geospatial items holder instance byname
.- Specified by:
getGeo
in interfaceRBatchReactive
- Type Parameters:
V
- type of value- Parameters:
name
- - name of object- Returns:
- Geo object
-
getGeo
public <V> name, Codec codec)
Description copied from interface:RBatchReactive
Returns geospatial items holder instance byname
using provided codec for geospatial members.- Specified by:
getGeo
in interfaceRBatchReactive
- Type Parameters:
V
- type of value- Parameters:
name
- - name of objectcodec
- - codec for value- Returns:
- Geo object
-
getSetMultimap
public <K,V> name)
Description copied from interface:RBatchReactive
Returns Set based Multimap instance by name.- Specified by:
getSetMultimap
in interfaceRBatchReactive
- Type Parameters:
K
- type of keyV
- type of value- Parameters:
name
- - name of object- Returns:
- SetMultimap object
-
getSetMultimap
public <K,V> name, Codec codec)
Description copied from interface:RBatchReactive
Returns Set based Multimap instance by name using provided codec for both map keys and values.- Specified by:
getSetMultimap
in interfaceRBatchReactive
- Type Parameters:
K
- type of keyV
- type of value- Parameters:
name
- - name of objectcodec
- - codec for keys and values- Returns:
- SetMultimap object
-
getListMultimap
public <K,V> name)
Description copied from interface:RBatchReactive
Returns List based MultiMap instance by name.- Specified by:
getListMultimap
in interfaceRBatchReactive
- Type Parameters:
K
- type of keyV
- type of value- Parameters:
name
- - name of object- Returns:
- ListMultimap object
-
getListMultimap
public <K,V> name, Codec codec)
Description copied from interface:RBatchReactive
Returns List based MultiMap instance by name using provided codec for both map keys and values.- Specified by:
getListMultimap
in interfaceRBatchReactive
- Type Parameters:
K
- type of keyV
- type of value- Parameters:
name
- - name of objectcodec
- - codec for keys and values- Returns:
- ListMultimap object
-
getAtomicDouble
public name)
Description copied from interface:RBatchReactive
Returns atomicDouble instance by name.- Specified by:
getAtomicDouble
in interfaceRBatchReactive
- Parameters:
name
- - name of object- Returns:
- AtomicDouble object
-
getBlockingDeque
public <V> name)
Description copied from interface:RBatchReactive
Returns blocking deque instance by name.- Specified by:
getBlockingDeque
in interfaceRBatchReactive
- Type Parameters:
V
- type of value- Parameters:
name
- - name of object- Returns:
- BlockingDeque object
-
getBlockingDeque
public <V> name, Codec codec)
- Specified by:
getBlockingDeque
in interfaceRBatchReactive
-
-