org.springframework.data.redis.connection

Interface ReactiveZSetCommands

All Known Subinterfaces:

ReactiveClusterZSetCommands

public interface ReactiveZSetCommands

Redis Sorted Set commands executed using reactive infrastructure.

Since:

2.0

Author:

Christoph Strobl, Mark Paluch

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	ReactiveZSetCommands.ZAddCommand ZADD command parameters.
static class	ReactiveZSetCommands.ZCountCommand ZCOUNT command parameters.
static class	ReactiveZSetCommands.ZIncrByCommand ZINCRBY command parameters.
static class	ReactiveZSetCommands.ZInterStoreCommand ZINTERSTORE command parameters.
static class	ReactiveZSetCommands.ZRangeByLexCommand ZRANGEBYLEX/ZREVRANGEBYLEX command parameters.
static class	ReactiveZSetCommands.ZRangeByScoreCommand ZRANGEBYSCORE/ZREVRANGEBYSCORE.
static class	ReactiveZSetCommands.ZRangeCommand ZRANGE/ZREVRANGE command parameters.
static class	ReactiveZSetCommands.ZRankCommand ZRANK/ZREVRANK command parameters.
static class	ReactiveZSetCommands.ZRemCommand ZREM command parameters.
static class	ReactiveZSetCommands.ZRemRangeByRankCommand ZREMRANGEBYRANK command parameters.
static class	ReactiveZSetCommands.ZRemRangeByScoreCommand ZREMRANGEBYSCORE command parameters.
static class	ReactiveZSetCommands.ZScoreCommand ZSCORE command parameters.
static class	ReactiveZSetCommands.ZUnionStoreCommand ZUNIONSTORE command parameters.

Method Summary

Modifier and Type	Method and Description
default reactor.core.publisher.Mono<Long>	zAdd(ByteBuffer key, Collection<? extends RedisZSetCommands.Tuple> tuples) Add a tuples to a sorted set at key, or update their score if it already exists.
default reactor.core.publisher.Mono<Long>	zAdd(ByteBuffer key, Double score, ByteBuffer value) Add value to a sorted set at key, or update its score if it already exists.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZAddCommand,Number>>	zAdd(org.reactivestreams.Publisher<ReactiveZSetCommands.ZAddCommand> commands) Add ReactiveZSetCommands.ZAddCommand.getTuples() to a sorted set at ReactiveRedisConnection.KeyCommand.getKey(), or update its score if it already exists.
default reactor.core.publisher.Mono<Long>	zCard(ByteBuffer key) Get the size of sorted set with key.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>>	zCard(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Get the size of sorted set with ReactiveRedisConnection.KeyCommand.getKey().
default reactor.core.publisher.Mono<Long>	zCount(ByteBuffer key, Range<Double> range) Count number of elements within sorted set with scores within Range.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZCountCommand,Long>>	zCount(org.reactivestreams.Publisher<ReactiveZSetCommands.ZCountCommand> commands) Count number of elements within sorted set with scores within Range.
default reactor.core.publisher.Mono<Double>	zIncrBy(ByteBuffer key, Number increment, ByteBuffer value) Increment the score of element with value in sorted set by increment.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZIncrByCommand,Double>>	zIncrBy(org.reactivestreams.Publisher<ReactiveZSetCommands.ZIncrByCommand> commands) Increment the score of element with ReactiveZSetCommands.ZIncrByCommand.getValue() in sorted set by ReactiveZSetCommands.ZIncrByCommand.getIncrement().
default reactor.core.publisher.Mono<Long>	zInterStore(ByteBuffer destinationKey, List<ByteBuffer> sets) Intersect sorted sets and store result in destination destinationKey.
default reactor.core.publisher.Mono<Long>	zInterStore(ByteBuffer destinationKey, List<ByteBuffer> sets, List<Double> weights) Intersect sorted sets and store result in destination destinationKey and apply weights to individual sets.
default reactor.core.publisher.Mono<Long>	zInterStore(ByteBuffer destinationKey, List<ByteBuffer> sets, List<Double> weights, RedisZSetCommands.Aggregate aggregateFunction) Intersect sorted sets by applying aggregateFunction and store result in destination destinationKey and apply weights to individual sets.
default reactor.core.publisher.Mono<Long>	zInterStore(ByteBuffer destinationKey, List<ByteBuffer> sets, RedisZSetCommands.Weights weights) Intersect sorted sets and store result in destination destinationKey and apply weights to individual sets.
default reactor.core.publisher.Mono<Long>	zInterStore(ByteBuffer destinationKey, List<ByteBuffer> sets, RedisZSetCommands.Weights weights, RedisZSetCommands.Aggregate aggregateFunction) Intersect sorted sets by applying aggregateFunction and store result in destination destinationKey and apply weights to individual sets.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZInterStoreCommand,Long>>	zInterStore(org.reactivestreams.Publisher<ReactiveZSetCommands.ZInterStoreCommand> commands) Intersect sorted sets by applying aggregateFunction and store result in destination destinationKey and apply weights to individual sets.
default reactor.core.publisher.Flux<ByteBuffer>	zRange(ByteBuffer key, Range<Long> range) Get elements in range from sorted set.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZRangeCommand,reactor.core.publisher.Flux<RedisZSetCommands.Tuple>>>	zRange(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRangeCommand> commands) Get set of RedisZSetCommands.Tuples in range from sorted set.
default reactor.core.publisher.Flux<ByteBuffer>	zRangeByLex(ByteBuffer key, Range<String> range) Get all elements in Range from the sorted set at key in lexicographical ordering.
default reactor.core.publisher.Flux<ByteBuffer>	zRangeByLex(ByteBuffer key, Range<String> range, RedisZSetCommands.Limit limit) Get all elements in Range from the sorted set at key in lexicographical ordering.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZRangeByLexCommand,reactor.core.publisher.Flux<ByteBuffer>>>	zRangeByLex(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRangeByLexCommand> commands) Get all elements in Range from the sorted set at key in lexicographical ordering.
default reactor.core.publisher.Flux<ByteBuffer>	zRangeByScore(ByteBuffer key, Range<Double> range) Get elements in range from sorted set.
default reactor.core.publisher.Flux<ByteBuffer>	zRangeByScore(ByteBuffer key, Range<Double> range, RedisZSetCommands.Limit limit) Get elements in range from sorted set.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZRangeByScoreCommand,reactor.core.publisher.Flux<RedisZSetCommands.Tuple>>>	zRangeByScore(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRangeByScoreCommand> commands) Get RedisZSetCommands.Tuples in range from sorted set.
default reactor.core.publisher.Flux<RedisZSetCommands.Tuple>	zRangeByScoreWithScores(ByteBuffer key, Range<Double> range) Get RedisZSetCommands.Tuples in range from sorted set.
default reactor.core.publisher.Flux<RedisZSetCommands.Tuple>	zRangeByScoreWithScores(ByteBuffer key, Range<Double> range, RedisZSetCommands.Limit limit) Get RedisZSetCommands.Tuples in range from sorted set.
default reactor.core.publisher.Flux<RedisZSetCommands.Tuple>	zRangeWithScores(ByteBuffer key, Range<Long> range) Get set of RedisZSetCommands.Tuples in range from sorted set.
default reactor.core.publisher.Mono<Long>	zRank(ByteBuffer key, ByteBuffer value) Determine the index of element with value in a sorted set.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZRankCommand,Long>>	zRank(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRankCommand> commands) Determine the index of element with value in a sorted set when scored by ReactiveZSetCommands.ZRankCommand.getDirection().
default reactor.core.publisher.Mono<Long>	zRem(ByteBuffer key, ByteBuffer value) Remove value from sorted set.
default reactor.core.publisher.Mono<Long>	zRem(ByteBuffer key, Collection<ByteBuffer> values) Remove values from sorted set.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZRemCommand,Long>>	zRem(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRemCommand> commands) Remove ReactiveZSetCommands.ZRemCommand.getValues() from sorted set.
default reactor.core.publisher.Mono<Long>	zRemRangeByRank(ByteBuffer key, Range<Long> range) Remove elements in Range from sorted set with key.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZRemRangeByRankCommand,Long>>	zRemRangeByRank(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRemRangeByRankCommand> commands) Remove elements in Range from sorted set with ReactiveRedisConnection.KeyCommand.getKey().
default reactor.core.publisher.Mono<Long>	zRemRangeByScore(ByteBuffer key, Range<Double> range) Remove elements in Range from sorted set with key.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZRemRangeByScoreCommand,Long>>	zRemRangeByScore(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRemRangeByScoreCommand> commands) Remove elements in Range from sorted set with ReactiveRedisConnection.KeyCommand.getKey().
default reactor.core.publisher.Flux<ByteBuffer>	zRevRange(ByteBuffer key, Range<Long> range) Get elements in range from sorted set in reverse score ordering.
default reactor.core.publisher.Flux<ByteBuffer>	zRevRangeByLex(ByteBuffer key, Range<String> range) Get all elements in Range from the sorted set at key in lexicographical ordering.
default reactor.core.publisher.Flux<ByteBuffer>	zRevRangeByLex(ByteBuffer key, Range<String> range, RedisZSetCommands.Limit limit) Get all elements in Range from the sorted set at key in lexicographical ordering.
default reactor.core.publisher.Flux<ByteBuffer>	zRevRangeByScore(ByteBuffer key, Range<Double> range) Get elements in range from sorted set in reverse score ordering.
default reactor.core.publisher.Flux<ByteBuffer>	zRevRangeByScore(ByteBuffer key, Range<Double> range, RedisZSetCommands.Limit limit) Get elements in range from sorted set in reverse score ordering.
default reactor.core.publisher.Flux<RedisZSetCommands.Tuple>	zRevRangeByScoreWithScores(ByteBuffer key, Range<Double> range) Get set of RedisZSetCommands.Tuples in range from sorted set in reverse score ordering.
default reactor.core.publisher.Flux<RedisZSetCommands.Tuple>	zRevRangeByScoreWithScores(ByteBuffer key, Range<Double> range, RedisZSetCommands.Limit limit) Get RedisZSetCommands.Tuples in range from sorted set in reverse score ordering.
default reactor.core.publisher.Flux<RedisZSetCommands.Tuple>	zRevRangeWithScores(ByteBuffer key, Range<Long> range) Get set of RedisZSetCommands.Tuples in range from sorted set in reverse score ordering.
default reactor.core.publisher.Mono<Long>	zRevRank(ByteBuffer key, ByteBuffer value) Determine the index of element with value in a sorted set when scored high to low.
default reactor.core.publisher.Flux<RedisZSetCommands.Tuple>	zScan(ByteBuffer key) Use a Flux to iterate over members in the sorted set at key.
default reactor.core.publisher.Flux<RedisZSetCommands.Tuple>	zScan(ByteBuffer key, ScanOptions options) Use a Flux to iterate over members in the sorted set at key given ScanOptions.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,reactor.core.publisher.Flux<RedisZSetCommands.Tuple>>>	zScan(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyScanCommand> commands) Use a Flux to iterate over members in the sorted set at key.
default reactor.core.publisher.Mono<Double>	zScore(ByteBuffer key, ByteBuffer value) Get the score of element with value from sorted set with key key.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZScoreCommand,Double>>	zScore(org.reactivestreams.Publisher<ReactiveZSetCommands.ZScoreCommand> commands) Get the score of element with ReactiveZSetCommands.ZScoreCommand.getValue() from sorted set with key ReactiveRedisConnection.KeyCommand.getKey()
default reactor.core.publisher.Mono<Long>	zUnionStore(ByteBuffer destinationKey, List<ByteBuffer> sets) Union sorted sets and store result in destination destinationKey.
default reactor.core.publisher.Mono<Long>	zUnionStore(ByteBuffer destinationKey, List<ByteBuffer> sets, List<Double> weights) Union sorted sets and store result in destination destinationKey and apply weights to individual sets.
default reactor.core.publisher.Mono<Long>	zUnionStore(ByteBuffer destinationKey, List<ByteBuffer> sets, List<Double> weights, RedisZSetCommands.Aggregate aggregateFunction) Union sorted sets by applying aggregateFunction and store result in destination destinationKey and apply weights to individual sets.
default reactor.core.publisher.Mono<Long>	zUnionStore(ByteBuffer destinationKey, List<ByteBuffer> sets, RedisZSetCommands.Weights weights) Union sorted sets and store result in destination destinationKey and apply weights to individual sets.
default reactor.core.publisher.Mono<Long>	zUnionStore(ByteBuffer destinationKey, List<ByteBuffer> sets, RedisZSetCommands.Weights weights, RedisZSetCommands.Aggregate aggregateFunction) Union sorted sets by applying aggregateFunction and store result in destination destinationKey and apply weights to individual sets.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZUnionStoreCommand,Long>>	zUnionStore(org.reactivestreams.Publisher<ReactiveZSetCommands.ZUnionStoreCommand> commands) Union sorted sets by applying aggregateFunction and store result in destination destinationKey and apply weights to individual sets.

Method Detail

zAdd

default reactor.core.publisher.Mono<Long> zAdd(ByteBuffer key,
                                               Double score,
                                               ByteBuffer value)

Add value to a sorted set at key, or update its score if it already exists.

Parameters:

key - must not be null.

score - must not be null.

value - must not be null.

Returns:

See Also:

Redis Documentation: ZADD

zAdd

default reactor.core.publisher.Mono<Long> zAdd(ByteBuffer key,
                                               Collection<? extends RedisZSetCommands.Tuple> tuples)

Add a tuples to a sorted set at key, or update their score if it already exists.

Parameters:

key - must not be null.

tuples - must not be null.

Returns:

See Also:

Redis Documentation: ZADD

zAdd

reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZAddCommand,Number>> zAdd(org.reactivestreams.Publisher<ReactiveZSetCommands.ZAddCommand> commands)

Add ReactiveZSetCommands.ZAddCommand.getTuples() to a sorted set at ReactiveRedisConnection.KeyCommand.getKey(), or update its score if it already exists.

Parameters:

commands - must not be null.

Returns:

See Also:

Redis Documentation: ZADD

zRem

default reactor.core.publisher.Mono<Long> zRem(ByteBuffer key,
                                               ByteBuffer value)

Remove value from sorted set. Return number of removed elements.

Parameters:

key - must not be null.

value - must not be null.

Returns:

See Also:

Redis Documentation: ZREM

zRem

default reactor.core.publisher.Mono<Long> zRem(ByteBuffer key,
                                               Collection<ByteBuffer> values)

Remove values from sorted set. Return number of removed elements.

Parameters:

key - must not be null.

values - must not be null.

Returns:

See Also:

Redis Documentation: ZREM

zRem

reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZRemCommand,Long>> zRem(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRemCommand> commands)

Remove ReactiveZSetCommands.ZRemCommand.getValues() from sorted set. Return number of removed elements.

Parameters:

commands - must not be null.

Returns:

See Also:

Redis Documentation: ZREM

zIncrBy

default reactor.core.publisher.Mono<Double> zIncrBy(ByteBuffer key,
                                                    Number increment,
                                                    ByteBuffer value)

Increment the score of element with value in sorted set by increment.

Parameters:

key - must not be null.

increment - must not be null.

value - must not be null.

Returns:

See Also:

Redis Documentation: ZINCRBY

zIncrBy

reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZIncrByCommand,Double>> zIncrBy(org.reactivestreams.Publisher<ReactiveZSetCommands.ZIncrByCommand> commands)

Increment the score of element with ReactiveZSetCommands.ZIncrByCommand.getValue() in sorted set by ReactiveZSetCommands.ZIncrByCommand.getIncrement().

Parameters:

commands - must not be null.

Returns:

See Also:

Redis Documentation: ZINCRBY

zRank

default reactor.core.publisher.Mono<Long> zRank(ByteBuffer key,
                                                ByteBuffer value)

Determine the index of element with value in a sorted set.

Parameters:

key - must not be null.

value - must not be null.

Returns:

See Also:

Redis Documentation: ZRANK

zRevRank

default reactor.core.publisher.Mono<Long> zRevRank(ByteBuffer key,
                                                   ByteBuffer value)

Determine the index of element with value in a sorted set when scored high to low.

Parameters:

key - must not be null.

value - must not be null.

Returns:

See Also:

Redis Documentation: ZREVRANK

zRank

reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZRankCommand,Long>> zRank(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRankCommand> commands)

Determine the index of element with value in a sorted set when scored by ReactiveZSetCommands.ZRankCommand.getDirection().

Parameters:

commands - must not be null.

Returns:

See Also:

Redis Documentation: ZRANK, Redis Documentation: ZREVRANK

zRange

default reactor.core.publisher.Flux<ByteBuffer> zRange(ByteBuffer key,
                                                       Range<Long> range)

Get elements in range from sorted set.

Parameters:

key - must not be null.

range - must not be null.

Returns:

See Also:

Redis Documentation: ZRANGE

zRangeWithScores

default reactor.core.publisher.Flux<RedisZSetCommands.Tuple> zRangeWithScores(ByteBuffer key,
                                                                              Range<Long> range)

Get set of RedisZSetCommands.Tuples in range from sorted set.

Parameters:

key - must not be null.

range - must not be null.

Returns:

See Also:

Redis Documentation: ZRANGE

zRevRange

default reactor.core.publisher.Flux<ByteBuffer> zRevRange(ByteBuffer key,
                                                          Range<Long> range)

Get elements in range from sorted set in reverse score ordering.

Parameters:

key - must not be null.

range - must not be null.

Returns:

See Also:

Redis Documentation: ZREVRANGE

zRevRangeWithScores

default reactor.core.publisher.Flux<RedisZSetCommands.Tuple> zRevRangeWithScores(ByteBuffer key,
                                                                                 Range<Long> range)

Get set of RedisZSetCommands.Tuples in range from sorted set in reverse score ordering.

Parameters:

key - must not be null.

range - must not be null.

Returns:

See Also:

Redis Documentation: ZREVRANGE

zRange

reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZRangeCommand,reactor.core.publisher.Flux<RedisZSetCommands.Tuple>>> zRange(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRangeCommand> commands)

Get set of RedisZSetCommands.Tuples in range from sorted set.

Parameters:

commands - must not be null.

Returns:

See Also:

Redis Documentation: ZRANGE, Redis Documentation: ZREVRANGE

zRangeByScore

default reactor.core.publisher.Flux<ByteBuffer> zRangeByScore(ByteBuffer key,
                                                              Range<Double> range)

Get elements in range from sorted set.

Parameters:

key - must not be null.

range - must not be null.

Returns:

See Also:

Redis Documentation: ZRANGEBYSCORE

zRangeByScore

default reactor.core.publisher.Flux<ByteBuffer> zRangeByScore(ByteBuffer key,
                                                              Range<Double> range,
                                                              RedisZSetCommands.Limit limit)

Get elements in range from sorted set.

Parameters:

key - must not be null.

range - must not be null.

limit - must not be null.

Returns:

See Also:

Redis Documentation: ZRANGEBYSCORE

zRangeByScoreWithScores

default reactor.core.publisher.Flux<RedisZSetCommands.Tuple> zRangeByScoreWithScores(ByteBuffer key,
                                                                                     Range<Double> range)

Get RedisZSetCommands.Tuples in range from sorted set.

Parameters:

key - must not be null.

range - must not be null.

Returns:

See Also:

Redis Documentation: ZRANGEBYSCORE

zRangeByScoreWithScores

default reactor.core.publisher.Flux<RedisZSetCommands.Tuple> zRangeByScoreWithScores(ByteBuffer key,
                                                                                     Range<Double> range,
                                                                                     RedisZSetCommands.Limit limit)

Get RedisZSetCommands.Tuples in range from sorted set.

Parameters:

key - must not be null.

range - must not be null.

limit - must not be null.

Returns:

See Also:

Redis Documentation: ZRANGEBYSCORE

zRevRangeByScore

default reactor.core.publisher.Flux<ByteBuffer> zRevRangeByScore(ByteBuffer key,
                                                                 Range<Double> range)

Get elements in range from sorted set in reverse score ordering.

Parameters:

key - must not be null.

range - must not be null.

Returns:

See Also:

Redis Documentation: ZREVRANGEBYSCORE

zRevRangeByScore

default reactor.core.publisher.Flux<ByteBuffer> zRevRangeByScore(ByteBuffer key,
                                                                 Range<Double> range,
                                                                 RedisZSetCommands.Limit limit)

Get elements in range from sorted set in reverse score ordering.

Parameters:

key - must not be null.

range - must not be null.

limit - must not be null.

Returns:

See Also:

Redis Documentation: ZREVRANGEBYSCORE

zRevRangeByScoreWithScores

default reactor.core.publisher.Flux<RedisZSetCommands.Tuple> zRevRangeByScoreWithScores(ByteBuffer key,
                                                                                        Range<Double> range)

Get set of RedisZSetCommands.Tuples in range from sorted set in reverse score ordering.

Parameters:

key - must not be null.

range - must not be null.

Returns:

See Also:

Redis Documentation: ZREVRANGEBYSCORE

zRevRangeByScoreWithScores

default reactor.core.publisher.Flux<RedisZSetCommands.Tuple> zRevRangeByScoreWithScores(ByteBuffer key,
                                                                                        Range<Double> range,
                                                                                        RedisZSetCommands.Limit limit)

Get RedisZSetCommands.Tuples in range from sorted set in reverse score ordering.

Parameters:

key - must not be null.

range - must not be null.

limit - must not be null.

Returns:

See Also:

Redis Documentation: ZREVRANGEBYSCORE

zRangeByScore

reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZRangeByScoreCommand,reactor.core.publisher.Flux<RedisZSetCommands.Tuple>>> zRangeByScore(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRangeByScoreCommand> commands)

Get RedisZSetCommands.Tuples in range from sorted set.

Parameters:

commands - must not be null.

Returns:

See Also:

Redis Documentation: ZRANGEBYSCORE, Redis Documentation: ZREVRANGEBYSCORE

zScan

default reactor.core.publisher.Flux<RedisZSetCommands.Tuple> zScan(ByteBuffer key)

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

Parameters:

key - must not be null.

Returns:

the Flux emitting the raw tuples one by one.

Throws:

IllegalArgumentException - when key is null.

Since:

2.1

See Also:

Redis Documentation: ZSCAN

zScan

default reactor.core.publisher.Flux<RedisZSetCommands.Tuple> zScan(ByteBuffer key,
                                                                   ScanOptions options)

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

Parameters:

key - must not be null.

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

Returns:

the Flux emitting the raw tuples one by one.

Throws:

IllegalArgumentException - when one of the required arguments is null.

Since:

2.1

See Also:

Redis Documentation: ZSCAN

zScan

reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,reactor.core.publisher.Flux<RedisZSetCommands.Tuple>>> zScan(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyScanCommand> commands)

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

Parameters:

commands - must not be null.

Returns:

Since:

2.1

See Also:

Redis Documentation: ZSCAN

zCount

default reactor.core.publisher.Mono<Long> zCount(ByteBuffer key,
                                                 Range<Double> range)

Count number of elements within sorted set with scores within Range.
NOTE please use Double.NEGATIVE_INFINITY for -inf and Double.POSITIVE_INFINITY for +inf.

Parameters:

key - must not be null.

range - must not be null.

Returns:

See Also:

Redis Documentation: ZCOUNT

zCount

reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZCountCommand,Long>> zCount(org.reactivestreams.Publisher<ReactiveZSetCommands.ZCountCommand> commands)

Count number of elements within sorted set with scores within Range.
NOTE please use Double.NEGATIVE_INFINITY for -inf and Double.POSITIVE_INFINITY for +inf.

Parameters:

commands - must not be null.

Returns:

See Also:

Redis Documentation: ZCOUNT

zCard

default reactor.core.publisher.Mono<Long> zCard(ByteBuffer key)

Get the size of sorted set with key.

Parameters:

key - must not be null.

Returns:

See Also:

Redis Documentation: ZCARD

zCard

reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>> zCard(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands)

Get the size of sorted set with ReactiveRedisConnection.KeyCommand.getKey().

Parameters:

commands - must not be null.

Returns:

See Also:

Redis Documentation: ZCARD

zScore

default reactor.core.publisher.Mono<Double> zScore(ByteBuffer key,
                                                   ByteBuffer value)

Get the score of element with value from sorted set with key key.

Parameters:

key - must not be null.

value - must not be null.

Returns:

See Also:

Redis Documentation: ZSCORE

zScore

reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZScoreCommand,Double>> zScore(org.reactivestreams.Publisher<ReactiveZSetCommands.ZScoreCommand> commands)

Get the score of element with ReactiveZSetCommands.ZScoreCommand.getValue() from sorted set with key ReactiveRedisConnection.KeyCommand.getKey()

Parameters:

commands - must not be null.

Returns:

See Also:

Redis Documentation: ZSCORE

zRemRangeByRank

default reactor.core.publisher.Mono<Long> zRemRangeByRank(ByteBuffer key,
                                                          Range<Long> range)

Remove elements in Range from sorted set with key.

Parameters:

key - must not be null.

range - must not be null.

Returns:

See Also:

Redis Documentation: ZREMRANGEBYRANK

zRemRangeByRank

reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZRemRangeByRankCommand,Long>> zRemRangeByRank(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRemRangeByRankCommand> commands)

Remove elements in Range from sorted set with ReactiveRedisConnection.KeyCommand.getKey().

Parameters:

commands - must not be null.

Returns:

See Also:

Redis Documentation: ZREMRANGEBYRANK

zRemRangeByScore

default reactor.core.publisher.Mono<Long> zRemRangeByScore(ByteBuffer key,
                                                           Range<Double> range)

Remove elements in Range from sorted set with key.

Parameters:

key - must not be null.

range - must not be null.

Returns:

See Also:

Redis Documentation: ZREMRANGEBYSCORE

zRemRangeByScore

reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZRemRangeByScoreCommand,Long>> zRemRangeByScore(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRemRangeByScoreCommand> commands)

Remove elements in Range from sorted set with ReactiveRedisConnection.KeyCommand.getKey().

Parameters:

commands - must not be null.

Returns:

See Also:

Redis Documentation: ZREMRANGEBYSCORE

zUnionStore

default reactor.core.publisher.Mono<Long> zUnionStore(ByteBuffer destinationKey,
                                                      List<ByteBuffer> sets)

Union sorted sets and store result in destination destinationKey.

Parameters:

destinationKey - must not be null.

sets - must not be null.

Returns:

See Also:

Redis Documentation: ZUNIONSTORE

zUnionStore

default reactor.core.publisher.Mono<Long> zUnionStore(ByteBuffer destinationKey,
                                                      List<ByteBuffer> sets,
                                                      List<Double> weights)

Union sorted sets and store result in destination destinationKey and apply weights to individual sets.

Parameters:

destinationKey - must not be null.

sets - must not be null.

weights - must not be null.

Returns:

See Also:

Redis Documentation: ZUNIONSTORE

zUnionStore

default reactor.core.publisher.Mono<Long> zUnionStore(ByteBuffer destinationKey,
                                                      List<ByteBuffer> sets,
                                                      RedisZSetCommands.Weights weights)

Union sorted sets and store result in destination destinationKey and apply weights to individual sets.

Parameters:

destinationKey - must not be null.

sets - must not be null.

weights - must not be null.

Returns:

Since:

2.1

See Also:

Redis Documentation: ZUNIONSTORE

zUnionStore

default reactor.core.publisher.Mono<Long> zUnionStore(ByteBuffer destinationKey,
                                                      List<ByteBuffer> sets,
                                                      List<Double> weights,
                                                      @Nullable
                                                      RedisZSetCommands.Aggregate aggregateFunction)

Union sorted sets by applying aggregateFunction and store result in destination destinationKey and apply weights to individual sets.

Parameters:

destinationKey - must not be null.

sets - must not be null.

weights - can be null.

aggregateFunction - can be null.

Returns:

See Also:

Redis Documentation: ZUNIONSTORE

zUnionStore

default reactor.core.publisher.Mono<Long> zUnionStore(ByteBuffer destinationKey,
                                                      List<ByteBuffer> sets,
                                                      RedisZSetCommands.Weights weights,
                                                      @Nullable
                                                      RedisZSetCommands.Aggregate aggregateFunction)

Union sorted sets by applying aggregateFunction and store result in destination destinationKey and apply weights to individual sets.

Parameters:

destinationKey - must not be null.

sets - must not be null.

weights - can be null.

aggregateFunction - can be null.

Returns:

Since:

2.1

See Also:

Redis Documentation: ZUNIONSTORE

zUnionStore

reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZUnionStoreCommand,Long>> zUnionStore(org.reactivestreams.Publisher<ReactiveZSetCommands.ZUnionStoreCommand> commands)

Union sorted sets by applying aggregateFunction and store result in destination destinationKey and apply weights to individual sets.

Parameters:

commands -

Returns:

See Also:

Redis Documentation: ZUNIONSTORE

zInterStore

default reactor.core.publisher.Mono<Long> zInterStore(ByteBuffer destinationKey,
                                                      List<ByteBuffer> sets)

Intersect sorted sets and store result in destination destinationKey.

Parameters:

destinationKey - must not be null.

sets - must not be null.

Returns:

See Also:

Redis Documentation: ZINTERSTORE

zInterStore

default reactor.core.publisher.Mono<Long> zInterStore(ByteBuffer destinationKey,
                                                      List<ByteBuffer> sets,
                                                      List<Double> weights)

Intersect sorted sets and store result in destination destinationKey and apply weights to individual sets.

Parameters:

destinationKey - must not be null.

sets - must not be null.

weights - must not be null.

Returns:

See Also:

Redis Documentation: ZINTERSTORE

zInterStore

default reactor.core.publisher.Mono<Long> zInterStore(ByteBuffer destinationKey,
                                                      List<ByteBuffer> sets,
                                                      RedisZSetCommands.Weights weights)

Intersect sorted sets and store result in destination destinationKey and apply weights to individual sets.

Parameters:

destinationKey - must not be null.

sets - must not be null.

weights - must not be null.

Returns:

Since:

2.1

See Also:

Redis Documentation: ZINTERSTORE

zInterStore

default reactor.core.publisher.Mono<Long> zInterStore(ByteBuffer destinationKey,
                                                      List<ByteBuffer> sets,
                                                      List<Double> weights,
                                                      @Nullable
                                                      RedisZSetCommands.Aggregate aggregateFunction)

Intersect sorted sets by applying aggregateFunction and store result in destination destinationKey and apply weights to individual sets.

Parameters:

destinationKey - must not be null.

sets - must not be null.

weights - must not be null.

aggregateFunction - can be null.

Returns:

See Also:

Redis Documentation: ZINTERSTORE

zInterStore

default reactor.core.publisher.Mono<Long> zInterStore(ByteBuffer destinationKey,
                                                      List<ByteBuffer> sets,
                                                      RedisZSetCommands.Weights weights,
                                                      @Nullable
                                                      RedisZSetCommands.Aggregate aggregateFunction)

Intersect sorted sets by applying aggregateFunction and store result in destination destinationKey and apply weights to individual sets.

Parameters:

destinationKey - must not be null.

sets - must not be null.

weights - must not be null.

aggregateFunction - can be null.

Returns:

Since:

2.1

See Also:

Redis Documentation: ZINTERSTORE

zInterStore

reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZInterStoreCommand,Long>> zInterStore(org.reactivestreams.Publisher<ReactiveZSetCommands.ZInterStoreCommand> commands)

Intersect sorted sets by applying aggregateFunction and store result in destination destinationKey and apply weights to individual sets.

Parameters:

commands -

Returns:

See Also:

Redis Documentation: ZINTERSTORE

zRangeByLex

default reactor.core.publisher.Flux<ByteBuffer> zRangeByLex(ByteBuffer key,
                                                            Range<String> range)

Get all elements in Range from the sorted set at key in lexicographical ordering.

Parameters:

key - must not be null.

range - must not be null.

Returns:

See Also:

Redis Documentation: ZRANGEBYLEX

zRangeByLex

default reactor.core.publisher.Flux<ByteBuffer> zRangeByLex(ByteBuffer key,
                                                            Range<String> range,
                                                            RedisZSetCommands.Limit limit)

Get all elements in Range from the sorted set at key in lexicographical ordering. Result is limited via RedisZSetCommands.Limit.

Parameters:

key - must not be null.

range - must not be null.

limit - can be null.

Returns:

See Also:

Redis Documentation: ZRANGEBYLEX

zRevRangeByLex

default reactor.core.publisher.Flux<ByteBuffer> zRevRangeByLex(ByteBuffer key,
                                                               Range<String> range)

Get all elements in Range from the sorted set at key in lexicographical ordering.

Parameters:

key - must not be null.

range - must not be null.

Returns:

See Also:

Redis Documentation: ZREVRANGEBYLEX

zRevRangeByLex

default reactor.core.publisher.Flux<ByteBuffer> zRevRangeByLex(ByteBuffer key,
                                                               Range<String> range,
                                                               RedisZSetCommands.Limit limit)

Get all elements in Range from the sorted set at key in lexicographical ordering. Result is limited via RedisZSetCommands.Limit.

Parameters:

key - must not be null.

range - must not be null.

limit - must not be null.

Returns:

See Also:

Redis Documentation: ZREVRANGEBYLEX

zRangeByLex

reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZRangeByLexCommand,reactor.core.publisher.Flux<ByteBuffer>>> zRangeByLex(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRangeByLexCommand> commands)

Get all elements in Range from the sorted set at key in lexicographical ordering. Result is limited via RedisZSetCommands.Limit and sorted by ReactiveZSetCommands.ZRangeByLexCommand.getDirection().

Parameters:

commands - must not be null.

Returns:

See Also:

Redis Documentation: ZRANGEBYLEX, Redis Documentation: ZREVRANGEBYLEX