Package 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, Andrey Shlykov

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	ReactiveZSetCommands.BZPopCommand	BZPOPMIN/BZPOPMAX command parameters.
static enum	ReactiveZSetCommands.PopDirection
static class	ReactiveZSetCommands.ZAddCommand	ZADD command parameters.
static class	ReactiveZSetCommands.ZAggregateCommand	ZINTER/ZUNION command parameters.
static class	ReactiveZSetCommands.ZAggregateStoreCommand	ZINTERSTORE/ZUNIONSTORE command parameters.
static class	ReactiveZSetCommands.ZCountCommand	ZCOUNT command parameters.
static class	ReactiveZSetCommands.ZDiffCommand	ZDIFF command parameters.
static class	ReactiveZSetCommands.ZDiffStoreCommand	ZDIFFSTORE command parameters.
static class	ReactiveZSetCommands.ZIncrByCommand	ZINCRBY command parameters.
static class	ReactiveZSetCommands.ZInterStoreCommand	ZINTERSTORE command parameters.
static class	ReactiveZSetCommands.ZLexCountCommand	ZLEXCOUNT command parameters.
static class	ReactiveZSetCommands.ZMScoreCommand	ZMSCORE command parameters.
static class	ReactiveZSetCommands.ZPopCommand	ZPOPMIN/ZPOPMAX command parameters.
static class	ReactiveZSetCommands.ZRandMemberCommand	ZRANDMEMBER 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.ZRangeStoreCommand	ZRANGESTORE command parameters.
static class	ReactiveZSetCommands.ZRankCommand	ZRANK/ZREVRANK command parameters.
static class	ReactiveZSetCommands.ZRemCommand	ZREM command parameters.
static class	ReactiveZSetCommands.ZRemRangeByLexCommand	ZREMRANGEBYLEX 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	Description
Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.BZPopCommand,Flux<Tuple>>>	bZPop(Publisher<ReactiveZSetCommands.BZPopCommand> commands)	Remove and return elements from sorted set at keyCommand#getKey().
default Mono<Tuple>	bZPopMax(ByteBuffer key, Duration timeout)	Remove and return the value with its score having the highest score from sorted set at key.
default Mono<Tuple>	bZPopMin(ByteBuffer key, Duration timeout)	Remove and return the value with its score having the lowest score from sorted set at key.
default 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.
default Mono<Long>	zAdd(ByteBuffer key, Collection<? extends Tuple> tuples)	Add a tuples to a sorted set at key, or update their score if it already exists.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZAddCommand,Number>>	zAdd(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 Mono<Long>	zCard(ByteBuffer key)	Get the size of sorted set with key.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>>	zCard(Publisher<ReactiveRedisConnection.KeyCommand> commands)	Get the size of sorted set with keyCommand#getKey().
default Mono<Long>	zCount(ByteBuffer key, Range<Double> range)	Count number of elements within sorted set with scores within Range.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZCountCommand,Long>>	zCount(Publisher<ReactiveZSetCommands.ZCountCommand> commands)	Count number of elements within sorted set with scores within Range.
default Flux<ByteBuffer>	zDiff(List<ByteBuffer> sets)	Diff sorted sets.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZDiffCommand,Flux<ByteBuffer>>>	zDiff(Publisher<? extends ReactiveZSetCommands.ZDiffCommand> commands)	Diff sorted sets.
default Mono<Long>	zDiffStore(ByteBuffer destinationKey, List<ByteBuffer> sets)	Diff sorted sets and store result in destination destinationKey.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZDiffStoreCommand,Long>>	zDiffStore(Publisher<ReactiveZSetCommands.ZDiffStoreCommand> commands)	Diff sorted sets and store result in destination destinationKey.
default Flux<Tuple>	zDiffWithScores(List<ByteBuffer> sets)	Diff sorted sets.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZDiffCommand,Flux<Tuple>>>	zDiffWithScores(Publisher<? extends ReactiveZSetCommands.ZDiffCommand> commands)	Diff sorted sets.
default Mono<Double>	zIncrBy(ByteBuffer key, Number increment, ByteBuffer value)	Increment the score of element with value in sorted set by increment.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZIncrByCommand,Double>>	zIncrBy(Publisher<ReactiveZSetCommands.ZIncrByCommand> commands)	Increment the score of element with ReactiveZSetCommands.ZIncrByCommand.getValue() in sorted set by ReactiveZSetCommands.ZIncrByCommand.getIncrement().
default Flux<ByteBuffer>	zInter(List<ByteBuffer> sets)	Intersect sorted sets.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZAggregateCommand,Flux<ByteBuffer>>>	zInter(Publisher<? extends ReactiveZSetCommands.ZAggregateCommand> commands)	Intersect sorted sets by applying aggregateFunction and apply weights to individual sets.
default Mono<Long>	zInterStore(ByteBuffer destinationKey, List<ByteBuffer> sets)	Intersect sorted sets and store result in destination destinationKey.
default 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 Mono<Long>	zInterStore(ByteBuffer destinationKey, List<ByteBuffer> sets, List<Double> weights, Aggregate aggregateFunction)	Intersect sorted sets by applying aggregateFunction and store result in destination destinationKey and apply weights to individual sets.
default Mono<Long>	zInterStore(ByteBuffer destinationKey, List<ByteBuffer> sets, Weights weights)	Intersect sorted sets and store result in destination destinationKey and apply weights to individual sets.
default Mono<Long>	zInterStore(ByteBuffer destinationKey, List<ByteBuffer> sets, Weights weights, Aggregate aggregateFunction)	Intersect sorted sets by applying aggregateFunction and store result in destination destinationKey and apply weights to individual sets.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZAggregateStoreCommand,Long>>	zInterStore(Publisher<? extends ReactiveZSetCommands.ZAggregateStoreCommand> commands)	Intersect sorted sets by applying aggregateFunction and store result in destination destinationKey and apply weights to individual sets.
default Flux<Tuple>	zInterWithScores(List<ByteBuffer> sets)	Intersect sorted sets.
default Flux<Tuple>	zInterWithScores(List<ByteBuffer> sets, List<Double> weights)	Intersect sorted sets and apply weights to individual sets.
default Flux<Tuple>	zInterWithScores(List<ByteBuffer> sets, List<Double> weights, Aggregate aggregateFunction)	Intersect sorted sets by applying aggregateFunction and apply weights to individual sets.
default Flux<Tuple>	zInterWithScores(List<ByteBuffer> sets, Weights weights)	Intersect sorted sets and apply weights to individual sets.
default Flux<Tuple>	zInterWithScores(List<ByteBuffer> sets, Weights weights, Aggregate aggregateFunction)	Intersect sorted sets by applying aggregateFunction and apply weights to individual sets.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZAggregateCommand,Flux<Tuple>>>	zInterWithScores(Publisher<? extends ReactiveZSetCommands.ZAggregateCommand> commands)	Intersect sorted sets by applying aggregateFunction and apply weights to individual sets.
default Mono<Long>	zLexCount(ByteBuffer key, Range<String> range)	Count number of elements within sorted set with value between Range#min and Range#max applying lexicographical ordering.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZLexCountCommand,Long>>	zLexCount(Publisher<ReactiveZSetCommands.ZLexCountCommand> commands)	Count number of elements within sorted set with value between Range#min and Range#max applying lexicographical ordering.
default Mono<List<Double>>	zMScore(ByteBuffer key, Collection<ByteBuffer> values)	Get the scores of elements with values from sorted set with key key.
Flux<ReactiveRedisConnection.MultiValueResponse<ReactiveZSetCommands.ZMScoreCommand,Double>>	zMScore(Publisher<ReactiveZSetCommands.ZMScoreCommand> commands)	Get the scores of elements with ReactiveZSetCommands.ZMScoreCommand.getValues() from sorted set with key ReactiveRedisConnection.KeyCommand.getKey()
Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZPopCommand,Flux<Tuple>>>	zPop(Publisher<ReactiveZSetCommands.ZPopCommand> commands)	Remove and return elements from sorted set at keyCommand#getKey().
default Mono<Tuple>	zPopMax(ByteBuffer key)	Remove and return the value with its score having the highest score from sorted set at key.
default Flux<Tuple>	zPopMax(ByteBuffer key, long count)	Remove and return count values with their score having the highest score from sorted set at key.
default Mono<Tuple>	zPopMin(ByteBuffer key)	Remove and return the value with its score having the lowest score from sorted set at key.
default Flux<Tuple>	zPopMin(ByteBuffer key, long count)	Remove and return count values with their score having the lowest score from sorted set at key.
default Mono<ByteBuffer>	zRandMember(ByteBuffer key)	Get random element from sorted set at key.
default Flux<ByteBuffer>	zRandMember(ByteBuffer key, long count)	Get count random elements from sorted set at key.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZRandMemberCommand,Flux<ByteBuffer>>>	zRandMember(Publisher<ReactiveZSetCommands.ZRandMemberCommand> commands)	Get random elements from sorted set at key.
default Mono<Tuple>	zRandMemberWithScore(ByteBuffer key)	Get random element from sorted set at key.
default Flux<Tuple>	zRandMemberWithScore(ByteBuffer key, long count)	Get count random elements from sorted set at key.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZRandMemberCommand,Flux<Tuple>>>	zRandMemberWithScore(Publisher<ReactiveZSetCommands.ZRandMemberCommand> commands)	Get random elements from sorted set at key.
default Flux<ByteBuffer>	zRange(ByteBuffer key, Range<Long> range)	Get elements in range from sorted set.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZRangeCommand,Flux<Tuple>>>	zRange(Publisher<ReactiveZSetCommands.ZRangeCommand> commands)	Get set of Tuples in range from sorted set.
default Flux<ByteBuffer>	zRangeByLex(ByteBuffer key, Range<String> range)	Get all elements in Range from the sorted set at key in lexicographical ordering.
default Flux<ByteBuffer>	zRangeByLex(ByteBuffer key, Range<String> range, Limit limit)	Get all elements in Range from the sorted set at key in lexicographical ordering.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZRangeByLexCommand,Flux<ByteBuffer>>>	zRangeByLex(Publisher<ReactiveZSetCommands.ZRangeByLexCommand> commands)	Get all elements in Range from the sorted set at key in lexicographical ordering.
default Flux<ByteBuffer>	zRangeByScore(ByteBuffer key, Range<Double> range)	Get elements in range from sorted set.
default Flux<ByteBuffer>	zRangeByScore(ByteBuffer key, Range<Double> range, Limit limit)	Get elements in range from sorted set.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZRangeByScoreCommand,Flux<Tuple>>>	zRangeByScore(Publisher<ReactiveZSetCommands.ZRangeByScoreCommand> commands)	Get Tuples in range from sorted set.
default Flux<Tuple>	zRangeByScoreWithScores(ByteBuffer key, Range<Double> range)	Get Tuples in range from sorted set.
default Flux<Tuple>	zRangeByScoreWithScores(ByteBuffer key, Range<Double> range, Limit limit)	Get Tuples in range from sorted set.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZRangeStoreCommand,Mono<Long>>>	zRangeStore(Publisher<ReactiveZSetCommands.ZRangeStoreCommand> commands)	Get set of Tuples in range from sorted set.
default Mono<Long>	zRangeStoreByLex(ByteBuffer srcKey, ByteBuffer destKey, Range<String> range, Limit limit)	Add elements from srcKey by lexicographical range to destKey.
default Mono<Long>	zRangeStoreByScore(ByteBuffer srcKey, ByteBuffer destKey, Range<Double> range, Limit limit)	Add elements from srcKey by score range to destKey.
default Mono<Long>	zRangeStoreRevByLex(ByteBuffer srcKey, ByteBuffer destKey, Range<String> range, Limit limit)	Add elements from srcKey by reverse lexicographical range to destKey.
default Mono<Long>	zRangeStoreRevByScore(ByteBuffer srcKey, ByteBuffer destKey, Range<Double> range, Limit limit)	Add elements from srcKey by reverse score range to destKey.
default Flux<Tuple>	zRangeWithScores(ByteBuffer key, Range<Long> range)	Get set of Tuples in range from sorted set.
default Mono<Long>	zRank(ByteBuffer key, ByteBuffer value)	Determine the index of element with value in a sorted set.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZRankCommand,Long>>	zRank(Publisher<ReactiveZSetCommands.ZRankCommand> commands)	Determine the index of element with value in a sorted set when scored by ReactiveZSetCommands.ZRankCommand.getDirection().
default Mono<Long>	zRem(ByteBuffer key, ByteBuffer value)	Remove value from sorted set.
default Mono<Long>	zRem(ByteBuffer key, Collection<ByteBuffer> values)	Remove values from sorted set.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZRemCommand,Long>>	zRem(Publisher<ReactiveZSetCommands.ZRemCommand> commands)	Remove ReactiveZSetCommands.ZRemCommand.getValues() from sorted set.
default Mono<Long>	zRemRangeByLex(ByteBuffer key, Range<String> range)	Remove elements in Range from sorted set with key.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZRemRangeByLexCommand,Long>>	zRemRangeByLex(Publisher<ReactiveZSetCommands.ZRemRangeByLexCommand> commands)	Remove elements in Range from sorted set with ReactiveRedisConnection.KeyCommand.getKey().
default Mono<Long>	zRemRangeByRank(ByteBuffer key, Range<Long> range)	Remove elements in Range from sorted set with key.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZRemRangeByRankCommand,Long>>	zRemRangeByRank(Publisher<ReactiveZSetCommands.ZRemRangeByRankCommand> commands)	Remove elements in Range from sorted set with ReactiveRedisConnection.KeyCommand.getKey().
default Mono<Long>	zRemRangeByScore(ByteBuffer key, Range<Double> range)	Remove elements in Range from sorted set with key.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZRemRangeByScoreCommand,Long>>	zRemRangeByScore(Publisher<ReactiveZSetCommands.ZRemRangeByScoreCommand> commands)	Remove elements in Range from sorted set with ReactiveRedisConnection.KeyCommand.getKey().
default Flux<ByteBuffer>	zRevRange(ByteBuffer key, Range<Long> range)	Get elements in range from sorted set in reverse score ordering.
default Flux<ByteBuffer>	zRevRangeByLex(ByteBuffer key, Range<String> range)	Get all elements in Range from the sorted set at key in lexicographical ordering.
default Flux<ByteBuffer>	zRevRangeByLex(ByteBuffer key, Range<String> range, Limit limit)	Get all elements in Range from the sorted set at key in lexicographical ordering.
default Flux<ByteBuffer>	zRevRangeByScore(ByteBuffer key, Range<Double> range)	Get elements in range from sorted set in reverse score ordering.
default Flux<ByteBuffer>	zRevRangeByScore(ByteBuffer key, Range<Double> range, Limit limit)	Get elements in range from sorted set in reverse score ordering.
default Flux<Tuple>	zRevRangeByScoreWithScores(ByteBuffer key, Range<Double> range)	Get set of Tuples in range from sorted set in reverse score ordering.
default Flux<Tuple>	zRevRangeByScoreWithScores(ByteBuffer key, Range<Double> range, Limit limit)	Get Tuples in range from sorted set in reverse score ordering.
default Flux<Tuple>	zRevRangeWithScores(ByteBuffer key, Range<Long> range)	Get set of Tuples in range from sorted set in reverse score ordering.
default Mono<Long>	zRevRank(ByteBuffer key, ByteBuffer value)	Determine the index of element with value in a sorted set when scored high to low.
default Flux<Tuple>	zScan(ByteBuffer key)	Use a Flux to iterate over members in the sorted set at key.
default Flux<Tuple>	zScan(ByteBuffer key, ScanOptions options)	Use a Flux to iterate over members in the sorted set at key given ScanOptions.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,Flux<Tuple>>>	zScan(Publisher<ReactiveRedisConnection.KeyScanCommand> commands)	Use a Flux to iterate over members in the sorted set at key.
default Mono<Double>	zScore(ByteBuffer key, ByteBuffer value)	Get the score of element with value from sorted set with key key.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZScoreCommand,Double>>	zScore(Publisher<ReactiveZSetCommands.ZScoreCommand> commands)	Get the score of element with ReactiveZSetCommands.ZScoreCommand.getValue() from sorted set with key ReactiveRedisConnection.KeyCommand.getKey()
default Flux<ByteBuffer>	zUnion(List<ByteBuffer> sets)	Union sorted sets.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZAggregateCommand,Flux<ByteBuffer>>>	zUnion(Publisher<? extends ReactiveZSetCommands.ZAggregateCommand> commands)	Union sorted sets by applying aggregateFunction and apply weights to individual sets.
default Mono<Long>	zUnionStore(ByteBuffer destinationKey, List<ByteBuffer> sets)	Union sorted sets and store result in destination destinationKey.
default 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 Mono<Long>	zUnionStore(ByteBuffer destinationKey, List<ByteBuffer> sets, List<Double> weights, Aggregate aggregateFunction)	Union sorted sets by applying aggregateFunction and store result in destination destinationKey and apply weights to individual sets.
default Mono<Long>	zUnionStore(ByteBuffer destinationKey, List<ByteBuffer> sets, Weights weights)	Union sorted sets and store result in destination destinationKey and apply weights to individual sets.
default Mono<Long>	zUnionStore(ByteBuffer destinationKey, List<ByteBuffer> sets, Weights weights, Aggregate aggregateFunction)	Union sorted sets by applying aggregateFunction and store result in destination destinationKey and apply weights to individual sets.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZAggregateStoreCommand,Long>>	zUnionStore(Publisher<? extends ReactiveZSetCommands.ZAggregateStoreCommand> commands)	Union sorted sets by applying aggregateFunction and store result in destination destinationKey and apply weights to individual sets.
default Flux<Tuple>	zUnionWithScores(List<ByteBuffer> sets)	Union sorted sets.
default Flux<Tuple>	zUnionWithScores(List<ByteBuffer> sets, List<Double> weights)	Union sorted sets and apply weights to individual sets.
default Flux<Tuple>	zUnionWithScores(List<ByteBuffer> sets, List<Double> weights, Aggregate aggregateFunction)	Union sorted sets by applying aggregateFunction and apply weights to individual sets.
default Flux<Tuple>	zUnionWithScores(List<ByteBuffer> sets, Weights weights)	Union sorted sets and apply weights to individual sets.
default Flux<Tuple>	zUnionWithScores(List<ByteBuffer> sets, Weights weights, Aggregate aggregateFunction)	Union sorted sets by applying aggregateFunction and apply weights to individual sets.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZAggregateCommand,Flux<Tuple>>>	zUnionWithScores(Publisher<? extends ReactiveZSetCommands.ZAggregateCommand> commands)	Union sorted sets by applying aggregateFunction and apply weights to individual sets.

Method Details

zAdd

default 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 Mono<Long> zAdd(ByteBuffer key,
 Collection<? extends 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

Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZAddCommand,Number>> zAdd(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 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 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

Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZRemCommand,Long>> zRem(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 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

Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZIncrByCommand,Double>> zIncrBy(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

zRandMember

default Mono<ByteBuffer> zRandMember(ByteBuffer key)

Get random element from sorted set at key.

Parameters:

key - must not be null.

Returns:

Since:

2.6

See Also:

• Redis Documentation: ZRANDMEMBER

zRandMember

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

Get count random elements from sorted set at key.

Parameters:

key - must not be null.

count - if the provided count argument is positive, return a list of distinct fields, capped either at count or the set size. If count is negative, the behavior changes and the command is allowed to return the same value multiple times. In this case, the number of returned values is the absolute value of the specified count.

Returns:

Since:

2.6

See Also:

• Redis Documentation: ZRANDMEMBER

zRandMember

Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZRandMemberCommand,Flux<ByteBuffer>>> zRandMember(Publisher<ReactiveZSetCommands.ZRandMemberCommand> commands)

Get random elements from sorted set at key.

Parameters:

commands - must not be null.

Returns:

Since:

2.6

See Also:

• Redis Documentation: ZRANDMEMBER

zRandMemberWithScore

default Mono<Tuple> zRandMemberWithScore(ByteBuffer key)

Get random element from sorted set at key.

Parameters:

key - must not be null.

Returns:

Since:

2.6

See Also:

• Redis Documentation: ZRANDMEMBER

zRandMemberWithScore

default Flux<Tuple> zRandMemberWithScore(ByteBuffer key,
 long count)

Get count random elements from sorted set at key.

Parameters:

key - must not be null.

count - if the provided count argument is positive, return a list of distinct fields, capped either at count or the set size. If count is negative, the behavior changes and the command is allowed to return the same value multiple times. In this case, the number of returned values is the absolute value of the specified count.

Returns:

Since:

2.6

See Also:

• Redis Documentation: ZRANDMEMBER

zRandMemberWithScore

Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZRandMemberCommand,Flux<Tuple>>> zRandMemberWithScore(Publisher<ReactiveZSetCommands.ZRandMemberCommand> commands)

Get random elements from sorted set at key.

Parameters:

commands - must not be null.

Returns:

Since:

2.6

See Also:

• Redis Documentation: ZRANDMEMBER

zRank

default 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 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

Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZRankCommand,Long>> zRank(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 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 Flux<Tuple> zRangeWithScores(ByteBuffer key,
 Range<Long> range)

Get set of 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 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 Flux<Tuple> zRevRangeWithScores(ByteBuffer key,
 Range<Long> range)

Get set of 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

Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZRangeCommand,Flux<Tuple>>> zRange(Publisher<ReactiveZSetCommands.ZRangeCommand> commands)

Get set of Tuples in range from sorted set.

Parameters:

commands - must not be null.

Returns:

See Also:

• Redis Documentation: ZRANGE
• Redis Documentation: ZREVRANGE

zRangeStoreByScore

default Mono<Long> zRangeStoreByScore(ByteBuffer srcKey,
 ByteBuffer destKey,
 Range<Double> range,
 Limit limit)

Add elements from srcKey by score range to destKey.

Parameters:

srcKey - must not be null.

destKey - must not be null.

range - must not be null.

limit - must not be null.

Returns:

Since:

3.0

See Also:

• Redis Documentation: ZRANGESTORE

zRangeStoreByLex

default Mono<Long> zRangeStoreByLex(ByteBuffer srcKey,
 ByteBuffer destKey,
 Range<String> range,
 Limit limit)

Add elements from srcKey by lexicographical range to destKey.

Parameters:

srcKey - must not be null.

destKey - must not be null.

range - must not be null.

limit - must not be null.

Returns:

Since:

3.0

See Also:

• Redis Documentation: ZRANGESTORE

zRangeStoreRevByScore

default Mono<Long> zRangeStoreRevByScore(ByteBuffer srcKey,
 ByteBuffer destKey,
 Range<Double> range,
 Limit limit)

Add elements from srcKey by reverse score range to destKey.

Parameters:

srcKey - must not be null.

destKey - must not be null.

range - must not be null.

limit - must not be null.

Returns:

Since:

3.0

See Also:

• Redis Documentation: ZRANGESTORE

zRangeStoreRevByLex

default Mono<Long> zRangeStoreRevByLex(ByteBuffer srcKey,
 ByteBuffer destKey,
 Range<String> range,
 Limit limit)

Add elements from srcKey by reverse lexicographical range to destKey.

Parameters:

srcKey - must not be null.

destKey - must not be null.

range - must not be null.

limit - must not be null.

Returns:

Since:

3.0

See Also:

• Redis Documentation: ZRANGESTORE

zRangeStore

Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZRangeStoreCommand,Mono<Long>>> zRangeStore(Publisher<ReactiveZSetCommands.ZRangeStoreCommand> commands)

Get set of Tuples in range from sorted set.

Parameters:

commands - must not be null.

Returns:

Since:

3.0

See Also:

• Redis Documentation: ZRANGESTORE

zRangeByScore

default 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 Flux<ByteBuffer> zRangeByScore(ByteBuffer key,
 Range<Double> range,
 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 Flux<Tuple> zRangeByScoreWithScores(ByteBuffer key,
 Range<Double> range)

Get 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 Flux<Tuple> zRangeByScoreWithScores(ByteBuffer key,
 Range<Double> range,
 Limit limit)

Get 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 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 Flux<ByteBuffer> zRevRangeByScore(ByteBuffer key,
 Range<Double> range,
 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 Flux<Tuple> zRevRangeByScoreWithScores(ByteBuffer key,
 Range<Double> range)

Get set of 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 Flux<Tuple> zRevRangeByScoreWithScores(ByteBuffer key,
 Range<Double> range,
 Limit limit)

Get 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

Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZRangeByScoreCommand,Flux<Tuple>>> zRangeByScore(Publisher<ReactiveZSetCommands.ZRangeByScoreCommand> commands)

Get Tuples in range from sorted set.

Parameters:

commands - must not be null.

Returns:

See Also:

• Redis Documentation: ZRANGEBYSCORE
• Redis Documentation: ZREVRANGEBYSCORE

zScan

default Flux<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 Flux<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

Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,Flux<Tuple>>> zScan(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 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

Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZCountCommand,Long>> zCount(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

zLexCount

default Mono<Long> zLexCount(ByteBuffer key,
 Range<String> range)

Count number of elements within sorted set with value between Range#min and Range#max applying lexicographical ordering.

Parameters:

key - must not be null.

range - must not be null.

Returns:

Since:

2.4

See Also:

• Redis Documentation: ZLEXCOUNT

zLexCount

Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZLexCountCommand,Long>> zLexCount(Publisher<ReactiveZSetCommands.ZLexCountCommand> commands)

Count number of elements within sorted set with value between Range#min and Range#max applying lexicographical ordering.

Parameters:

commands - must not be null.

Returns:

Since:

2.4

See Also:

• Redis Documentation: ZLEXCOUNT

zPopMin

default Mono<Tuple> zPopMin(ByteBuffer key)

Remove and return the value with its score having the lowest score from sorted set at key.

Parameters:

key - must not be null.

Returns:

Since:

2.6

See Also:

• Redis Documentation: ZPOPMIN

zPopMin

default Flux<Tuple> zPopMin(ByteBuffer key,
 long count)

Remove and return count values with their score having the lowest score from sorted set at key.

Parameters:

key - must not be null.

count - number of elements to pop.

Returns:

Since:

2.6

See Also:

• Redis Documentation: ZPOPMIN

bZPopMin

default Mono<Tuple> bZPopMin(ByteBuffer key,
 Duration timeout)

Remove and return the value with its score having the lowest score from sorted set at key. Blocks connection until element available or timeout reached.

Parameters:

key - must not be null.

timeout - must not be null.

Returns:

Throws:

IllegalArgumentException - if the timeout is null or negative.

Since:

2.6

See Also:

• Redis Documentation: BZPOPMIN

zPopMax

default Mono<Tuple> zPopMax(ByteBuffer key)

Remove and return the value with its score having the highest score from sorted set at key.

Parameters:

key - must not be null.

Returns:

Since:

2.6

See Also:

• Redis Documentation: ZPOPMAX

zPopMax

default Flux<Tuple> zPopMax(ByteBuffer key,
 long count)

Remove and return count values with their score having the highest score from sorted set at key.

Parameters:

key - must not be null.

count - number of elements to pop.

Returns:

Since:

2.6

See Also:

• Redis Documentation: ZPOPMAX

bZPopMax

default Mono<Tuple> bZPopMax(ByteBuffer key,
 Duration timeout)

Remove and return the value with its score having the highest score from sorted set at key. Blocks connection until element available or timeout reached.

Parameters:

key - must not be null.

timeout - must not be null.

Returns:

Throws:

IllegalArgumentException - if the timeout is null or negative.

Since:

2.6

See Also:

• Redis Documentation: BZPOPMAX

zPop

Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZPopCommand,Flux<Tuple>>> zPop(Publisher<ReactiveZSetCommands.ZPopCommand> commands)

Remove and return elements from sorted set at keyCommand#getKey().

Parameters:

commands - must not be null.

Returns:

See Also:

• Redis Documentation: ZPOPMIN
• Redis Documentation: ZPOPMAX

bZPop

Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.BZPopCommand,Flux<Tuple>>> bZPop(Publisher<ReactiveZSetCommands.BZPopCommand> commands)

Remove and return elements from sorted set at keyCommand#getKey().

Parameters:

commands - must not be null.

Returns:

See Also:

• Redis Documentation: ZPOPMIN
• Redis Documentation: ZPOPMAX

zCard

default 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

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

Get the size of sorted set with keyCommand#getKey().

Parameters:

commands - must not be null.

Returns:

See Also:

• Redis Documentation: ZCARD

zScore

default 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

Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZScoreCommand,Double>> zScore(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

zMScore

default Mono<List<Double>> zMScore(ByteBuffer key,
 Collection<ByteBuffer> values)

Get the scores of elements with values from sorted set with key key.

Parameters:

key - must not be null.

values - must not be null.

Returns:

Since:

2.6

See Also:

• Redis Documentation: ZMSCORE

zMScore

Flux<ReactiveRedisConnection.MultiValueResponse<ReactiveZSetCommands.ZMScoreCommand,Double>> zMScore(Publisher<ReactiveZSetCommands.ZMScoreCommand> commands)

Get the scores of elements with ReactiveZSetCommands.ZMScoreCommand.getValues() from sorted set with key ReactiveRedisConnection.KeyCommand.getKey()

Parameters:

commands - must not be null.

Returns:

Since:

2.6

See Also:

• Redis Documentation: ZMSCORE

zRemRangeByRank

default 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

Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZRemRangeByRankCommand,Long>> zRemRangeByRank(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 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

Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZRemRangeByScoreCommand,Long>> zRemRangeByScore(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

zRemRangeByLex

default Mono<Long> zRemRangeByLex(ByteBuffer key,
 Range<String> range)

Remove elements in Range from sorted set with key.

Parameters:

key - must not be null.

range - must not be null.

Returns:

a Mono emitting the number of removed elements.

Since:

2.5

See Also:

• Redis Documentation: ZREMRANGEBYLEX

zRemRangeByLex

Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZRemRangeByLexCommand,Long>> zRemRangeByLex(Publisher<ReactiveZSetCommands.ZRemRangeByLexCommand> commands)

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

Parameters:

commands - must not be null.

Returns:

Since:

2.5

See Also:

• Redis Documentation: ZREMRANGEBYLEX

zDiff

default Flux<ByteBuffer> zDiff(List<ByteBuffer> sets)

Diff sorted sets.

Parameters:

sets - must not be null.

Returns:

Since:

2.6

See Also:

• Redis Documentation: ZDIFF

zDiff

Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZDiffCommand,Flux<ByteBuffer>>> zDiff(Publisher<? extends ReactiveZSetCommands.ZDiffCommand> commands)

Diff sorted sets.

Parameters:

commands -

Returns:

Since:

2.6

See Also:

• Redis Documentation: ZDIFF

zDiffWithScores

default Flux<Tuple> zDiffWithScores(List<ByteBuffer> sets)

Diff sorted sets.

Parameters:

sets - must not be null.

Returns:

Since:

2.6

See Also:

• Redis Documentation: ZDIFF

zDiffWithScores

Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZDiffCommand,Flux<Tuple>>> zDiffWithScores(Publisher<? extends ReactiveZSetCommands.ZDiffCommand> commands)

Diff sorted sets.

Parameters:

commands -

Returns:

Since:

2.6

See Also:

• Redis Documentation: ZDIFF

zDiffStore

default Mono<Long> zDiffStore(ByteBuffer destinationKey,
 List<ByteBuffer> sets)

Diff sorted sets and store result in destination destinationKey.

Parameters:

destinationKey - must not be null.

sets - must not be null.

Returns:

Since:

2.6

See Also:

• Redis Documentation: ZDIFFSTORE

zDiffStore

Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZDiffStoreCommand,Long>> zDiffStore(Publisher<ReactiveZSetCommands.ZDiffStoreCommand> commands)

Diff sorted sets and store result in destination destinationKey.

Parameters:

commands -

Returns:

Since:

2.6

See Also:

• Redis Documentation: ZDIFFSTORE

zInter

default Flux<ByteBuffer> zInter(List<ByteBuffer> sets)

Intersect sorted sets.

Parameters:

sets - must not be null.

Returns:

Since:

2.6

See Also:

• Redis Documentation: ZINTER

zInter

Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZAggregateCommand,Flux<ByteBuffer>>> zInter(Publisher<? extends ReactiveZSetCommands.ZAggregateCommand> commands)

Intersect sorted sets by applying aggregateFunction and apply weights to individual sets.

Parameters:

commands -

Returns:

Since:

2.6

See Also:

• Redis Documentation: ZINTER

zInterWithScores

default Flux<Tuple> zInterWithScores(List<ByteBuffer> sets)

Intersect sorted sets.

Parameters:

sets - must not be null.

Returns:

Since:

2.6

See Also:

• Redis Documentation: ZINTER

zInterWithScores

default Flux<Tuple> zInterWithScores(List<ByteBuffer> sets,
 List<Double> weights)

Intersect sorted sets and apply weights to individual sets.

Parameters:

sets - must not be null.

weights - must not be null.

Returns:

Since:

2.6

See Also:

• Redis Documentation: ZINTER

zInterWithScores

default Flux<Tuple> zInterWithScores(List<ByteBuffer> sets,
 Weights weights)

Intersect sorted sets and apply weights to individual sets.

Parameters:

sets - must not be null.

weights - must not be null.

Returns:

Since:

2.6

See Also:

• Redis Documentation: ZINTER

zInterWithScores

default Flux<Tuple> zInterWithScores(List<ByteBuffer> sets,
 List<Double> weights,
 @Nullable
 Aggregate aggregateFunction)

Intersect sorted sets by applying aggregateFunction and apply weights to individual sets.

Parameters:

sets - must not be null.

weights - must not be null.

aggregateFunction - can be null.

Returns:

Since:

2.6

See Also:

• Redis Documentation: ZINTER

zInterWithScores

default Flux<Tuple> zInterWithScores(List<ByteBuffer> sets,
 Weights weights,
 @Nullable
 Aggregate aggregateFunction)

Intersect sorted sets by applying aggregateFunction and apply weights to individual sets.

Parameters:

sets - must not be null.

weights - must not be null.

aggregateFunction - can be null.

Returns:

Since:

2.6

See Also:

• Redis Documentation: ZINTER

zInterWithScores

Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZAggregateCommand,Flux<Tuple>>> zInterWithScores(Publisher<? extends ReactiveZSetCommands.ZAggregateCommand> commands)

Intersect sorted sets by applying aggregateFunction and apply weights to individual sets.

Parameters:

commands -

Returns:

Since:

2.6

See Also:

• Redis Documentation: ZINTER

zInterStore

default 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 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 Mono<Long> zInterStore(ByteBuffer destinationKey,
 List<ByteBuffer> sets,
 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 Mono<Long> zInterStore(ByteBuffer destinationKey,
 List<ByteBuffer> sets,
 List<Double> weights,
 @Nullable
 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 Mono<Long> zInterStore(ByteBuffer destinationKey,
 List<ByteBuffer> sets,
 Weights weights,
 @Nullable
 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

Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZAggregateStoreCommand,Long>> zInterStore(Publisher<? extends ReactiveZSetCommands.ZAggregateStoreCommand> 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

zUnion

default Flux<ByteBuffer> zUnion(List<ByteBuffer> sets)

Union sorted sets.

Parameters:

sets - must not be null.

Returns:

Since:

2.6

See Also:

• Redis Documentation: ZUNION

zUnionWithScores

default Flux<Tuple> zUnionWithScores(List<ByteBuffer> sets)

Union sorted sets.

Parameters:

sets - must not be null.

Returns:

Since:

2.6

See Also:

• Redis Documentation: ZUNION

zUnionWithScores

default Flux<Tuple> zUnionWithScores(List<ByteBuffer> sets,
 List<Double> weights)

Union sorted sets and apply weights to individual sets.

Parameters:

sets - must not be null.

weights - must not be null.

Returns:

Since:

2.6

See Also:

• Redis Documentation: ZUNION

zUnionWithScores

default Flux<Tuple> zUnionWithScores(List<ByteBuffer> sets,
 Weights weights)

Union sorted sets and apply weights to individual sets.

Parameters:

sets - must not be null.

weights - must not be null.

Returns:

Since:

2.6

See Also:

• Redis Documentation: ZUNION

zUnionWithScores

default Flux<Tuple> zUnionWithScores(List<ByteBuffer> sets,
 List<Double> weights,
 @Nullable
 Aggregate aggregateFunction)

Union sorted sets by applying aggregateFunction and apply weights to individual sets.

Parameters:

sets - must not be null.

weights - can be null.

aggregateFunction - can be null.

Returns:

Since:

2.6

See Also:

• Redis Documentation: ZUNION

zUnionWithScores

default Flux<Tuple> zUnionWithScores(List<ByteBuffer> sets,
 Weights weights,
 @Nullable
 Aggregate aggregateFunction)

Union sorted sets by applying aggregateFunction and apply weights to individual sets.

Parameters:

sets - must not be null.

weights - can be null.

aggregateFunction - can be null.

Returns:

Since:

2.6

See Also:

• Redis Documentation: ZUNION

zUnionWithScores

Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZAggregateCommand,Flux<Tuple>>> zUnionWithScores(Publisher<? extends ReactiveZSetCommands.ZAggregateCommand> commands)

Union sorted sets by applying aggregateFunction and apply weights to individual sets.

Parameters:

commands -

Returns:

Since:

2.6

See Also:

• Redis Documentation: ZUNION

zUnion

Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZAggregateCommand,Flux<ByteBuffer>>> zUnion(Publisher<? extends ReactiveZSetCommands.ZAggregateCommand> commands)

Union sorted sets by applying aggregateFunction and apply weights to individual sets.

Parameters:

commands -

Returns:

Since:

2.6

See Also:

• Redis Documentation: ZUNION

zUnionStore

default 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 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 Mono<Long> zUnionStore(ByteBuffer destinationKey,
 List<ByteBuffer> sets,
 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 Mono<Long> zUnionStore(ByteBuffer destinationKey,
 List<ByteBuffer> sets,
 List<Double> weights,
 @Nullable
 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 Mono<Long> zUnionStore(ByteBuffer destinationKey,
 List<ByteBuffer> sets,
 Weights weights,
 @Nullable
 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

Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZAggregateStoreCommand,Long>> zUnionStore(Publisher<? extends ReactiveZSetCommands.ZAggregateStoreCommand> 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

zRangeByLex

default 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 Flux<ByteBuffer> zRangeByLex(ByteBuffer key,
 Range<String> range,
 Limit limit)

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

Parameters:

key - must not be null.

range - must not be null.

limit - can be null.

Returns:

See Also:

• Redis Documentation: ZRANGEBYLEX

zRevRangeByLex

default 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 Flux<ByteBuffer> zRevRangeByLex(ByteBuffer key,
 Range<String> range,
 Limit limit)

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

Parameters:

key - must not be null.

range - must not be null.

limit - must not be null.

Returns:

See Also:

• Redis Documentation: ZREVRANGEBYLEX

zRangeByLex

Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZRangeByLexCommand,Flux<ByteBuffer>>> zRangeByLex(Publisher<ReactiveZSetCommands.ZRangeByLexCommand> commands)

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

Parameters:

commands - must not be null.

Returns:

See Also:

• Redis Documentation: ZRANGEBYLEX
• Redis Documentation: ZREVRANGEBYLEX