Uses of Interface
io.lettuce.core.output.ScoredValueStreamingChannel
-
Packages that use ScoredValueStreamingChannel Package Description io.lettuce.core The Redis client package containingRedisClient
for Redis Standalone and Redis Sentinel operations.io.lettuce.core.api.async Standalone Redis API for asynchronous executed commands.io.lettuce.core.api.reactive Standalone Redis API for reactive command execution.io.lettuce.core.api.sync Standalone Redis API for synchronous executed commands.io.lettuce.core.cluster.api.async Redis Cluster API for asynchronous executed commands.io.lettuce.core.cluster.api.sync Redis Cluster API for synchronous executed commands.io.lettuce.core.output Implementation of different output protocols including the Streaming API. -
-
Uses of ScoredValueStreamingChannel in io.lettuce.core
Methods in io.lettuce.core with parameters of type ScoredValueStreamingChannel Modifier and Type Method Description RedisFuture<Long>
AbstractRedisAsyncCommands. zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, double min, double max)
RedisFuture<Long>
AbstractRedisAsyncCommands. zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, double min, double max, long offset, long count)
RedisFuture<Long>
AbstractRedisAsyncCommands. zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, Range<? extends Number> range)
RedisFuture<Long>
AbstractRedisAsyncCommands. zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, Range<? extends Number> range, Limit limit)
RedisFuture<Long>
AbstractRedisAsyncCommands. zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, String min, String max)
RedisFuture<Long>
AbstractRedisAsyncCommands. zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, String min, String max, long offset, long count)
Mono<Long>
AbstractRedisReactiveCommands. zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, double min, double max)
Mono<Long>
AbstractRedisReactiveCommands. zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, double min, double max, long offset, long count)
Mono<Long>
AbstractRedisReactiveCommands. zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, Range<? extends Number> range)
Mono<Long>
AbstractRedisReactiveCommands. zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, Range<? extends Number> range, Limit limit)
Mono<Long>
AbstractRedisReactiveCommands. zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, String min, String max)
Mono<Long>
AbstractRedisReactiveCommands. zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, String min, String max, long offset, long count)
RedisFuture<Long>
AbstractRedisAsyncCommands. zrangeWithScores(ScoredValueStreamingChannel<V> channel, K key, long start, long stop)
Mono<Long>
AbstractRedisReactiveCommands. zrangeWithScores(ScoredValueStreamingChannel<V> channel, K key, long start, long stop)
RedisFuture<Long>
AbstractRedisAsyncCommands. zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, double max, double min)
RedisFuture<Long>
AbstractRedisAsyncCommands. zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, double max, double min, long offset, long count)
RedisFuture<Long>
AbstractRedisAsyncCommands. zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, Range<? extends Number> range)
RedisFuture<Long>
AbstractRedisAsyncCommands. zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, Range<? extends Number> range, Limit limit)
RedisFuture<Long>
AbstractRedisAsyncCommands. zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, String max, String min)
RedisFuture<Long>
AbstractRedisAsyncCommands. zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, String max, String min, long offset, long count)
Mono<Long>
AbstractRedisReactiveCommands. zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, double max, double min)
Mono<Long>
AbstractRedisReactiveCommands. zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, double max, double min, long offset, long count)
Mono<Long>
AbstractRedisReactiveCommands. zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, Range<? extends Number> range)
Mono<Long>
AbstractRedisReactiveCommands. zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, Range<? extends Number> range, Limit limit)
Mono<Long>
AbstractRedisReactiveCommands. zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, String max, String min)
Mono<Long>
AbstractRedisReactiveCommands. zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, String max, String min, long offset, long count)
RedisFuture<Long>
AbstractRedisAsyncCommands. zrevrangeWithScores(ScoredValueStreamingChannel<V> channel, K key, long start, long stop)
Mono<Long>
AbstractRedisReactiveCommands. zrevrangeWithScores(ScoredValueStreamingChannel<V> channel, K key, long start, long stop)
RedisFuture<StreamScanCursor>
AbstractRedisAsyncCommands. zscan(ScoredValueStreamingChannel<V> channel, K key)
RedisFuture<StreamScanCursor>
AbstractRedisAsyncCommands. zscan(ScoredValueStreamingChannel<V> channel, K key, ScanArgs scanArgs)
RedisFuture<StreamScanCursor>
AbstractRedisAsyncCommands. zscan(ScoredValueStreamingChannel<V> channel, K key, ScanCursor scanCursor)
RedisFuture<StreamScanCursor>
AbstractRedisAsyncCommands. zscan(ScoredValueStreamingChannel<V> channel, K key, ScanCursor scanCursor, ScanArgs scanArgs)
Mono<StreamScanCursor>
AbstractRedisReactiveCommands. zscan(ScoredValueStreamingChannel<V> channel, K key)
Mono<StreamScanCursor>
AbstractRedisReactiveCommands. zscan(ScoredValueStreamingChannel<V> channel, K key, ScanArgs scanArgs)
Mono<StreamScanCursor>
AbstractRedisReactiveCommands. zscan(ScoredValueStreamingChannel<V> channel, K key, ScanCursor scanCursor)
Mono<StreamScanCursor>
AbstractRedisReactiveCommands. zscan(ScoredValueStreamingChannel<V> channel, K key, ScanCursor scanCursor, ScanArgs scanArgs)
-
Uses of ScoredValueStreamingChannel in io.lettuce.core.api.async
Methods in io.lettuce.core.api.async with parameters of type ScoredValueStreamingChannel Modifier and Type Method Description RedisFuture<Long>
RedisSortedSetAsyncCommands. zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, double min, double max)
RedisFuture<Long>
RedisSortedSetAsyncCommands. zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, double min, double max, long offset, long count)
RedisFuture<Long>
RedisSortedSetAsyncCommands. zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, Range<? extends Number> range)
Stream over a range of members with scores in a sorted set, by score.RedisFuture<Long>
RedisSortedSetAsyncCommands. zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, Range<? extends Number> range, Limit limit)
Stream over a range of members with scores in a sorted set, by score.RedisFuture<Long>
RedisSortedSetAsyncCommands. zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, String min, String max)
RedisFuture<Long>
RedisSortedSetAsyncCommands. zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, String min, String max, long offset, long count)
RedisFuture<Long>
RedisSortedSetAsyncCommands. zrangeWithScores(ScoredValueStreamingChannel<V> channel, K key, long start, long stop)
Stream over a range of members with scores in a sorted set, by index.RedisFuture<Long>
RedisSortedSetAsyncCommands. zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, double max, double min)
RedisFuture<Long>
RedisSortedSetAsyncCommands. zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, double max, double min, long offset, long count)
RedisFuture<Long>
RedisSortedSetAsyncCommands. zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, Range<? extends Number> range)
Stream over a range of members with scores in a sorted set, by score, with scores ordered from high to low.RedisFuture<Long>
RedisSortedSetAsyncCommands. zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, Range<? extends Number> range, Limit limit)
Stream over a range of members with scores in a sorted set, by score, with scores ordered from high to low.RedisFuture<Long>
RedisSortedSetAsyncCommands. zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, String max, String min)
RedisFuture<Long>
RedisSortedSetAsyncCommands. zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, String max, String min, long offset, long count)
RedisFuture<Long>
RedisSortedSetAsyncCommands. zrevrangeWithScores(ScoredValueStreamingChannel<V> channel, K key, long start, long stop)
Stream over a range of members with scores in a sorted set, by index, with scores ordered from high to low.RedisFuture<StreamScanCursor>
RedisSortedSetAsyncCommands. zscan(ScoredValueStreamingChannel<V> channel, K key)
Incrementally iterate sorted sets elements and associated scores.RedisFuture<StreamScanCursor>
RedisSortedSetAsyncCommands. zscan(ScoredValueStreamingChannel<V> channel, K key, ScanArgs scanArgs)
Incrementally iterate sorted sets elements and associated scores.RedisFuture<StreamScanCursor>
RedisSortedSetAsyncCommands. zscan(ScoredValueStreamingChannel<V> channel, K key, ScanCursor scanCursor)
Incrementally iterate sorted sets elements and associated scores.RedisFuture<StreamScanCursor>
RedisSortedSetAsyncCommands. zscan(ScoredValueStreamingChannel<V> channel, K key, ScanCursor scanCursor, ScanArgs scanArgs)
Incrementally iterate sorted sets elements and associated scores. -
Uses of ScoredValueStreamingChannel in io.lettuce.core.api.reactive
Methods in io.lettuce.core.api.reactive with parameters of type ScoredValueStreamingChannel Modifier and Type Method Description Mono<Long>
RedisSortedSetReactiveCommands. zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, double min, double max)
Mono<Long>
RedisSortedSetReactiveCommands. zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, double min, double max, long offset, long count)
Mono<Long>
RedisSortedSetReactiveCommands. zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, Range<? extends Number> range)
Deprecated.since 6.0 in favor of consuming large results through thePublisher
returned byRedisSortedSetReactiveCommands.zrangebyscoreWithScores(K, double, double)
.Mono<Long>
RedisSortedSetReactiveCommands. zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, Range<? extends Number> range, Limit limit)
Deprecated.since 6.0 in favor of consuming large results through thePublisher
returned byRedisSortedSetReactiveCommands.zrangebyscoreWithScores(K, double, double)
.Mono<Long>
RedisSortedSetReactiveCommands. zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, String min, String max)
Mono<Long>
RedisSortedSetReactiveCommands. zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, String min, String max, long offset, long count)
Mono<Long>
RedisSortedSetReactiveCommands. zrangeWithScores(ScoredValueStreamingChannel<V> channel, K key, long start, long stop)
Deprecated.since 6.0 in favor of consuming large results through thePublisher
returned byRedisSortedSetReactiveCommands.zrangeWithScores(K, long, long)
.Mono<Long>
RedisSortedSetReactiveCommands. zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, double max, double min)
Mono<Long>
RedisSortedSetReactiveCommands. zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, double max, double min, long offset, long count)
Mono<Long>
RedisSortedSetReactiveCommands. zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, Range<? extends Number> range)
Deprecated.since 6.0 in favor of consuming large results through thePublisher
returned byRedisSortedSetReactiveCommands.zrevrangebyscoreWithScores(K, double, double)
.Mono<Long>
RedisSortedSetReactiveCommands. zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, Range<? extends Number> range, Limit limit)
Deprecated.since 6.0 in favor of consuming large results through thePublisher
returned byRedisSortedSetReactiveCommands.zrevrangebyscoreWithScores(K, double, double)
.Mono<Long>
RedisSortedSetReactiveCommands. zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, String max, String min)
Mono<Long>
RedisSortedSetReactiveCommands. zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, String max, String min, long offset, long count)
Mono<Long>
RedisSortedSetReactiveCommands. zrevrangeWithScores(ScoredValueStreamingChannel<V> channel, K key, long start, long stop)
Deprecated.since 6.0 in favor of consuming large results through thePublisher
returned byRedisSortedSetReactiveCommands.zrevrangeWithScores(K, long, long)
.Mono<StreamScanCursor>
RedisSortedSetReactiveCommands. zscan(ScoredValueStreamingChannel<V> channel, K key)
Deprecated.since 6.0 in favor of consuming large results through thePublisher
returned byRedisSortedSetReactiveCommands.zscan(K)
.Mono<StreamScanCursor>
RedisSortedSetReactiveCommands. zscan(ScoredValueStreamingChannel<V> channel, K key, ScanArgs scanArgs)
Deprecated.since 6.0 in favor of consuming large results through thePublisher
returned byRedisSortedSetReactiveCommands.zscan(K)
.Mono<StreamScanCursor>
RedisSortedSetReactiveCommands. zscan(ScoredValueStreamingChannel<V> channel, K key, ScanCursor scanCursor)
Deprecated.since 6.0 in favor of consuming large results through thePublisher
returned byRedisSortedSetReactiveCommands.zscan(K)
.Mono<StreamScanCursor>
RedisSortedSetReactiveCommands. zscan(ScoredValueStreamingChannel<V> channel, K key, ScanCursor scanCursor, ScanArgs scanArgs)
Deprecated.since 6.0 in favor of consuming large results through thePublisher
returned byRedisSortedSetReactiveCommands.zscan(K)
. -
Uses of ScoredValueStreamingChannel in io.lettuce.core.api.sync
Methods in io.lettuce.core.api.sync with parameters of type ScoredValueStreamingChannel Modifier and Type Method Description Long
RedisSortedSetCommands. zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, double min, double max)
Long
RedisSortedSetCommands. zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, double min, double max, long offset, long count)
Long
RedisSortedSetCommands. zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, Range<? extends Number> range)
Stream over a range of members with scores in a sorted set, by score.Long
RedisSortedSetCommands. zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, Range<? extends Number> range, Limit limit)
Stream over a range of members with scores in a sorted set, by score.Long
RedisSortedSetCommands. zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, String min, String max)
Long
RedisSortedSetCommands. zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, String min, String max, long offset, long count)
Long
RedisSortedSetCommands. zrangeWithScores(ScoredValueStreamingChannel<V> channel, K key, long start, long stop)
Stream over a range of members with scores in a sorted set, by index.Long
RedisSortedSetCommands. zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, double max, double min)
Long
RedisSortedSetCommands. zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, double max, double min, long offset, long count)
Long
RedisSortedSetCommands. zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, Range<? extends Number> range)
Stream over a range of members with scores in a sorted set, by score, with scores ordered from high to low.Long
RedisSortedSetCommands. zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, Range<? extends Number> range, Limit limit)
Stream over a range of members with scores in a sorted set, by score, with scores ordered from high to low.Long
RedisSortedSetCommands. zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, String max, String min)
Long
RedisSortedSetCommands. zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, String max, String min, long offset, long count)
Long
RedisSortedSetCommands. zrevrangeWithScores(ScoredValueStreamingChannel<V> channel, K key, long start, long stop)
Stream over a range of members with scores in a sorted set, by index, with scores ordered from high to low.StreamScanCursor
RedisSortedSetCommands. zscan(ScoredValueStreamingChannel<V> channel, K key)
Incrementally iterate sorted sets elements and associated scores.StreamScanCursor
RedisSortedSetCommands. zscan(ScoredValueStreamingChannel<V> channel, K key, ScanArgs scanArgs)
Incrementally iterate sorted sets elements and associated scores.StreamScanCursor
RedisSortedSetCommands. zscan(ScoredValueStreamingChannel<V> channel, K key, ScanCursor scanCursor)
Incrementally iterate sorted sets elements and associated scores.StreamScanCursor
RedisSortedSetCommands. zscan(ScoredValueStreamingChannel<V> channel, K key, ScanCursor scanCursor, ScanArgs scanArgs)
Incrementally iterate sorted sets elements and associated scores. -
Uses of ScoredValueStreamingChannel in io.lettuce.core.cluster.api.async
Methods in io.lettuce.core.cluster.api.async with parameters of type ScoredValueStreamingChannel Modifier and Type Method Description AsyncExecutions<Long>
NodeSelectionSortedSetAsyncCommands. zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, double min, double max)
AsyncExecutions<Long>
NodeSelectionSortedSetAsyncCommands. zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, double min, double max, long offset, long count)
AsyncExecutions<Long>
NodeSelectionSortedSetAsyncCommands. zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, Range<? extends Number> range)
Stream over a range of members with scores in a sorted set, by score.AsyncExecutions<Long>
NodeSelectionSortedSetAsyncCommands. zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, Range<? extends Number> range, Limit limit)
Stream over a range of members with scores in a sorted set, by score.AsyncExecutions<Long>
NodeSelectionSortedSetAsyncCommands. zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, String min, String max)
AsyncExecutions<Long>
NodeSelectionSortedSetAsyncCommands. zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, String min, String max, long offset, long count)
AsyncExecutions<Long>
NodeSelectionSortedSetAsyncCommands. zrangeWithScores(ScoredValueStreamingChannel<V> channel, K key, long start, long stop)
Stream over a range of members with scores in a sorted set, by index.AsyncExecutions<Long>
NodeSelectionSortedSetAsyncCommands. zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, double max, double min)
AsyncExecutions<Long>
NodeSelectionSortedSetAsyncCommands. zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, double max, double min, long offset, long count)
AsyncExecutions<Long>
NodeSelectionSortedSetAsyncCommands. zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, Range<? extends Number> range)
Stream over a range of members with scores in a sorted set, by score, with scores ordered from high to low.AsyncExecutions<Long>
NodeSelectionSortedSetAsyncCommands. zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, Range<? extends Number> range, Limit limit)
Stream over a range of members with scores in a sorted set, by score, with scores ordered from high to low.AsyncExecutions<Long>
NodeSelectionSortedSetAsyncCommands. zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, String max, String min)
AsyncExecutions<Long>
NodeSelectionSortedSetAsyncCommands. zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, String max, String min, long offset, long count)
AsyncExecutions<Long>
NodeSelectionSortedSetAsyncCommands. zrevrangeWithScores(ScoredValueStreamingChannel<V> channel, K key, long start, long stop)
Stream over a range of members with scores in a sorted set, by index, with scores ordered from high to low.AsyncExecutions<StreamScanCursor>
NodeSelectionSortedSetAsyncCommands. zscan(ScoredValueStreamingChannel<V> channel, K key)
Incrementally iterate sorted sets elements and associated scores.AsyncExecutions<StreamScanCursor>
NodeSelectionSortedSetAsyncCommands. zscan(ScoredValueStreamingChannel<V> channel, K key, ScanArgs scanArgs)
Incrementally iterate sorted sets elements and associated scores.AsyncExecutions<StreamScanCursor>
NodeSelectionSortedSetAsyncCommands. zscan(ScoredValueStreamingChannel<V> channel, K key, ScanCursor scanCursor)
Incrementally iterate sorted sets elements and associated scores.AsyncExecutions<StreamScanCursor>
NodeSelectionSortedSetAsyncCommands. zscan(ScoredValueStreamingChannel<V> channel, K key, ScanCursor scanCursor, ScanArgs scanArgs)
Incrementally iterate sorted sets elements and associated scores. -
Uses of ScoredValueStreamingChannel in io.lettuce.core.cluster.api.sync
Methods in io.lettuce.core.cluster.api.sync with parameters of type ScoredValueStreamingChannel Modifier and Type Method Description Executions<Long>
NodeSelectionSortedSetCommands. zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, double min, double max)
Executions<Long>
NodeSelectionSortedSetCommands. zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, double min, double max, long offset, long count)
Executions<Long>
NodeSelectionSortedSetCommands. zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, Range<? extends Number> range)
Stream over a range of members with scores in a sorted set, by score.Executions<Long>
NodeSelectionSortedSetCommands. zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, Range<? extends Number> range, Limit limit)
Stream over a range of members with scores in a sorted set, by score.Executions<Long>
NodeSelectionSortedSetCommands. zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, String min, String max)
Executions<Long>
NodeSelectionSortedSetCommands. zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, String min, String max, long offset, long count)
Executions<Long>
NodeSelectionSortedSetCommands. zrangeWithScores(ScoredValueStreamingChannel<V> channel, K key, long start, long stop)
Stream over a range of members with scores in a sorted set, by index.Executions<Long>
NodeSelectionSortedSetCommands. zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, double max, double min)
Executions<Long>
NodeSelectionSortedSetCommands. zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, double max, double min, long offset, long count)
Executions<Long>
NodeSelectionSortedSetCommands. zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, Range<? extends Number> range)
Stream over a range of members with scores in a sorted set, by score, with scores ordered from high to low.Executions<Long>
NodeSelectionSortedSetCommands. zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, Range<? extends Number> range, Limit limit)
Stream over a range of members with scores in a sorted set, by score, with scores ordered from high to low.Executions<Long>
NodeSelectionSortedSetCommands. zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, String max, String min)
Executions<Long>
NodeSelectionSortedSetCommands. zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, String max, String min, long offset, long count)
Executions<Long>
NodeSelectionSortedSetCommands. zrevrangeWithScores(ScoredValueStreamingChannel<V> channel, K key, long start, long stop)
Stream over a range of members with scores in a sorted set, by index, with scores ordered from high to low.Executions<StreamScanCursor>
NodeSelectionSortedSetCommands. zscan(ScoredValueStreamingChannel<V> channel, K key)
Incrementally iterate sorted sets elements and associated scores.Executions<StreamScanCursor>
NodeSelectionSortedSetCommands. zscan(ScoredValueStreamingChannel<V> channel, K key, ScanArgs scanArgs)
Incrementally iterate sorted sets elements and associated scores.Executions<StreamScanCursor>
NodeSelectionSortedSetCommands. zscan(ScoredValueStreamingChannel<V> channel, K key, ScanCursor scanCursor)
Incrementally iterate sorted sets elements and associated scores.Executions<StreamScanCursor>
NodeSelectionSortedSetCommands. zscan(ScoredValueStreamingChannel<V> channel, K key, ScanCursor scanCursor, ScanArgs scanArgs)
Incrementally iterate sorted sets elements and associated scores. -
Uses of ScoredValueStreamingChannel in io.lettuce.core.output
Constructors in io.lettuce.core.output with parameters of type ScoredValueStreamingChannel Constructor Description ScoredValueScanStreamingOutput(RedisCodec<K,V> codec, ScoredValueStreamingChannel<V> channel)
ScoredValueStreamingOutput(RedisCodec<K,V> codec, ScoredValueStreamingChannel<V> channel)
-