K
- Key type.V
- Value type.public interface RedisSetReactiveCommands<K,V>
Modifier and Type | Method and Description |
---|---|
Mono<Long> |
sadd(K key,
V... members)
Add one or more members to a set.
|
Mono<Long> |
scard(K key)
Get the number of members in a set.
|
Flux<V> |
sdiff(K... keys)
Subtract multiple sets.
|
Mono<Long> |
sdiff(ValueStreamingChannel<V> channel,
K... keys)
Subtract multiple sets.
|
Mono<Long> |
sdiffstore(K destination,
K... keys)
Subtract multiple sets and store the resulting set in a key.
|
Flux<V> |
sinter(K... keys)
Intersect multiple sets.
|
Mono<Long> |
sinter(ValueStreamingChannel<V> channel,
K... keys)
Intersect multiple sets.
|
Mono<Long> |
sinterstore(K destination,
K... keys)
Intersect multiple sets and store the resulting set in a key.
|
Mono<Boolean> |
sismember(K key,
V member)
Determine if a given value is a member of a set.
|
Flux<V> |
smembers(K key)
Get all the members in a set.
|
Mono<Long> |
smembers(ValueStreamingChannel<V> channel,
K key)
Get all the members in a set.
|
Mono<Boolean> |
smove(K source,
K destination,
V member)
Move a member from one set to another.
|
Mono<V> |
spop(K key)
Remove and return a random member from a set.
|
Flux<V> |
spop(K key,
long count)
Remove and return one or multiple random members from a set.
|
Mono<V> |
srandmember(K key)
Get one random member from a set.
|
Flux<V> |
srandmember(K key,
long count)
Get one or multiple random members from a set.
|
Mono<Long> |
srandmember(ValueStreamingChannel<V> channel,
K key,
long count)
Get one or multiple random members from a set.
|
Mono<Long> |
srem(K key,
V... members)
Remove one or more members from a set.
|
Mono<ValueScanCursor<V>> |
sscan(K key)
Incrementally iterate Set elements.
|
Mono<ValueScanCursor<V>> |
sscan(K key,
ScanArgs scanArgs)
Incrementally iterate Set elements.
|
Mono<ValueScanCursor<V>> |
sscan(K key,
ScanCursor scanCursor)
Incrementally iterate Set elements.
|
Mono<ValueScanCursor<V>> |
sscan(K key,
ScanCursor scanCursor,
ScanArgs scanArgs)
Incrementally iterate Set elements.
|
Mono<StreamScanCursor> |
sscan(ValueStreamingChannel<V> channel,
K key)
Incrementally iterate Set elements.
|
Mono<StreamScanCursor> |
sscan(ValueStreamingChannel<V> channel,
K key,
ScanArgs scanArgs)
Incrementally iterate Set elements.
|
Mono<StreamScanCursor> |
sscan(ValueStreamingChannel<V> channel,
K key,
ScanCursor scanCursor)
Incrementally iterate Set elements.
|
Mono<StreamScanCursor> |
sscan(ValueStreamingChannel<V> channel,
K key,
ScanCursor scanCursor,
ScanArgs scanArgs)
Incrementally iterate Set elements.
|
Flux<V> |
sunion(K... keys)
Add multiple sets.
|
Mono<Long> |
sunion(ValueStreamingChannel<V> channel,
K... keys)
Add multiple sets.
|
Mono<Long> |
sunionstore(K destination,
K... keys)
Add multiple sets and store the resulting set in a key.
|
Mono<Long> sadd(K key, V... members)
key
- the keymembers
- the member type: valueMono<Long> scard(K key)
key
- the keykey
does not
exist.Flux<V> sdiff(K... keys)
keys
- the keyMono<Long> sdiff(ValueStreamingChannel<V> channel, K... keys)
channel
- the channelkeys
- the keysMono<Long> sdiffstore(K destination, K... keys)
destination
- the destination type: keykeys
- the keyFlux<V> sinter(K... keys)
keys
- the keyMono<Long> sinter(ValueStreamingChannel<V> channel, K... keys)
channel
- the channelkeys
- the keysMono<Long> sinterstore(K destination, K... keys)
destination
- the destination type: keykeys
- the keyMono<Boolean> sismember(K key, V member)
key
- the keymember
- the member type: valuekey
does not exist.Mono<Boolean> smove(K source, K destination, V member)
source
- the source keydestination
- the destination type: keymember
- the member type: valuesource
and no
operation was performed.Flux<V> smembers(K key)
key
- the keyMono<Long> smembers(ValueStreamingChannel<V> channel, K key)
channel
- the channelkey
- the keysMono<V> spop(K key)
key
- the keykey
does not exist.Flux<V> spop(K key, long count)
key
- the keycount
- number of members to popkey
does not exist.Mono<V> srandmember(K key)
key
- the keycount
argument the command returns a Bulk Reply with the
randomly selected element, or null when key
does not exist.Flux<V> srandmember(K key, long count)
key
- the keycount
- the count type: longcount
argument the command returns a Bulk Reply
with the randomly selected element, or null when key
does not exist.Mono<Long> srandmember(ValueStreamingChannel<V> channel, K key, long count)
channel
- streaming channel that receives a call for every valuekey
- the keycount
- the countMono<Long> srem(K key, V... members)
key
- the keymembers
- the member type: valueFlux<V> sunion(K... keys)
keys
- the keyMono<Long> sunion(ValueStreamingChannel<V> channel, K... keys)
channel
- streaming channel that receives a call for every valuekeys
- the keysMono<Long> sunionstore(K destination, K... keys)
destination
- the destination type: keykeys
- the keyMono<ValueScanCursor<V>> sscan(K key)
key
- the keyMono<ValueScanCursor<V>> sscan(K key, ScanArgs scanArgs)
key
- the keyscanArgs
- scan argumentsMono<ValueScanCursor<V>> sscan(K key, ScanCursor scanCursor, ScanArgs scanArgs)
key
- the keyscanCursor
- cursor to resume from a previous scan, must not be nullscanArgs
- scan argumentsMono<ValueScanCursor<V>> sscan(K key, ScanCursor scanCursor)
key
- the keyscanCursor
- cursor to resume from a previous scan, must not be nullMono<StreamScanCursor> sscan(ValueStreamingChannel<V> channel, K key)
channel
- streaming channel that receives a call for every valuekey
- the keyMono<StreamScanCursor> sscan(ValueStreamingChannel<V> channel, K key, ScanArgs scanArgs)
channel
- streaming channel that receives a call for every valuekey
- the keyscanArgs
- scan argumentsMono<StreamScanCursor> sscan(ValueStreamingChannel<V> channel, K key, ScanCursor scanCursor, ScanArgs scanArgs)
channel
- streaming channel that receives a call for every valuekey
- the keyscanCursor
- cursor to resume from a previous scan, must not be nullscanArgs
- scan argumentsMono<StreamScanCursor> sscan(ValueStreamingChannel<V> channel, K key, ScanCursor scanCursor)
channel
- streaming channel that receives a call for every valuekey
- the keyscanCursor
- cursor to resume from a previous scan, must not be nullCopyright © 2019 lettuce.io. All rights reserved.