Interface ReactiveSetOperations<K,V>
public interface ReactiveSetOperations<K,V>
Reactive Redis operations for Set Commands.
Streams of methods returning Mono<K>
or Flux<M>
are terminated with
InvalidDataAccessApiUsageException
when
RedisElementReader.read(ByteBuffer)
returns null for a
particular element as Reactive Streams prohibit the usage of null values.
- Since:
- 2.0
- Author:
- Mark Paluch, Christoph Strobl, Roman Bezpalko
- See Also:
-
Method Summary
Modifier and TypeMethodDescriptionAdd givenvalues
to set atkey
.Removes the given key.difference
(Collection<K> keys) Diff all sets for givenkeys
.difference
(K key, Collection<K> otherKeys) Diff all sets for givenkey
andotherKeys
.difference
(K key, K otherKey) Diff all sets for givenkey
andotherKey
.differenceAndStore
(Collection<K> keys, K destKey) Diff all sets for givenkeys
and store result indestKey
.differenceAndStore
(K key, Collection<K> otherKeys, K destKey) Diff all sets for givenkey
andotherKeys
and store result indestKey
.differenceAndStore
(K key, K otherKey, K destKey) Diff all sets for givenkey
andotherKey
and store result indestKey
.distinctRandomMembers
(K key, long count) Getcount
distinct random elements from set atkey
.intersect
(Collection<K> keys) Returns the members intersecting all given sets atkeys
.intersect
(K key, Collection<K> otherKeys) Returns the members intersecting all given sets atkey
andotherKeys
.Returns the members intersecting all given sets atkey
andotherKey
.intersectAndStore
(Collection<K> keys, K destKey) Intersect all given sets atkeys
and store result indestKey
.intersectAndStore
(K key, Collection<K> otherKeys, K destKey) Intersect all given sets atkey
andotherKeys
and store result indestKey
.intersectAndStore
(K key, K otherKey, K destKey) Intersect all given sets atkey
andotherKey
and store result indestKey
.Check if set atkey
containsvalue
.Check if set atkey
contains one or morevalues
.Get all elements of set atkey
.Movevalue
fromkey
todestKey
Remove and return a random member from set atkey
.Remove and returncount
random members from set atkey
.randomMember
(K key) Get random element from set atkey
.randomMembers
(K key, long count) Getcount
random elements from set atkey
.Remove givenvalues
from set atkey
and return the number of removed elements.Use aFlux
to iterate over entries in the set atkey
.scan
(K key, ScanOptions options) Get size of set atkey
.union
(Collection<K> keys) Union all sets at givenkeys
.union
(K key, Collection<K> otherKeys) Union all sets at givenkeys
andotherKeys
.Union all sets at givenkeys
andotherKey
.unionAndStore
(Collection<K> keys, K destKey) Union all sets at givenkeys
and store result indestKey
.unionAndStore
(K key, Collection<K> otherKeys, K destKey) Union all sets at givenkey
andotherKeys
and store result indestKey
.unionAndStore
(K key, K otherKey, K destKey) Union all sets at givenkey
andotherKey
and store result indestKey
.
-
Method Details
-
add
Add givenvalues
to set atkey
.- Parameters:
key
- must not be null.values
-- Returns:
- See Also:
-
remove
Remove givenvalues
from set atkey
and return the number of removed elements.- Parameters:
key
- must not be null.values
-- Returns:
- See Also:
-
pop
Remove and return a random member from set atkey
.- Parameters:
key
- must not be null.- Returns:
- See Also:
-
pop
Remove and returncount
random members from set atkey
.- Parameters:
key
- must not be null.count
- number of random members to pop from the set.- Returns:
Flux
emitting random members.- See Also:
-
move
Movevalue
fromkey
todestKey
- Parameters:
sourceKey
- must not be null.value
-destKey
- must not be null.- Returns:
- See Also:
-
size
Get size of set atkey
.- Parameters:
key
- must not be null.- Returns:
- See Also:
-
isMember
Check if set atkey
containsvalue
.- Parameters:
key
- must not be null.o
-- Returns:
- See Also:
-
isMember
Check if set atkey
contains one or morevalues
.- Parameters:
key
- must not be null.objects
-- Returns:
- Since:
- 2.6
- See Also:
-
intersect
Returns the members intersecting all given sets atkey
andotherKey
.- Parameters:
key
- must not be null.otherKey
- must not be null.- Returns:
- See Also:
-
intersect
Returns the members intersecting all given sets atkey
andotherKeys
.- Parameters:
key
- must not be null.otherKeys
- must not be null.- Returns:
- See Also:
-
intersect
Returns the members intersecting all given sets atkeys
.- Parameters:
keys
- must not be null.- Returns:
- Since:
- 2.2
- See Also:
-
intersectAndStore
Intersect all given sets atkey
andotherKey
and store result indestKey
.- Parameters:
key
- must not be null.otherKey
- must not be null.destKey
- must not be null.- Returns:
- See Also:
-
intersectAndStore
Intersect all given sets atkey
andotherKeys
and store result indestKey
.- Parameters:
key
- must not be null.otherKeys
- must not be null.destKey
- must not be null.- Returns:
- See Also:
-
intersectAndStore
Intersect all given sets atkeys
and store result indestKey
.- Parameters:
keys
- must not be null.destKey
- must not be null.- Returns:
- Since:
- 2.2
- See Also:
-
union
Union all sets at givenkeys
andotherKey
.- Parameters:
key
- must not be null.otherKey
- must not be null.- Returns:
- See Also:
-
union
Union all sets at givenkeys
andotherKeys
.- Parameters:
key
- must not be null.otherKeys
- must not be null.- Returns:
- See Also:
-
union
Union all sets at givenkeys
.- Parameters:
keys
- must not be null.- Returns:
- Since:
- 2.2
- See Also:
-
unionAndStore
Union all sets at givenkey
andotherKey
and store result indestKey
.- Parameters:
key
- must not be null.otherKey
- must not be null.destKey
- must not be null.- Returns:
- See Also:
-
unionAndStore
Union all sets at givenkey
andotherKeys
and store result indestKey
.- Parameters:
key
- must not be null.otherKeys
- must not be null.destKey
- must not be null.- Returns:
- See Also:
-
unionAndStore
Union all sets at givenkeys
and store result indestKey
.- Parameters:
keys
- must not be null.destKey
- must not be null.- Returns:
- Since:
- 2.2
- See Also:
-
difference
Diff all sets for givenkey
andotherKey
.- Parameters:
key
- must not be null.otherKey
- must not be null.- Returns:
- See Also:
-
difference
Diff all sets for givenkey
andotherKeys
.- Parameters:
key
- must not be null.otherKeys
- must not be null.- Returns:
- See Also:
-
difference
Diff all sets for givenkeys
.- Parameters:
keys
- must not be null.- Returns:
- Since:
- 2.2
- See Also:
-
differenceAndStore
Diff all sets for givenkey
andotherKey
and store result indestKey
.- Parameters:
key
- must not be null.otherKey
- must not be null.destKey
- must not be null.- Returns:
- See Also:
-
differenceAndStore
Diff all sets for givenkey
andotherKeys
and store result indestKey
.- Parameters:
key
- must not be null.otherKeys
- must not be null.destKey
- must not be null.- Returns:
- See Also:
-
differenceAndStore
Diff all sets for givenkeys
and store result indestKey
.- Parameters:
keys
- must not be null.destKey
- must not be null.- Returns:
- Since:
- 2.2
- See Also:
-
members
Get all elements of set atkey
.- Parameters:
key
- must not be null.- Returns:
- See Also:
-
scan
Use aFlux
to iterate over entries in the set atkey
. The resultingFlux
acts as a cursor and issuesSSCAN
commands itself as long as the subscriber signals demand.- Parameters:
key
- must not be null.- Returns:
- the
Flux
emitting the values one by one or anempty Flux
if none exist. - Throws:
IllegalArgumentException
- when givenkey
is null.- Since:
- 2.1
- See Also:
-
scan
Use aFlux
to iterate over entries in the set atkey
givenScanOptions
. The resultingFlux
acts as a cursor and issuesSSCAN
commands itself as long as the subscriber signals demand.- Parameters:
key
- must not be null.options
- must not be null. UseScanOptions.NONE
instead.- Returns:
- the
Flux
emitting the values one by one or anempty Flux
if the key does not exist. - Throws:
IllegalArgumentException
- when one of the required arguments is null.- Since:
- 2.1
- See Also:
-
randomMember
Get random element from set atkey
.- Parameters:
key
- must not be null.- Returns:
- See Also:
-
distinctRandomMembers
Getcount
distinct random elements from set atkey
.- Parameters:
key
- must not be null.count
- number of members to return.- Returns:
- See Also:
-
randomMembers
Getcount
random elements from set atkey
.- Parameters:
key
- must not be null.count
- number of members to return.- Returns:
- See Also:
-
delete
Removes the given key.- Parameters:
key
- must not be null.
-