Package org.redisson.api
Interface RBatchRx
-
- All Known Implementing Classes:
RedissonBatchRx
public interface RBatchRx
RxJava2 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 io.reactivex.rxjava3.core.Completable
discard()
Discard batched commands and release allocated buffers used for parameters encoding.io.reactivex.rxjava3.core.Maybe<BatchResult<?>>
execute()
Executes all operations accumulated during Reactive methods invocations Reactivehronously.RAtomicDoubleRx
name)
Returns atomicDouble instance by name.RAtomicLongRx
name)
Returns "atomic long" instance by name.RBitSetRx
name)
Returns bitSet instance by name.<V> RBlockingDequeRx<V>
name)
Returns blocking deque instance by name.<V> RBlockingDequeRx<V>
name, Codec codec)
<V> RBlockingQueueRx<V>
name)
Returns blocking queue instance by name.<V> RBlockingQueueRx<V>
name, Codec codec)
<V> RBucketRx<V>
name)
Returns object holder by name<V> RBucketRx<V>
name, Codec codec)
<V> RDequeRx<V>
name)
Returns deque instance by name.<V> RDequeRx<V>
name, Codec codec)
<V> RGeoRx<V>
name)
Returns geospatial items holder instance byname
.<V> RGeoRx<V>
name, Codec codec)
Returns geospatial items holder instance byname
using provided codec for geospatial members.<V> RHyperLogLogRx<V>
name)
Returns HyperLogLog object by name<V> RHyperLogLogRx<V>
name, Codec codec)
RKeysRx
getKeys()
Returns keys operations.RLexSortedSetRx
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> RListRx<V>
name)
Returns list instance by name.<V> RListRx<V>
name, Codec codec)
<K,V>
RListMultimapRx<K,V>name)
Returns List based MultiMap instance by name.<K,V>
RListMultimapRx<K,V>name, Codec codec)
Returns List based MultiMap instance by name using provided codec for both map keys and values.<K,V>
RListMultimapCacheRx<K,V>name)
Returns List based Multimap cache instance by name.<K,V>
RListMultimapCacheRx<K,V>name, Codec codec)
Returns List based Multimap cache instance by name using provided codec for both map keys and values.<K,V>
RMapRx<K,V>name)
Returns map instance by name.<K,V>
RMapRx<K,V>name, Codec codec)
<K,V>
RMapCacheRx<K,V>name)
Returns map-based cache instance byname
.<K,V>
RMapCacheRx<K,V>name, Codec codec)
Returns map-based cache instance byname
using providedcodec
for both cache keys and values.<V> RQueueRx<V>
name)
Returns queue instance by name.<V> RQueueRx<V>
name, Codec codec)
<V> RScoredSortedSetRx<V>
name)
Returns Redis Sorted Set instance by name<V> RScoredSortedSetRx<V>
name, Codec codec)
RScriptRx
getScript()
Returns script operations objectRScriptRx
getScript(Codec codec)
Returns script operations object using provided codec.<V> RSetRx<V>
name)
Returns set instance by name.<V> RSetRx<V>
name, Codec codec)
<V> RSetCacheRx<V>
name)
Returns set-based cache instance byname
.<V> RSetCacheRx<V>
name, Codec codec)
Returns set-based cache instance byname
using providedcodec
for values.<K,V>
RSetMultimapRx<K,V>name)
Returns Set based Multimap instance by name.<K,V>
RSetMultimapRx<K,V>name, Codec codec)
Returns Set based Multimap instance by name using provided codec for both map keys and values.<K,V>
RSetMultimapCacheRx<K,V>name)
Returns Set based Multimap cache instance by name.<K,V>
RSetMultimapCacheRx<K,V>name, Codec codec)
Returns Set based Multimap cache instance by name using provided codec for both map keys and values.<K,V>
RStreamRx<K,V>name)
Returns stream instance byname
<K,V>
RStreamRx<K,V>name, Codec codec)
Returns stream instance byname
using providedcodec
for entries.RTopicRx
name)
Returns topic instance by name.RTopicRx
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
-
getSetMultimapCache
<K,V> name)
Returns Set based Multimap cache instance by name. Supports key eviction by specifying a time to live. If eviction is not required then it's better to use regular set multimapgetSetMultimap(String)
.- Type Parameters:
K
- type of keyV
- type of value- Parameters:
name
- - name of object- Returns:
- RSetMultimapCacheRx object
-
getSetMultimapCache
<K,V> name, Codec codec)
Returns Set based Multimap cache instance by name using provided codec for both map keys and values. Supports key eviction by specifying a time to live. If eviction is not required then it's better to use regular set multimapgetSetMultimap(String, Codec)
.- Type Parameters:
K
- type of keyV
- type of value- Parameters:
name
- - name of objectcodec
- - codec for keys and values- Returns:
- RSetMultimapCacheRx 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
-
getListMultimapCache
<K,V> name)
Returns List based Multimap cache instance by name. Supports key eviction by specifying a time to live. If eviction is not required then it's better to use regular list multimapgetListMultimap(String)
.- Type Parameters:
K
- type of keyV
- type of value- Parameters:
name
- - name of object- Returns:
- RListMultimapCacheRx object
-
getListMultimapCache
<K,V> name, Codec codec)
Returns List based Multimap cache instance by name using provided codec for both map keys and values. Supports key eviction by specifying a time to live. If eviction is not required then it's better to use regular list multimapgetListMultimap(String, Codec)
.- Type Parameters:
K
- type of keyV
- type of value- Parameters:
name
- - name of objectcodec
- - codec for keys and values- Returns:
- RListMultimapCacheRx 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
RScriptRx getScript()
Returns script operations object- Returns:
- Script object
-
getScript
RScriptRx getScript(Codec codec)
Returns script operations object using provided codec.- Parameters:
codec
- - codec for params and result- Returns:
- Script object
-
getKeys
RKeysRx getKeys()
Returns keys operations. Each of Redis/Redisson object associated with own key- Returns:
- Keys object
-
execute
io.reactivex.rxjava3.core.Maybe<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
io.reactivex.rxjava3.core.Completable discard()
Discard batched commands and release allocated buffers used for parameters encoding.- Returns:
- void
-
-