org.springframework.data.redis.connection.lettuce

Class LettuceReactiveZSetCommands

java.lang.Object

org.springframework.data.redis.connection.lettuce.LettuceReactiveZSetCommands

All Implemented Interfaces:

ReactiveZSetCommands

Direct Known Subclasses:

LettuceReactiveClusterZSetCommands

public class LettuceReactiveZSetCommands
extends Object
implements ReactiveZSetCommands

Since:

2.0

Author:

Christoph Strobl, Mark Paluch

Nested Class Summary

Nested classes/interfaces inherited from interface org.springframework.data.redis.connection.ReactiveZSetCommands

ReactiveZSetCommands.ZAddCommand, ReactiveZSetCommands.ZCountCommand, ReactiveZSetCommands.ZIncrByCommand, ReactiveZSetCommands.ZInterStoreCommand, ReactiveZSetCommands.ZRangeByLexCommand, ReactiveZSetCommands.ZRangeByScoreCommand, ReactiveZSetCommands.ZRangeCommand, ReactiveZSetCommands.ZRankCommand, ReactiveZSetCommands.ZRemCommand, ReactiveZSetCommands.ZRemRangeByRankCommand, ReactiveZSetCommands.ZRemRangeByScoreCommand, ReactiveZSetCommands.ZScoreCommand, ReactiveZSetCommands.ZUnionStoreCommand

Constructor Summary

Constructors

Constructor and Description
LettuceReactiveZSetCommands(LettuceReactiveRedisConnection connection) Create new LettuceReactiveSetCommands.

Method Summary

Modifier and Type	Method and Description
protected LettuceReactiveRedisConnection	getConnection()
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.
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().
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.
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().
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.
reactor.core.publisher.Flux<ReactiveRedisConnection.MultiValueResponse<ReactiveZSetCommands.ZRangeCommand,RedisZSetCommands.Tuple>>	zRange(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRangeCommand> commands) Get set of RedisZSetCommands.Tuples in range from sorted set.
reactor.core.publisher.Flux<ReactiveRedisConnection.MultiValueResponse<ReactiveZSetCommands.ZRangeByLexCommand,ByteBuffer>>	zRangeByLex(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRangeByLexCommand> commands) Get all elements in Range from the sorted set at key in lexicographical ordering.
reactor.core.publisher.Flux<ReactiveRedisConnection.MultiValueResponse<ReactiveZSetCommands.ZRangeByScoreCommand,RedisZSetCommands.Tuple>>	zRangeByScore(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRangeByScoreCommand> commands) Get RedisZSetCommands.Tuples in range from 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().
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZRemCommand,Long>>	zRem(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRemCommand> commands) Remove ReactiveZSetCommands.ZRemCommand.getValues() from sorted set.
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().
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().
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()
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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.springframework.data.redis.connection.ReactiveZSetCommands

zAdd, zAdd, zCard, zCount, zIncrBy, zInterStore, zInterStore, zInterStore, zRange, zRangeByLex, zRangeByLex, zRangeByScore, zRangeByScore, zRangeByScoreWithScores, zRangeByScoreWithScores, zRangeWithScores, zRank, zRem, zRem, zRemRangeByRank, zRemRangeByScore, zRevRange, zRevRangeByLex, zRevRangeByLex, zRevRangeByScore, zRevRangeByScore, zRevRangeByScoreWithScores, zRevRangeByScoreWithScores, zRevRangeWithScores, zRevRank, zScore, zUnionStore, zUnionStore, zUnionStore

Constructor Detail

LettuceReactiveZSetCommands

public LettuceReactiveZSetCommands(LettuceReactiveRedisConnection connection)

Create new LettuceReactiveSetCommands.

Parameters:

connection - must not be null.

Method Detail

zAdd

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

Description copied from interface: ReactiveZSetCommands

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

Specified by:

zAdd in interface ReactiveZSetCommands

Parameters:

commands - must not be null.

Returns:

See Also:

Redis Documentation: ZADD

zRem

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

Description copied from interface: ReactiveZSetCommands

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

Specified by:

zRem in interface ReactiveZSetCommands

Parameters:

commands - must not be null.

Returns:

See Also:

Redis Documentation: ZREM

zIncrBy

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

Description copied from interface: ReactiveZSetCommands

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

Specified by:

zIncrBy in interface ReactiveZSetCommands

Parameters:

commands - must not be null.

Returns:

See Also:

Redis Documentation: ZINCRBY

zRank

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

Description copied from interface: ReactiveZSetCommands

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

Specified by:

zRank in interface ReactiveZSetCommands

Parameters:

commands - must not be null.

Returns:

See Also:

Redis Documentation: ZRANK, Redis Documentation: ZREVRANK

zRange

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

Description copied from interface: ReactiveZSetCommands

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

Specified by:

zRange in interface ReactiveZSetCommands

Parameters:

commands - must not be null.

Returns:

See Also:

Redis Documentation: ZRANGE, Redis Documentation: ZREVRANGE

zRangeByScore

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

Description copied from interface: ReactiveZSetCommands

Get RedisZSetCommands.Tuples in range from sorted set.

Specified by:

zRangeByScore in interface ReactiveZSetCommands

Parameters:

commands - must not be null.

Returns:

See Also:

Redis Documentation: ZRANGEBYSCORE, Redis Documentation: ZREVRANGEBYSCORE

zCount

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

Description copied from interface: ReactiveZSetCommands

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.

Specified by:

zCount in interface ReactiveZSetCommands

Parameters:

commands - must not be null.

Returns:

See Also:

Redis Documentation: ZCOUNT

zCard

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

Description copied from interface: ReactiveZSetCommands

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

Specified by:

zCard in interface ReactiveZSetCommands

Parameters:

commands - must not be null.

Returns:

See Also:

Redis Documentation: ZCARD

zScore

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

Description copied from interface: ReactiveZSetCommands

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

Specified by:

zScore in interface ReactiveZSetCommands

Parameters:

commands - must not be null.

Returns:

See Also:

Redis Documentation: ZSCORE

zRemRangeByRank

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

Description copied from interface: ReactiveZSetCommands

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

Specified by:

zRemRangeByRank in interface ReactiveZSetCommands

Parameters:

commands - must not be null.

Returns:

See Also:

Redis Documentation: ZREMRANGEBYRANK

zRemRangeByScore

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

Description copied from interface: ReactiveZSetCommands

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

Specified by:

zRemRangeByScore in interface ReactiveZSetCommands

Parameters:

commands - must not be null.

Returns:

See Also:

Redis Documentation: ZREMRANGEBYSCORE

zUnionStore

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

Description copied from interface: ReactiveZSetCommands

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

Specified by:

zUnionStore in interface ReactiveZSetCommands

Returns:

See Also:

Redis Documentation: ZUNIONSTORE

zInterStore

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

Description copied from interface: ReactiveZSetCommands

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

Specified by:

zInterStore in interface ReactiveZSetCommands

Returns:

See Also:

Redis Documentation: ZINTERSTORE

zRangeByLex

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

Description copied from interface: ReactiveZSetCommands

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().

Specified by:

zRangeByLex in interface ReactiveZSetCommands

Parameters:

commands - must not be null.

Returns:

See Also:

Redis Documentation: ZRANGEBYLEX, Redis Documentation: ZREVRANGEBYLEX

getConnection

protected LettuceReactiveRedisConnection getConnection()