public interface ReactiveSetCommands
Modifier and Type | Interface and 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.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. |
Modifier and Type | Method and 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 ReactiveRedisConnection.KeyCommand.getKey() . |
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<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)
|
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)
|
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.
|
default reactor.core.publisher.Mono<Long> sAdd(ByteBuffer key, ByteBuffer value)
key
- must not be null.value
- must not be null.default reactor.core.publisher.Mono<Long> sAdd(ByteBuffer key, Collection<ByteBuffer> values)
key
- must not be null.values
- must not be null.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SAddCommand,Long>> sAdd(org.reactivestreams.Publisher<ReactiveSetCommands.SAddCommand> commands)
ReactiveSetCommands.SAddCommand.getValues()
to set at ReactiveRedisConnection.KeyCommand.getKey()
.commands
- must not be null.default reactor.core.publisher.Mono<Long> sRem(ByteBuffer key, ByteBuffer value)
key
- must not be null.value
- must not be null.default reactor.core.publisher.Mono<Long> sRem(ByteBuffer key, Collection<ByteBuffer> values)
key
- must not be null.values
- must not be null.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SRemCommand,Long>> sRem(org.reactivestreams.Publisher<ReactiveSetCommands.SRemCommand> commands)
ReactiveSetCommands.SRemCommand.getValues()
from set at ReactiveRedisConnection.KeyCommand.getKey()
.commands
- must not be null.default reactor.core.publisher.Mono<ByteBuffer> sPop(ByteBuffer key)
key
- must not be null.default reactor.core.publisher.Flux<ByteBuffer> sPop(ByteBuffer key, long count)
count
random members from set at key
.key
- must not be null.count
- number of random members to pop from the set.reactor.core.publisher.Flux<ByteBuffer> sPop(ReactiveSetCommands.SPopCommand command)
command
- must not be null.reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveRedisConnection.KeyCommand>> sPop(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands)
ReactiveRedisConnection.KeyCommand.getKey()
commands
- default reactor.core.publisher.Mono<Boolean> sMove(ByteBuffer sourceKey, ByteBuffer destinationKey, ByteBuffer value)
sourceKey
- must not be null.destinationKey
- must not be null.value
- must not be null.reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveSetCommands.SMoveCommand>> sMove(org.reactivestreams.Publisher<ReactiveSetCommands.SMoveCommand> commands)
ReactiveSetCommands.SMoveCommand.getValue()
from ReactiveRedisConnection.KeyCommand.getKey()
to ReactiveSetCommands.SMoveCommand.getDestination()
.commands
- must not be null.default reactor.core.publisher.Mono<Long> sCard(ByteBuffer key)
key
- must not be null.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>> sCard(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands)
ReactiveRedisConnection.KeyCommand.getKey()
.commands
- must not be null.default reactor.core.publisher.Mono<Boolean> sIsMember(ByteBuffer key, ByteBuffer value)
key
- must not be null.value
- must not be null.reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveSetCommands.SIsMemberCommand>> sIsMember(org.reactivestreams.Publisher<ReactiveSetCommands.SIsMemberCommand> commands)
ReactiveRedisConnection.KeyCommand.getKey()
contains ReactiveRedisConnection.KeyCommand.getKey()
.commands
- must not be null.default reactor.core.publisher.Flux<ByteBuffer> sInter(Collection<ByteBuffer> keys)
keys
- must not be null.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveSetCommands.SInterCommand,reactor.core.publisher.Flux<ByteBuffer>>> sInter(org.reactivestreams.Publisher<ReactiveSetCommands.SInterCommand> commands)
ReactiveSetCommands.SInterCommand.getKeys()
.commands
- must not be null.default reactor.core.publisher.Mono<Long> sInterStore(ByteBuffer destinationKey, Collection<ByteBuffer> keys)
destinationKey
- must not be null.keys
- must not be null.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SInterStoreCommand,Long>> sInterStore(org.reactivestreams.Publisher<ReactiveSetCommands.SInterStoreCommand> commands)
commands
- must not be null.default reactor.core.publisher.Flux<ByteBuffer> sUnion(Collection<ByteBuffer> keys)
keys
- must not be null.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveSetCommands.SUnionCommand,reactor.core.publisher.Flux<ByteBuffer>>> sUnion(org.reactivestreams.Publisher<ReactiveSetCommands.SUnionCommand> commands)
ReactiveSetCommands.SInterCommand.getKeys()
.commands
- must not be null.default reactor.core.publisher.Mono<Long> sUnionStore(ByteBuffer destinationKey, Collection<ByteBuffer> keys)
destinationKey
- must not be null.keys
- must not be null.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SUnionStoreCommand,Long>> sUnionStore(org.reactivestreams.Publisher<ReactiveSetCommands.SUnionStoreCommand> commands)
commands
- must not be null.default reactor.core.publisher.Flux<ByteBuffer> sDiff(Collection<ByteBuffer> keys)
keys
- must not be null.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveSetCommands.SDiffCommand,reactor.core.publisher.Flux<ByteBuffer>>> sDiff(org.reactivestreams.Publisher<ReactiveSetCommands.SDiffCommand> commands)
ReactiveSetCommands.SInterCommand.getKeys()
.commands
- must not be null.default reactor.core.publisher.Mono<Long> sDiffStore(ByteBuffer destinationKey, Collection<ByteBuffer> keys)
destinationKey
- must not be null.keys
- must not be null.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SDiffStoreCommand,Long>> sDiffStore(org.reactivestreams.Publisher<ReactiveSetCommands.SDiffStoreCommand> commands)
commands
- must not be null.default reactor.core.publisher.Flux<ByteBuffer> sMembers(ByteBuffer key)
key
- must not be null.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,reactor.core.publisher.Flux<ByteBuffer>>> sMembers(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands)
ReactiveRedisConnection.KeyCommand.getKey()
.commands
- must not be null.default reactor.core.publisher.Flux<ByteBuffer> sScan(ByteBuffer key)
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.key
- must not be null.Flux
emitting the raw members
one by one.IllegalArgumentException
- when options is null.default reactor.core.publisher.Flux<ByteBuffer> sScan(ByteBuffer key, ScanOptions options)
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.key
- must not be null.options
- must not be null. Use ScanOptions.NONE
instead.Flux
emitting the raw members
one by one.IllegalArgumentException
- when one of the required arguments is null.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,reactor.core.publisher.Flux<ByteBuffer>>> sScan(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyScanCommand> commands)
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.commands
- must not be null.default reactor.core.publisher.Mono<ByteBuffer> sRandMember(ByteBuffer key)
key
- must not be null.default reactor.core.publisher.Flux<ByteBuffer> sRandMember(ByteBuffer key, Long count)
key
- must not be null.count
- must not be null.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveSetCommands.SRandMembersCommand,reactor.core.publisher.Flux<ByteBuffer>>> sRandMember(org.reactivestreams.Publisher<ReactiveSetCommands.SRandMembersCommand> commands)
ReactiveSetCommands.SRandMembersCommand.getCount()
random elements from set at ReactiveRedisConnection.KeyCommand.getKey()
.commands
- must not be null.Copyright © 2011–2019 Pivotal Software, Inc.. All rights reserved.