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

Method Details

sAdd

default reactor.core.publisher.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 reactor.core.publisher.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

reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SAddCommand,Long>> sAdd(org.reactivestreams.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 reactor.core.publisher.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 reactor.core.publisher.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

reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SRemCommand,Long>> sRem(org.reactivestreams.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 reactor.core.publisher.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 reactor.core.publisher.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

reactor.core.publisher.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

reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveRedisConnection.KeyCommand>> sPop(org.reactivestreams.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 reactor.core.publisher.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

reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveSetCommands.SMoveCommand>> sMove(org.reactivestreams.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 reactor.core.publisher.Mono<Long> sCard(ByteBuffer key)

Get size of set at key.

Parameters:

key - must not be null.

Returns:

See Also:

• Redis Documentation: SCARD

sCard

reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>> sCard(org.reactivestreams.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 reactor.core.publisher.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

reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveSetCommands.SIsMemberCommand>> sIsMember(org.reactivestreams.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 reactor.core.publisher.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

reactor.core.publisher.Flux<ReactiveRedisConnection.MultiValueResponse<ReactiveSetCommands.SMIsMemberCommand,Boolean>> sMIsMember(org.reactivestreams.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 reactor.core.publisher.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

reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveSetCommands.SInterCommand,reactor.core.publisher.Flux<ByteBuffer>>> sInter(org.reactivestreams.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 reactor.core.publisher.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

reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SInterStoreCommand,Long>> sInterStore(org.reactivestreams.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 reactor.core.publisher.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

reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveSetCommands.SUnionCommand,reactor.core.publisher.Flux<ByteBuffer>>> sUnion(org.reactivestreams.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 reactor.core.publisher.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

reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SUnionStoreCommand,Long>> sUnionStore(org.reactivestreams.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 reactor.core.publisher.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

reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveSetCommands.SDiffCommand,reactor.core.publisher.Flux<ByteBuffer>>> sDiff(org.reactivestreams.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 reactor.core.publisher.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

reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SDiffStoreCommand,Long>> sDiffStore(org.reactivestreams.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 reactor.core.publisher.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

reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,reactor.core.publisher.Flux<ByteBuffer>>> sMembers(org.reactivestreams.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 reactor.core.publisher.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 reactor.core.publisher.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

reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,reactor.core.publisher.Flux<ByteBuffer>>> sScan(org.reactivestreams.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 reactor.core.publisher.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 reactor.core.publisher.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

reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveSetCommands.SRandMembersCommand,reactor.core.publisher.Flux<ByteBuffer>>> sRandMember(org.reactivestreams.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