Package org.springframework.data.redis.connection

Interface ReactiveSetCommands

All Known Subinterfaces:

ReactiveClusterSetCommands

public interface ReactiveSetCommands

Redis Set commands executed using reactive infrastructure.

Since:

2.0

Author:

Christoph Strobl, Mark Paluch

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	ReactiveSetCommands.SAddCommand	SADD command parameters.
static class	ReactiveSetCommands.SDiffCommand	SDIFF command parameters.
static class	ReactiveSetCommands.SDiffStoreCommand	SDIFFSTORE command parameters.
static class	ReactiveSetCommands.SInterCommand	SINTER command parameters.
static class	ReactiveSetCommands.SInterStoreCommand	SINTERSTORE command parameters.
static class	ReactiveSetCommands.SIsMemberCommand	SISMEMBER command parameters.
static class	ReactiveSetCommands.SMIsMemberCommand	SMISMEMBER command parameters.
static class	ReactiveSetCommands.SMoveCommand	SMOVE command parameters.
static class	ReactiveSetCommands.SPopCommand	SPOP command parameters.
static class	ReactiveSetCommands.SRandMembersCommand	SRANDMEMBER command parameters.
static class	ReactiveSetCommands.SRemCommand	SREM command parameters.
static class	ReactiveSetCommands.SUnionCommand	SUNION command parameters.
static class	ReactiveSetCommands.SUnionStoreCommand	SUNIONSTORE command parameters.

Method Summary

Modifier and Type	Method	Description
default Mono<Long>	sAdd(ByteBuffer key, ByteBuffer value)	Add given value to set at key.
default Mono<Long>	sAdd(ByteBuffer key, Collection<ByteBuffer> values)	Add given values to set at key.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SAddCommand,Long>>	sAdd(Publisher<ReactiveSetCommands.SAddCommand> commands)	Add given ReactiveSetCommands.SAddCommand.getValues() to set at ReactiveRedisConnection.KeyCommand.getKey().
default Mono<Long>	sCard(ByteBuffer key)	Get size of set at key.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>>	sCard(Publisher<ReactiveRedisConnection.KeyCommand> commands)	Get size of set at ReactiveRedisConnection.KeyCommand.getKey().
default Flux<ByteBuffer>	sDiff(Collection<ByteBuffer> keys)	Returns the diff of the members of all given sets at keys.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveSetCommands.SDiffCommand,Flux<ByteBuffer>>>	sDiff(Publisher<ReactiveSetCommands.SDiffCommand> commands)	Returns the diff of the members of all given sets at ReactiveSetCommands.SInterCommand.getKeys().
default Mono<Long>	sDiffStore(ByteBuffer destinationKey, Collection<ByteBuffer> keys)	Diff all given sets at keys and store result in destinationKey.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SDiffStoreCommand,Long>>	sDiffStore(Publisher<ReactiveSetCommands.SDiffStoreCommand> commands)	Diff all given sets at keys and store result in destinationKey.
default Flux<ByteBuffer>	sInter(Collection<ByteBuffer> keys)	Returns the members intersecting all given sets at keys.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveSetCommands.SInterCommand,Flux<ByteBuffer>>>	sInter(Publisher<ReactiveSetCommands.SInterCommand> commands)	Returns the members intersecting all given sets at ReactiveSetCommands.SInterCommand.getKeys().
default Mono<Long>	sInterStore(ByteBuffer destinationKey, Collection<ByteBuffer> keys)	Intersect all given sets at keys and store result in destinationKey.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SInterStoreCommand,Long>>	sInterStore(Publisher<ReactiveSetCommands.SInterStoreCommand> commands)	Intersect all given sets at keys and store result in destinationKey.
default Mono<Boolean>	sIsMember(ByteBuffer key, ByteBuffer value)	Check if set at key contains value.
Flux<ReactiveRedisConnection.BooleanResponse<ReactiveSetCommands.SIsMemberCommand>>	sIsMember(Publisher<ReactiveSetCommands.SIsMemberCommand> commands)	Check if set at ReactiveRedisConnection.KeyCommand.getKey() contains ReactiveSetCommands.SIsMemberCommand.getValue().
default Flux<ByteBuffer>	sMembers(ByteBuffer key)	Get all elements of set at key.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,Flux<ByteBuffer>>>	sMembers(Publisher<ReactiveRedisConnection.KeyCommand> commands)	Get all elements of set at ReactiveRedisConnection.KeyCommand.getKey().
default Mono<List<Boolean>>	sMIsMember(ByteBuffer key, List<ByteBuffer> values)	Check if set at key contains one or more values.
Flux<ReactiveRedisConnection.MultiValueResponse<ReactiveSetCommands.SMIsMemberCommand,Boolean>>	sMIsMember(Publisher<ReactiveSetCommands.SMIsMemberCommand> commands)	Check if set at ReactiveRedisConnection.KeyCommand.getKey() contains ReactiveSetCommands.SMIsMemberCommand.getValues().
default Mono<Boolean>	sMove(ByteBuffer sourceKey, ByteBuffer destinationKey, ByteBuffer value)	Move value from sourceKey to destinationKey
Flux<ReactiveRedisConnection.BooleanResponse<ReactiveSetCommands.SMoveCommand>>	sMove(Publisher<ReactiveSetCommands.SMoveCommand> commands)	Move ReactiveSetCommands.SMoveCommand.getValue() from ReactiveRedisConnection.KeyCommand.getKey() to ReactiveSetCommands.SMoveCommand.getDestination().
default Mono<ByteBuffer>	sPop(ByteBuffer key)	Remove and return a random member from set at key.
default Flux<ByteBuffer>	sPop(ByteBuffer key, long count)	Remove and return count random members from set at key.
Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveRedisConnection.KeyCommand>>	sPop(Publisher<ReactiveRedisConnection.KeyCommand> commands)	Remove and return a random member from set at ReactiveRedisConnection.KeyCommand.getKey()
Flux<ByteBuffer>	sPop(ReactiveSetCommands.SPopCommand command)	Remove and return a random member from set at key.
default Mono<ByteBuffer>	sRandMember(ByteBuffer key)	Get random element from set at key.
default Flux<ByteBuffer>	sRandMember(ByteBuffer key, Long count)	Get count random elements from set at key.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveSetCommands.SRandMembersCommand,Flux<ByteBuffer>>>	sRandMember(Publisher<ReactiveSetCommands.SRandMembersCommand> commands)	Get ReactiveSetCommands.SRandMembersCommand.getCount() random elements from set at ReactiveRedisConnection.KeyCommand.getKey().
default Mono<Long>	sRem(ByteBuffer key, ByteBuffer value)	Remove given value from set at key and return the number of removed elements.
default Mono<Long>	sRem(ByteBuffer key, Collection<ByteBuffer> values)	Remove given values from set at key and return the number of removed elements.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SRemCommand,Long>>	sRem(Publisher<ReactiveSetCommands.SRemCommand> commands)	Remove given ReactiveSetCommands.SRemCommand.getValues() from set at ReactiveRedisConnection.KeyCommand.getKey().
default Flux<ByteBuffer>	sScan(ByteBuffer key)	Use a Flux to iterate over members in the set at key.
default Flux<ByteBuffer>	sScan(ByteBuffer key, ScanOptions options)	Use a Flux to iterate over members in the set at key given ScanOptions.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,Flux<ByteBuffer>>>	sScan(Publisher<ReactiveRedisConnection.KeyScanCommand> commands)	Use a Flux to iterate over members in the set at key.
default Flux<ByteBuffer>	sUnion(Collection<ByteBuffer> keys)	Returns the members intersecting all given sets at keys.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveSetCommands.SUnionCommand,Flux<ByteBuffer>>>	sUnion(Publisher<ReactiveSetCommands.SUnionCommand> commands)	Returns the members intersecting all given sets at ReactiveSetCommands.SInterCommand.getKeys().
default Mono<Long>	sUnionStore(ByteBuffer destinationKey, Collection<ByteBuffer> keys)	Union all given sets at keys and store result in destinationKey.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SUnionStoreCommand,Long>>	sUnionStore(Publisher<ReactiveSetCommands.SUnionStoreCommand> commands)	Union all given sets at keys and store result in destinationKey.

Method Details

sAdd

default Mono<Long> sAdd(ByteBuffer key,
 ByteBuffer value)

Add given value to set at key.

Parameters:

key - must not be null.

value - must not be null.

Returns:

See Also:

• Redis Documentation: SADD

sAdd

default Mono<Long> sAdd(ByteBuffer key,
 Collection<ByteBuffer> values)

Add given values to set at key.

Parameters:

key - must not be null.

values - must not be null.

Returns:

See Also:

• Redis Documentation: SADD

sAdd

Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SAddCommand,Long>> sAdd(Publisher<ReactiveSetCommands.SAddCommand> commands)

Add given ReactiveSetCommands.SAddCommand.getValues() to set at ReactiveRedisConnection.KeyCommand.getKey().

Parameters:

commands - must not be null.

Returns:

See Also:

• Redis Documentation: SADD

sRem

default Mono<Long> sRem(ByteBuffer key,
 ByteBuffer value)

Remove given value from set at key and return the number of removed elements.

Parameters:

key - must not be null.

value - must not be null.

Returns:

See Also:

• Redis Documentation: SREM

sRem

default Mono<Long> sRem(ByteBuffer key,
 Collection<ByteBuffer> values)

Remove given values from set at key and return the number of removed elements.

Parameters:

key - must not be null.

values - must not be null.

Returns:

See Also:

• Redis Documentation: SREM

sRem

Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SRemCommand,Long>> sRem(Publisher<ReactiveSetCommands.SRemCommand> commands)

Remove given ReactiveSetCommands.SRemCommand.getValues() from set at ReactiveRedisConnection.KeyCommand.getKey().

Parameters:

commands - must not be null.

Returns:

See Also:

• Redis Documentation: SREM

sPop

default Mono<ByteBuffer> sPop(ByteBuffer key)

Remove and return a random member from set at key.

Parameters:

key - must not be null.

Returns:

See Also:

• Redis Documentation: SPOP

sPop

default Flux<ByteBuffer> sPop(ByteBuffer key,
 long count)

Remove and return count random members from set at key.

Parameters:

key - must not be null.

count - number of random members to pop from the set.

Returns:

See Also:

• Redis Documentation: SPOP

sPop

Flux<ByteBuffer> sPop(ReactiveSetCommands.SPopCommand command)

Remove and return a random member from set at key.

Parameters:

command - must not be null.

Returns:

See Also:

• Redis Documentation: SPOP

sPop

Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveRedisConnection.KeyCommand>> sPop(Publisher<ReactiveRedisConnection.KeyCommand> commands)

Remove and return a random member from set at ReactiveRedisConnection.KeyCommand.getKey()

Parameters:

commands -

Returns:

See Also:

• Redis Documentation: SPOP

sMove

default Mono<Boolean> sMove(ByteBuffer sourceKey,
 ByteBuffer destinationKey,
 ByteBuffer value)

Move value from sourceKey to destinationKey

Parameters:

sourceKey - must not be null.

destinationKey - must not be null.

value - must not be null.

Returns:

See Also:

• Redis Documentation: SMOVE

sMove

Flux<ReactiveRedisConnection.BooleanResponse<ReactiveSetCommands.SMoveCommand>> sMove(Publisher<ReactiveSetCommands.SMoveCommand> commands)

Move ReactiveSetCommands.SMoveCommand.getValue() from ReactiveRedisConnection.KeyCommand.getKey() to ReactiveSetCommands.SMoveCommand.getDestination().

Parameters:

commands - must not be null.

Returns:

See Also:

• Redis Documentation: SMOVE

sCard

default Mono<Long> sCard(ByteBuffer key)

Get size of set at key.

Parameters:

key - must not be null.

Returns:

See Also:

• Redis Documentation: SCARD

sCard

Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>> sCard(Publisher<ReactiveRedisConnection.KeyCommand> commands)

Get size of set at ReactiveRedisConnection.KeyCommand.getKey().

Parameters:

commands - must not be null.

Returns:

See Also:

• Redis Documentation: SCARD

sIsMember

default Mono<Boolean> sIsMember(ByteBuffer key,
 ByteBuffer value)

Check if set at key contains value.

Parameters:

key - must not be null.

value - must not be null.

Returns:

See Also:

• Redis Documentation: SISMEMBER

sIsMember

Flux<ReactiveRedisConnection.BooleanResponse<ReactiveSetCommands.SIsMemberCommand>> sIsMember(Publisher<ReactiveSetCommands.SIsMemberCommand> commands)

Check if set at ReactiveRedisConnection.KeyCommand.getKey() contains ReactiveSetCommands.SIsMemberCommand.getValue().

Parameters:

commands - must not be null.

Returns:

See Also:

• Redis Documentation: SISMEMBER

sMIsMember

default Mono<List<Boolean>> sMIsMember(ByteBuffer key,
 List<ByteBuffer> values)

Check if set at key contains one or more values.

Parameters:

key - must not be null.

values - must not be null.

Returns:

null when used in pipeline / transaction.

Since:

2.6

See Also:

• Redis Documentation: SMISMEMBER

sMIsMember

Flux<ReactiveRedisConnection.MultiValueResponse<ReactiveSetCommands.SMIsMemberCommand,Boolean>> sMIsMember(Publisher<ReactiveSetCommands.SMIsMemberCommand> commands)

Check if set at ReactiveRedisConnection.KeyCommand.getKey() contains ReactiveSetCommands.SMIsMemberCommand.getValues().

Parameters:

commands - must not be null.

Returns:

Since:

2.6

See Also:

• Redis Documentation: SMISMEMBER

sInter

default Flux<ByteBuffer> sInter(Collection<ByteBuffer> keys)

Returns the members intersecting all given sets at keys.

Parameters:

keys - must not be null.

Returns:

See Also:

• Redis Documentation: SINTER

sInter

Flux<ReactiveRedisConnection.CommandResponse<ReactiveSetCommands.SInterCommand,Flux<ByteBuffer>>> sInter(Publisher<ReactiveSetCommands.SInterCommand> commands)

Returns the members intersecting all given sets at ReactiveSetCommands.SInterCommand.getKeys().

Parameters:

commands - must not be null.

Returns:

See Also:

• Redis Documentation: SINTER

sInterStore

default Mono<Long> sInterStore(ByteBuffer destinationKey,
 Collection<ByteBuffer> keys)

Intersect all given sets at keys and store result in destinationKey.

Parameters:

destinationKey - must not be null.

keys - must not be null.

Returns:

size of set stored a destinationKey.

See Also:

• Redis Documentation: SINTERSTORE

sInterStore

Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SInterStoreCommand,Long>> sInterStore(Publisher<ReactiveSetCommands.SInterStoreCommand> commands)

Intersect all given sets at keys and store result in destinationKey.

Parameters:

commands - must not be null.

Returns:

See Also:

• Redis Documentation: SINTERSTORE

sUnion

default Flux<ByteBuffer> sUnion(Collection<ByteBuffer> keys)

Returns the members intersecting all given sets at keys.

Parameters:

keys - must not be null.

Returns:

See Also:

• Redis Documentation: SUNION

sUnion

Flux<ReactiveRedisConnection.CommandResponse<ReactiveSetCommands.SUnionCommand,Flux<ByteBuffer>>> sUnion(Publisher<ReactiveSetCommands.SUnionCommand> commands)

Returns the members intersecting all given sets at ReactiveSetCommands.SInterCommand.getKeys().

Parameters:

commands - must not be null.

Returns:

See Also:

• Redis Documentation: SUNION

sUnionStore

default Mono<Long> sUnionStore(ByteBuffer destinationKey,
 Collection<ByteBuffer> keys)

Union all given sets at keys and store result in destinationKey.

Parameters:

destinationKey - must not be null.

keys - must not be null.

Returns:

size of set stored a destinationKey.

See Also:

• Redis Documentation: SUNIONSTORE

sUnionStore

Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SUnionStoreCommand,Long>> sUnionStore(Publisher<ReactiveSetCommands.SUnionStoreCommand> commands)

Union all given sets at keys and store result in destinationKey.

Parameters:

commands - must not be null.

Returns:

See Also:

• Redis Documentation: SUNIONSTORE

sDiff

default Flux<ByteBuffer> sDiff(Collection<ByteBuffer> keys)

Returns the diff of the members of all given sets at keys.

Parameters:

keys - must not be null.

Returns:

See Also:

• Redis Documentation: SDIFF

sDiff

Flux<ReactiveRedisConnection.CommandResponse<ReactiveSetCommands.SDiffCommand,Flux<ByteBuffer>>> sDiff(Publisher<ReactiveSetCommands.SDiffCommand> commands)

Returns the diff of the members of all given sets at ReactiveSetCommands.SInterCommand.getKeys().

Parameters:

commands - must not be null.

Returns:

See Also:

• Redis Documentation: SDIFF

sDiffStore

default Mono<Long> sDiffStore(ByteBuffer destinationKey,
 Collection<ByteBuffer> keys)

Diff all given sets at keys and store result in destinationKey.

Parameters:

destinationKey - must not be null.

keys - must not be null.

Returns:

size of set stored a destinationKey.

See Also:

• Redis Documentation: SDIFFSTORE

sDiffStore

Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SDiffStoreCommand,Long>> sDiffStore(Publisher<ReactiveSetCommands.SDiffStoreCommand> commands)

Diff all given sets at keys and store result in destinationKey.

Parameters:

commands - must not be null.

Returns:

See Also:

• Redis Documentation: SDIFFSTORE

sMembers

default Flux<ByteBuffer> sMembers(ByteBuffer key)

Get all elements of set at key.

Parameters:

key - must not be null.

Returns:

See Also:

• Redis Documentation: SMEMBERS

sMembers

Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,Flux<ByteBuffer>>> sMembers(Publisher<ReactiveRedisConnection.KeyCommand> commands)

Get all elements of set at ReactiveRedisConnection.KeyCommand.getKey().

Parameters:

commands - must not be null.

Returns:

See Also:

• Redis Documentation: SMEMBERS

sScan

default Flux<ByteBuffer> sScan(ByteBuffer key)

Use a Flux to iterate over members in the set at key. The resulting Flux acts as a cursor and issues SSCAN commands itself as long as the subscriber signals demand.

Parameters:

key - must not be null.

Returns:

the Flux emitting the raw members one by one.

Throws:

IllegalArgumentException - when options is null.

Since:

2.1

See Also:

• Redis Documentation: SSCAN

sScan

default Flux<ByteBuffer> sScan(ByteBuffer key,
 ScanOptions options)

Use a Flux to iterate over members in the set at key given ScanOptions. The resulting Flux acts as a cursor and issues SSCAN commands itself as long as the subscriber signals demand.

Parameters:

key - must not be null.

options - must not be null. Use ScanOptions.NONE instead.

Returns:

the Flux emitting the raw members one by one.

Throws:

IllegalArgumentException - when one of the required arguments is null.

Since:

2.1

See Also:

• Redis Documentation: SSCAN

sScan

Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,Flux<ByteBuffer>>> sScan(Publisher<ReactiveRedisConnection.KeyScanCommand> commands)

Use a Flux to iterate over members in the set at key. The resulting Flux acts as a cursor and issues SSCAN commands itself as long as the subscriber signals demand.

Parameters:

commands - must not be null.

Returns:

Since:

2.1

See Also:

• Redis Documentation: SSCAN

sRandMember

default Mono<ByteBuffer> sRandMember(ByteBuffer key)

Get random element from set at key.

Parameters:

key - must not be null.

Returns:

See Also:

• Redis Documentation: SRANDMEMBER

sRandMember

default Flux<ByteBuffer> sRandMember(ByteBuffer key,
 Long count)

Get count random elements from set at key.

Parameters:

key - must not be null.

count - must not be null.

Returns:

See Also:

• Redis Documentation: SRANDMEMBER

sRandMember

Flux<ReactiveRedisConnection.CommandResponse<ReactiveSetCommands.SRandMembersCommand,Flux<ByteBuffer>>> sRandMember(Publisher<ReactiveSetCommands.SRandMembersCommand> commands)

Get ReactiveSetCommands.SRandMembersCommand.getCount() random elements from set at ReactiveRedisConnection.KeyCommand.getKey().

Parameters:

commands - must not be null.

Returns:

See Also:

• Redis Documentation: SRANDMEMBER