io.lettuce.core.api.reactive

Interface RedisSetReactiveCommands<K,V>

Type Parameters:

K - Key type.

V - Value type.

All Known Subinterfaces:

RedisAdvancedClusterReactiveCommands<K,V>, RedisClusterPubSubReactiveCommands<K,V>, RedisClusterReactiveCommands<K,V>, RedisPubSubReactiveCommands<K,V>, RedisReactiveCommands<K,V>

All Known Implementing Classes:

AbstractRedisReactiveCommands, RedisAdvancedClusterReactiveCommandsImpl, RedisClusterPubSubReactiveCommandsImpl, RedisPubSubReactiveCommandsImpl, RedisReactiveCommandsImpl, RedisSentinelReactiveCommandsImpl

public interface RedisSetReactiveCommands<K,V>

Reactive executed commands for Sets.

Since:

4.0

Author:

Mark Paluch

Generated class:

by io.lettuce.apigenerator.CreateReactiveApi

Method Summary

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.

Method Detail

sadd

Mono<Long> sadd(K key,
                V... members)

Add one or more members to a set.

Parameters:

key - the key

members - the member type: value

Returns:

Long integer-reply the number of elements that were added to the set, not including all the elements already present into the set.

scard

Mono<Long> scard(K key)

Get the number of members in a set.

Parameters:

key - the key

Returns:

Long integer-reply the cardinality (number of elements) of the set, or false if key does not exist.

sdiff

Flux<V> sdiff(K... keys)

Subtract multiple sets.

Parameters:

keys - the key

Returns:

V array-reply list with members of the resulting set.

sdiff

Mono<Long> sdiff(ValueStreamingChannel<V> channel,
                 K... keys)

Subtract multiple sets.

Parameters:

channel - the channel

keys - the keys

Returns:

Long count of members of the resulting set.

sdiffstore

Mono<Long> sdiffstore(K destination,
                      K... keys)

Subtract multiple sets and store the resulting set in a key.

Parameters:

destination - the destination type: key

keys - the key

Returns:

Long integer-reply the number of elements in the resulting set.

sinter

Flux<V> sinter(K... keys)

Intersect multiple sets.

Parameters:

keys - the key

Returns:

V array-reply list with members of the resulting set.

sinter

Mono<Long> sinter(ValueStreamingChannel<V> channel,
                  K... keys)

Intersect multiple sets.

Parameters:

channel - the channel

keys - the keys

Returns:

Long count of members of the resulting set.

sinterstore

Mono<Long> sinterstore(K destination,
                       K... keys)

Intersect multiple sets and store the resulting set in a key.

Parameters:

destination - the destination type: key

keys - the key

Returns:

Long integer-reply the number of elements in the resulting set.

sismember

Mono<Boolean> sismember(K key,
                        V member)

Determine if a given value is a member of a set.

Parameters:

key - the key

member - the member type: value

Returns:

Boolean integer-reply specifically: true if the element is a member of the set. false if the element is not a member of the set, or if key does not exist.

smove

Mono<Boolean> smove(K source,
                    K destination,
                    V member)

Move a member from one set to another.

Parameters:

source - the source key

destination - the destination type: key

member - the member type: value

Returns:

Boolean integer-reply specifically: true if the element is moved. false if the element is not a member of source and no operation was performed.

smembers

Flux<V> smembers(K key)

Get all the members in a set.

Parameters:

key - the key

Returns:

V array-reply all elements of the set.

smembers

Mono<Long> smembers(ValueStreamingChannel<V> channel,
                    K key)

Get all the members in a set.

Parameters:

channel - the channel

key - the keys

Returns:

Long count of members of the resulting set.

spop

Mono<V> spop(K key)

Remove and return a random member from a set.

Parameters:

key - the key

Returns:

V bulk-string-reply the removed element, or null when key does not exist.

spop

Flux<V> spop(K key,
             long count)

Remove and return one or multiple random members from a set.

Parameters:

key - the key

count - number of members to pop

Returns:

V bulk-string-reply the removed element, or null when key does not exist.

srandmember

Mono<V> srandmember(K key)

Get one random member from a set.

Parameters:

key - the key

Returns:

V bulk-string-reply without the additional count argument the command returns a Bulk Reply with the randomly selected element, or null when key does not exist.

srandmember

Flux<V> srandmember(K key,
                    long count)

Get one or multiple random members from a set.

Parameters:

key - the key

count - the count type: long

Returns:

V bulk-string-reply without the additional count argument the command returns a Bulk Reply with the randomly selected element, or null when key does not exist.

srandmember

Mono<Long> srandmember(ValueStreamingChannel<V> channel,
                       K key,
                       long count)

Get one or multiple random members from a set.

Parameters:

channel - streaming channel that receives a call for every value

key - the key

count - the count

Returns:

Long count of members of the resulting set.

srem

Mono<Long> srem(K key,
                V... members)

Remove one or more members from a set.

Parameters:

key - the key

members - the member type: value

Returns:

Long integer-reply the number of members that were removed from the set, not including non existing members.

sunion

Flux<V> sunion(K... keys)

Add multiple sets.

Parameters:

keys - the key

Returns:

V array-reply list with members of the resulting set.

sunion

Mono<Long> sunion(ValueStreamingChannel<V> channel,
                  K... keys)

Add multiple sets.

Parameters:

channel - streaming channel that receives a call for every value

keys - the keys

Returns:

Long count of members of the resulting set.

sunionstore

Mono<Long> sunionstore(K destination,
                       K... keys)

Add multiple sets and store the resulting set in a key.

Parameters:

destination - the destination type: key

keys - the key

Returns:

Long integer-reply the number of elements in the resulting set.

sscan

Mono<ValueScanCursor<V>> sscan(K key)

Incrementally iterate Set elements.

Parameters:

key - the key

Returns:

ValueScanCursor<V> scan cursor.

sscan

Mono<ValueScanCursor<V>> sscan(K key,
                               ScanArgs scanArgs)

Incrementally iterate Set elements.

Parameters:

key - the key

scanArgs - scan arguments

Returns:

ValueScanCursor<V> scan cursor.

sscan

Mono<ValueScanCursor<V>> sscan(K key,
                               ScanCursor scanCursor,
                               ScanArgs scanArgs)

Incrementally iterate Set elements.

Parameters:

key - the key

scanCursor - cursor to resume from a previous scan, must not be null

scanArgs - scan arguments

Returns:

ValueScanCursor<V> scan cursor.

sscan

Mono<ValueScanCursor<V>> sscan(K key,
                               ScanCursor scanCursor)

Incrementally iterate Set elements.

Parameters:

key - the key

scanCursor - cursor to resume from a previous scan, must not be null

Returns:

ValueScanCursor<V> scan cursor.

sscan

Mono<StreamScanCursor> sscan(ValueStreamingChannel<V> channel,
                             K key)

Incrementally iterate Set elements.

Parameters:

channel - streaming channel that receives a call for every value

key - the key

Returns:

StreamScanCursor scan cursor.

sscan

Mono<StreamScanCursor> sscan(ValueStreamingChannel<V> channel,
                             K key,
                             ScanArgs scanArgs)

Incrementally iterate Set elements.

Parameters:

channel - streaming channel that receives a call for every value

key - the key

scanArgs - scan arguments

Returns:

StreamScanCursor scan cursor.

sscan

Mono<StreamScanCursor> sscan(ValueStreamingChannel<V> channel,
                             K key,
                             ScanCursor scanCursor,
                             ScanArgs scanArgs)

Incrementally iterate Set elements.

Parameters:

channel - streaming channel that receives a call for every value

key - the key

scanCursor - cursor to resume from a previous scan, must not be null

scanArgs - scan arguments

Returns:

StreamScanCursor scan cursor.

sscan

Mono<StreamScanCursor> sscan(ValueStreamingChannel<V> channel,
                             K key,
                             ScanCursor scanCursor)

Incrementally iterate Set elements.

Parameters:

channel - streaming channel that receives a call for every value

key - the key

scanCursor - cursor to resume from a previous scan, must not be null

Returns:

StreamScanCursor scan cursor.