Uses of Interface
org.springframework.data.redis.connection.zset.Tuple
Package
Description
Connection package providing low-level abstractions for interacting with the various Redis 'drivers'/libraries.
Redis specific converters used for sending data and parsing responses.
Connection package for Lettuce Redis client.
-
Uses of Tuple in org.springframework.data.redis.connection
Modifier and TypeInterfaceDescriptionstatic interface
String-friendly ZSet tuple.Modifier and TypeClassDescriptionclass
Default implementation forStringRedisConnection.StringTuple
interface.Modifier and TypeMethodDescriptiondefault Tuple
Deprecated.Remove and return the value with its score having the highest score from sorted set atkey
.default Tuple
Deprecated.in favor ofRedisCommandsProvider.zSetCommands()
}.Remove and return the value with its score having the lowest score from sorted set atkey
.default Tuple
DefaultedRedisConnection.zPopMax
(byte[] key) Deprecated.in favor ofRedisCommandsProvider.zSetCommands()
}.DefaultStringRedisConnection.zPopMax
(byte[] key) RedisZSetCommands.zPopMax
(byte[] key) Remove and return the value with its score having the highest score from sorted set atkey
.default Tuple
DefaultedRedisConnection.zPopMin
(byte[] key) Deprecated.in favor ofRedisCommandsProvider.zSetCommands()
}.DefaultStringRedisConnection.zPopMin
(byte[] key) RedisZSetCommands.zPopMin
(byte[] key) Remove and return the value with its score having the lowest score from sorted set atkey
.Remove and return the value with its score having the lowest score from sorted set atkey
.default Tuple
DefaultedRedisConnection.zRandMemberWithScore
(byte[] key) Deprecated.in favor ofRedisCommandsProvider.zSetCommands()
}.DefaultStringRedisConnection.zRandMemberWithScore
(byte[] key) RedisZSetCommands.zRandMemberWithScore
(byte[] key) Get random element from sorted set atkey
.Modifier and TypeMethodDescriptionreactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.BZPopCommand,
reactor.core.publisher.Flux<Tuple>>> ReactiveZSetCommands.bZPop
(org.reactivestreams.Publisher<ReactiveZSetCommands.BZPopCommand> commands) Remove and return elements from sorted set atkeyCommand#getKey()
.default reactor.core.publisher.Mono<Tuple>
ReactiveZSetCommands.bZPopMax
(ByteBuffer key, Duration timeout) Remove and return the value with its score having the highest score from sorted set atkey
.default reactor.core.publisher.Mono<Tuple>
ReactiveZSetCommands.bZPopMin
(ByteBuffer key, Duration timeout) Remove and return the value with its score having the lowest score from sorted set atkey
.ReactiveZSetCommands.ZAddCommand.getTuples()
DefaultedRedisConnection.zDiffWithScores
(byte[]... sets) Deprecated.in favor ofRedisCommandsProvider.zSetCommands()
}.DefaultStringRedisConnection.zDiffWithScores
(byte[]... sets) default reactor.core.publisher.Flux<Tuple>
ReactiveZSetCommands.zDiffWithScores
(List<ByteBuffer> sets) Diff sorted sets.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZDiffCommand,
reactor.core.publisher.Flux<Tuple>>> ReactiveZSetCommands.zDiffWithScores
(org.reactivestreams.Publisher<? extends ReactiveZSetCommands.ZDiffCommand> commands) Diff sorted sets.RedisZSetCommands.zDiffWithScores
(byte[]... sets) Diff sortedsets
.DefaultedRedisConnection.zInterWithScores
(byte[]... sets) Deprecated.in favor ofRedisCommandsProvider.zSetCommands()
}.DefaultedRedisConnection.zInterWithScores
(Aggregate aggregate, int[] weights, byte[]... sets) Deprecated.in favor ofRedisCommandsProvider.zSetCommands()
}.DefaultedRedisConnection.zInterWithScores
(Aggregate aggregate, Weights weights, byte[]... sets) Deprecated.in favor ofRedisCommandsProvider.zSetCommands()
}.DefaultStringRedisConnection.zInterWithScores
(byte[]... sets) DefaultStringRedisConnection.zInterWithScores
(Aggregate aggregate, Weights weights, byte[]... sets) default reactor.core.publisher.Flux<Tuple>
ReactiveZSetCommands.zInterWithScores
(List<ByteBuffer> sets) Intersect sorted sets.default reactor.core.publisher.Flux<Tuple>
ReactiveZSetCommands.zInterWithScores
(List<ByteBuffer> sets, List<Double> weights) Intersect sorted sets and apply weights to individual sets.default reactor.core.publisher.Flux<Tuple>
ReactiveZSetCommands.zInterWithScores
(List<ByteBuffer> sets, List<Double> weights, Aggregate aggregateFunction) Intersect sorted sets by applying aggregateFunction and apply weights to individual sets.default reactor.core.publisher.Flux<Tuple>
ReactiveZSetCommands.zInterWithScores
(List<ByteBuffer> sets, Weights weights) Intersect sorted sets and apply weights to individual sets.default reactor.core.publisher.Flux<Tuple>
ReactiveZSetCommands.zInterWithScores
(List<ByteBuffer> sets, Weights weights, Aggregate aggregateFunction) Intersect sorted sets by applying aggregateFunction and apply weights to individual sets.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZAggregateCommand,
reactor.core.publisher.Flux<Tuple>>> ReactiveZSetCommands.zInterWithScores
(org.reactivestreams.Publisher<? extends ReactiveZSetCommands.ZAggregateCommand> commands) Intersect sorted sets by applying aggregateFunction and apply weights to individual sets.RedisZSetCommands.zInterWithScores
(byte[]... sets) Intersect sortedsets
.RedisZSetCommands.zInterWithScores
(Aggregate aggregate, int[] weights, byte[]... sets) Intersect sortedsets
.RedisZSetCommands.zInterWithScores
(Aggregate aggregate, Weights weights, byte[]... sets) Intersect sortedsets
.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZPopCommand,
reactor.core.publisher.Flux<Tuple>>> ReactiveZSetCommands.zPop
(org.reactivestreams.Publisher<ReactiveZSetCommands.ZPopCommand> commands) Remove and return elements from sorted set atkeyCommand#getKey()
.DefaultedRedisConnection.zPopMax
(byte[] key, long count) Deprecated.in favor ofRedisCommandsProvider.zSetCommands()
}.DefaultStringRedisConnection.zPopMax
(byte[] key, long count) default reactor.core.publisher.Mono<Tuple>
ReactiveZSetCommands.zPopMax
(ByteBuffer key) Remove and return the value with its score having the highest score from sorted set atkey
.default reactor.core.publisher.Flux<Tuple>
ReactiveZSetCommands.zPopMax
(ByteBuffer key, long count) Remove and returncount
values with their score having the highest score from sorted set atkey
.RedisZSetCommands.zPopMax
(byte[] key, long count) Remove and returncount
values with their score having the highest score from sorted set atkey
.DefaultedRedisConnection.zPopMin
(byte[] key, long count) Deprecated.in favor ofRedisCommandsProvider.zSetCommands()
}.DefaultStringRedisConnection.zPopMin
(byte[] key, long count) default reactor.core.publisher.Mono<Tuple>
ReactiveZSetCommands.zPopMin
(ByteBuffer key) Remove and return the value with its score having the lowest score from sorted set atkey
.default reactor.core.publisher.Flux<Tuple>
ReactiveZSetCommands.zPopMin
(ByteBuffer key, long count) Remove and returncount
values with their score having the lowest score from sorted set atkey
.RedisZSetCommands.zPopMin
(byte[] key, long count) Remove and returncount
values with their score having the lowest score from sorted set atkey
.DefaultedRedisConnection.zRandMemberWithScore
(byte[] key, long count) Deprecated.in favor ofRedisCommandsProvider.zSetCommands()
}.DefaultStringRedisConnection.zRandMemberWithScore
(byte[] key, long count) default reactor.core.publisher.Mono<Tuple>
ReactiveZSetCommands.zRandMemberWithScore
(ByteBuffer key) Get random element from sorted set atkey
.default reactor.core.publisher.Flux<Tuple>
ReactiveZSetCommands.zRandMemberWithScore
(ByteBuffer key, long count) Getcount
random elements from sorted set atkey
.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZRandMemberCommand,
reactor.core.publisher.Flux<Tuple>>> ReactiveZSetCommands.zRandMemberWithScore
(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRandMemberCommand> commands) Get random elements from sorted set atkey
.RedisZSetCommands.zRandMemberWithScore
(byte[] key, long count) Getcount
random elements from sorted set atkey
.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZRangeCommand,
reactor.core.publisher.Flux<Tuple>>> ReactiveZSetCommands.zRange
(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRangeCommand> commands) Get set ofTuple
s in range from sorted set.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZRangeByScoreCommand,
reactor.core.publisher.Flux<Tuple>>> ReactiveZSetCommands.zRangeByScore
(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRangeByScoreCommand> commands) GetTuple
s in range from sorted set.DefaultedRedisConnection.zRangeByScoreWithScores
(byte[] key, org.springframework.data.domain.Range<? extends Number> range, Limit limit) Deprecated.in favor ofRedisCommandsProvider.zSetCommands()
}.DefaultStringRedisConnection.zRangeByScoreWithScores
(byte[] key, double min, double max) DefaultStringRedisConnection.zRangeByScoreWithScores
(byte[] key, double min, double max, long offset, long count) DefaultStringRedisConnection.zRangeByScoreWithScores
(byte[] key, org.springframework.data.domain.Range<? extends Number> range) DefaultStringRedisConnection.zRangeByScoreWithScores
(byte[] key, org.springframework.data.domain.Range<? extends Number> range, Limit limit) default reactor.core.publisher.Flux<Tuple>
ReactiveZSetCommands.zRangeByScoreWithScores
(ByteBuffer key, org.springframework.data.domain.Range<Double> range) GetTuple
s in range from sorted set.default reactor.core.publisher.Flux<Tuple>
ReactiveZSetCommands.zRangeByScoreWithScores
(ByteBuffer key, org.springframework.data.domain.Range<Double> range, Limit limit) GetTuple
s in range from sorted set.RedisZSetCommands.zRangeByScoreWithScores
(byte[] key, double min, double max) RedisZSetCommands.zRangeByScoreWithScores
(byte[] key, double min, double max, long offset, long count) RedisZSetCommands.zRangeByScoreWithScores
(byte[] key, org.springframework.data.domain.Range<? extends Number> range) RedisZSetCommands.zRangeByScoreWithScores
(byte[] key, org.springframework.data.domain.Range<? extends Number> range, Limit limit) Get set ofTuple
s in range fromLimit#offset
toLimit#offset + Limit#count
where score is betweenRange#min
andRange#max
from sorted set.DefaultedRedisConnection.zRangeWithScores
(byte[] key, long start, long end) Deprecated.in favor ofRedisCommandsProvider.zSetCommands()
}.DefaultStringRedisConnection.zRangeWithScores
(byte[] key, long start, long end) default reactor.core.publisher.Flux<Tuple>
ReactiveZSetCommands.zRangeWithScores
(ByteBuffer key, org.springframework.data.domain.Range<Long> range) Get set ofTuple
s in range from sorted set.RedisZSetCommands.zRangeWithScores
(byte[] key, long start, long end) DefaultedRedisConnection.zRevRangeByScoreWithScores
(byte[] key, org.springframework.data.domain.Range<? extends Number> range, Limit limit) Deprecated.in favor ofRedisCommandsProvider.zSetCommands()
}.DefaultStringRedisConnection.zRevRangeByScoreWithScores
(byte[] key, double min, double max) DefaultStringRedisConnection.zRevRangeByScoreWithScores
(byte[] key, double min, double max, long offset, long count) DefaultStringRedisConnection.zRevRangeByScoreWithScores
(byte[] key, org.springframework.data.domain.Range<? extends Number> range) DefaultStringRedisConnection.zRevRangeByScoreWithScores
(byte[] key, org.springframework.data.domain.Range<? extends Number> range, Limit limit) default reactor.core.publisher.Flux<Tuple>
ReactiveZSetCommands.zRevRangeByScoreWithScores
(ByteBuffer key, org.springframework.data.domain.Range<Double> range) Get set ofTuple
s in range from sorted set in reverse score ordering.default reactor.core.publisher.Flux<Tuple>
ReactiveZSetCommands.zRevRangeByScoreWithScores
(ByteBuffer key, org.springframework.data.domain.Range<Double> range, Limit limit) GetTuple
s in range from sorted set in reverse score ordering.RedisZSetCommands.zRevRangeByScoreWithScores
(byte[] key, double min, double max) RedisZSetCommands.zRevRangeByScoreWithScores
(byte[] key, double min, double max, long offset, long count) Get set ofTuple
in range fromstart
toend
where score is betweenmin
andmax
from sorted set ordered high -> low.RedisZSetCommands.zRevRangeByScoreWithScores
(byte[] key, org.springframework.data.domain.Range<? extends Number> range) Get set ofTuple
where score is betweenRange#min
andRange#max
from sorted set ordered from high to low.RedisZSetCommands.zRevRangeByScoreWithScores
(byte[] key, org.springframework.data.domain.Range<? extends Number> range, Limit limit) Get set ofTuple
in range fromLimit#offset
toLimit#count
where score is betweenRange#min
andRange#max
from sorted set ordered high -> low.DefaultedRedisConnection.zRevRangeWithScores
(byte[] key, long start, long end) Deprecated.in favor ofRedisCommandsProvider.zSetCommands()
}.DefaultStringRedisConnection.zRevRangeWithScores
(byte[] key, long start, long end) default reactor.core.publisher.Flux<Tuple>
ReactiveZSetCommands.zRevRangeWithScores
(ByteBuffer key, org.springframework.data.domain.Range<Long> range) Get set ofTuple
s in range from sorted set in reverse score ordering.RedisZSetCommands.zRevRangeWithScores
(byte[] key, long start, long end) DefaultedRedisConnection.zScan
(byte[] key, ScanOptions options) Deprecated.in favor ofRedisCommandsProvider.zSetCommands()
}.DefaultStringRedisConnection.zScan
(byte[] key, ScanOptions options) default reactor.core.publisher.Flux<Tuple>
ReactiveZSetCommands.zScan
(ByteBuffer key) Use aFlux
to iterate over members in the sorted set atkey
.default reactor.core.publisher.Flux<Tuple>
ReactiveZSetCommands.zScan
(ByteBuffer key, ScanOptions options) reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,
reactor.core.publisher.Flux<Tuple>>> ReactiveZSetCommands.zScan
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyScanCommand> commands) Use aFlux
to iterate over members in the sorted set atkey
.RedisZSetCommands.zScan
(byte[] key, ScanOptions options) Use aCursor
to iterate over elements in sorted set atkey
.DefaultedRedisConnection.zUnionWithScores
(byte[]... sets) Deprecated.in favor ofRedisCommandsProvider.zSetCommands()
}.DefaultedRedisConnection.zUnionWithScores
(Aggregate aggregate, int[] weights, byte[]... sets) Deprecated.in favor ofRedisCommandsProvider.zSetCommands()
}.DefaultedRedisConnection.zUnionWithScores
(Aggregate aggregate, Weights weights, byte[]... sets) Deprecated.in favor ofRedisCommandsProvider.zSetCommands()
}.DefaultStringRedisConnection.zUnionWithScores
(byte[]... sets) DefaultStringRedisConnection.zUnionWithScores
(Aggregate aggregate, Weights weights, byte[]... sets) default reactor.core.publisher.Flux<Tuple>
ReactiveZSetCommands.zUnionWithScores
(List<ByteBuffer> sets) Union sorted sets.default reactor.core.publisher.Flux<Tuple>
ReactiveZSetCommands.zUnionWithScores
(List<ByteBuffer> sets, List<Double> weights) Union sorted sets and apply weights to individual sets.default reactor.core.publisher.Flux<Tuple>
ReactiveZSetCommands.zUnionWithScores
(List<ByteBuffer> sets, List<Double> weights, Aggregate aggregateFunction) Union sorted sets by applying aggregateFunction and apply weights to individual sets.default reactor.core.publisher.Flux<Tuple>
ReactiveZSetCommands.zUnionWithScores
(List<ByteBuffer> sets, Weights weights) Union sorted sets and apply weights to individual sets.default reactor.core.publisher.Flux<Tuple>
ReactiveZSetCommands.zUnionWithScores
(List<ByteBuffer> sets, Weights weights, Aggregate aggregateFunction) Union sorted sets by applying aggregateFunction and apply weights to individual sets.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZAggregateCommand,
reactor.core.publisher.Flux<Tuple>>> ReactiveZSetCommands.zUnionWithScores
(org.reactivestreams.Publisher<? extends ReactiveZSetCommands.ZAggregateCommand> commands) Union sorted sets by applying aggregateFunction and apply weights to individual sets.RedisZSetCommands.zUnionWithScores
(byte[]... sets) Union sortedsets
.RedisZSetCommands.zUnionWithScores
(Aggregate aggregate, int[] weights, byte[]... sets) Union sortedsets
.RedisZSetCommands.zUnionWithScores
(Aggregate aggregate, Weights weights, byte[]... sets) Union sortedsets
.Modifier and TypeMethodDescriptionReactiveZSetCommands.ZAddCommand.tuples
(Collection<? extends Tuple> tuples) default Long
DefaultedRedisConnection.zAdd
(byte[] key, Set<Tuple> tuples, RedisZSetCommands.ZAddArgs args) Deprecated.in favor ofRedisCommandsProvider.zSetCommands()
}.DefaultStringRedisConnection.zAdd
(byte[] key, Set<Tuple> tuples, RedisZSetCommands.ZAddArgs args) default reactor.core.publisher.Mono<Long>
ReactiveZSetCommands.zAdd
(ByteBuffer key, Collection<? extends Tuple> tuples) Add a tuples to a sorted set at key, or update their score if it already exists.default Long
Addtuples
to a sorted set atkey
, or update itsscore
if it already exists.RedisZSetCommands.zAdd
(byte[] key, Set<Tuple> tuples, RedisZSetCommands.ZAddArgs args) ModifierConstructorDescriptionDefaultStringTuple
(Tuple tuple, String valueAsString) Constructs a newDefaultStringTuple
instance. -
Uses of Tuple in org.springframework.data.redis.connection.convert
-
Uses of Tuple in org.springframework.data.redis.connection.lettuce
Modifier and TypeMethodDescriptionstatic Tuple
LettuceConverters.toTuple
(io.lettuce.core.ScoredValue<byte[]> source) -
Uses of Tuple in org.springframework.data.redis.connection.zset
RedisCommandsProvider.zSetCommands()
}.