Package org.redisson.api
Interface RBatchReactive
-
- All Known Implementing Classes:
RedissonBatchReactive
public interface RBatchReactive
Reactive interface for Redis pipeline feature.All method invocations on objects from this interface are batched to separate queue and could be executed later with
execute()
method.- Author:
- Nikita Koksharov
-
-
Method Summary
All Methods Instance Methods Abstract 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)
-
-
-
Method Detail
-
getStream
<K,V> name)
Returns stream instance byname
Requires Redis 5.0.0 and higher.
- Type Parameters:
K
- type of keyV
- type of value- Parameters:
name
- of stream- Returns:
- RStream object
-
getStream
<K,V> name, Codec codec)
Returns stream instance byname
using providedcodec
for entries.Requires Redis 5.0.0 and higher.
- Type Parameters:
K
- type of keyV
- type of value- Parameters:
name
- - name of streamcodec
- - codec for entry- Returns:
- RStream object
-
getGeo
<V> name)
Returns geospatial items holder instance byname
.- Type Parameters:
V
- type of value- Parameters:
name
- - name of object- Returns:
- Geo object
-
getGeo
<V> name, Codec codec)
Returns geospatial items holder instance byname
using provided codec for geospatial members.- Type Parameters:
V
- type of value- Parameters:
name
- - name of objectcodec
- - codec for value- Returns:
- Geo object
-
getSetMultimap
<K,V> name)
Returns Set based Multimap instance by name.- Type Parameters:
K
- type of keyV
- type of value- Parameters:
name
- - name of object- Returns:
- SetMultimap object
-
getSetMultimap
<K,V> name, Codec codec)
Returns Set based Multimap instance by name using provided codec for both map keys and values.- Type Parameters:
K
- type of keyV
- type of value- Parameters:
name
- - name of objectcodec
- - codec for keys and values- Returns:
- SetMultimap object
-
getSetCache
<V> name)
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
getSet(String, Codec)
.- Type Parameters:
V
- type of value- Parameters:
name
- - name of object- Returns:
- SetCache object
-
getSetCache
<V> name, Codec codec)
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
getSet(String, Codec)
.- Type Parameters:
V
- type of value- Parameters:
name
- - name of objectcodec
- - codec for values- Returns:
- SetCache object
-
getMapCache
<K,V> name, Codec codec)
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
getMap(String, Codec)
.- Type Parameters:
K
- type of keyV
- type of value- Parameters:
name
- - name of objectcodec
- - codec for keys and values- Returns:
- MapCache object
-
getMapCache
<K,V> name)
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
getMap(String)
.- Type Parameters:
K
- type of keyV
- type of value- Parameters:
name
- - name of object- Returns:
- MapCache object
-
getBucket
<V> name)
Returns object holder by name- Type Parameters:
V
- type of value- Parameters:
name
- - name of object- Returns:
- Bucket object
-
getBucket
<V> name, Codec codec)
-
getHyperLogLog
<V> name)
Returns HyperLogLog object by name- Type Parameters:
V
- type of value- Parameters:
name
- - name of object- Returns:
- HyperLogLog object
-
getHyperLogLog
<V> name, Codec codec)
-
getList
<V> name)
Returns list instance by name.- Type Parameters:
V
- type of value- Parameters:
name
- - name of object- Returns:
- List object
-
getList
<V> name, Codec codec)
-
getListMultimap
<K,V> name)
Returns List based MultiMap instance by name.- Type Parameters:
K
- type of keyV
- type of value- Parameters:
name
- - name of object- Returns:
- ListMultimap object
-
getListMultimap
<K,V> name, Codec codec)
Returns List based MultiMap instance by name using provided codec for both map keys and values.- Type Parameters:
K
- type of keyV
- type of value- Parameters:
name
- - name of objectcodec
- - codec for keys and values- Returns:
- ListMultimap object
-
getMap
<K,V> name)
Returns map instance by name.- Type Parameters:
K
- type of keyV
- type of value- Parameters:
name
- - name of object- Returns:
- Map object
-
getMap
<K,V> name, Codec codec)
-
getSet
<V> name)
Returns set instance by name.- Type Parameters:
V
- type of value- Parameters:
name
- - name of object- Returns:
- Set object
-
getSet
<V> name, Codec codec)
-
getTopic
name)
Returns topic instance by name.- Parameters:
name
- - name of object- Returns:
- Topic object
-
getTopic
name, Codec codec)
-
getQueue
<V> name)
Returns queue instance by name.- Type Parameters:
V
- type of value- Parameters:
name
- - name of object- Returns:
- Queue object
-
getQueue
<V> name, Codec codec)
-
getBlockingQueue
<V> name)
Returns blocking queue instance by name.- Type Parameters:
V
- type of value- Parameters:
name
- - name of object- Returns:
- BlockingQueue object
-
getBlockingQueue
<V> name, Codec codec)
-
getBlockingDeque
<V> name)
Returns blocking deque instance by name.- Type Parameters:
V
- type of value- Parameters:
name
- - name of object- Returns:
- BlockingDeque object
-
getBlockingDeque
<V> name, Codec codec)
-
getDeque
<V> name)
Returns deque instance by name.- Type Parameters:
V
- type of value- Parameters:
name
- - name of object- Returns:
- Deque object
-
getDeque
<V> name, Codec codec)
-
getAtomicLong
name)
Returns "atomic long" instance by name.- Parameters:
name
- - name of object- Returns:
- AtomicLong object
-
getAtomicDouble
name)
Returns atomicDouble instance by name.- Parameters:
name
- - name of object- Returns:
- AtomicDouble object
-
getScoredSortedSet
<V> name)
Returns Redis Sorted Set instance by name- Type Parameters:
V
- type of value- Parameters:
name
- - name of object- Returns:
- ScoredSortedSet object
-
getScoredSortedSet
<V> name, Codec codec)
-
getLexSortedSet
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- Parameters:
name
- - name of object- Returns:
- LexSortedSet object
-
getBitSet
name)
Returns bitSet instance by name.- Parameters:
name
- of bitSet- Returns:
- BitSet object
-
getScript
RScriptReactive getScript()
Returns script operations object- Returns:
- Script object
-
getScript
RScriptReactive getScript(Codec codec)
Returns script operations object using provided codec.- Parameters:
codec
- - codec for params and result- Returns:
- Script object
-
getKeys
RKeysReactive getKeys()
Returns keys operations. Each of Redis/Redisson object associated with own key- Returns:
- Keys object
-
execute
reactor.core.publisher.Mono<BatchResult<?>> execute()
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- Returns:
- List with result object for each command
-
discard
reactor.core.publisher.Mono<> discard()
Discard batched commands and release allocated buffers used for parameters encoding.- Returns:
- void
-
-