Uses of Interface
io.lettuce.core.output.ValueStreamingChannel
-
Packages that use ValueStreamingChannel 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 ValueStreamingChannel in io.lettuce.core
Methods in io.lettuce.core with parameters of type ValueStreamingChannel Modifier and Type Method Description RedisFuture<Long>
AbstractRedisAsyncCommands. hvals(ValueStreamingChannel<V> channel, K key)
Mono<Long>
AbstractRedisReactiveCommands. hvals(ValueStreamingChannel<V> channel, K key)
RedisFuture<Long>
AbstractRedisAsyncCommands. lrange(ValueStreamingChannel<V> channel, K key, long start, long stop)
Mono<Long>
AbstractRedisReactiveCommands. lrange(ValueStreamingChannel<V> channel, K key, long start, long stop)
Mono<Long>
AbstractRedisReactiveCommands. mget(ValueStreamingChannel<V> channel, Iterable<K> keys)
RedisFuture<Long>
AbstractRedisAsyncCommands. sdiff(ValueStreamingChannel<V> channel, K... keys)
Mono<Long>
AbstractRedisReactiveCommands. sdiff(ValueStreamingChannel<V> channel, K... keys)
RedisFuture<Long>
AbstractRedisAsyncCommands. sinter(ValueStreamingChannel<V> channel, K... keys)
Mono<Long>
AbstractRedisReactiveCommands. sinter(ValueStreamingChannel<V> channel, K... keys)
RedisFuture<Long>
AbstractRedisAsyncCommands. smembers(ValueStreamingChannel<V> channel, K key)
Mono<Long>
AbstractRedisReactiveCommands. smembers(ValueStreamingChannel<V> channel, K key)
RedisFuture<Long>
AbstractRedisAsyncCommands. sort(ValueStreamingChannel<V> channel, K key)
RedisFuture<Long>
AbstractRedisAsyncCommands. sort(ValueStreamingChannel<V> channel, K key, SortArgs sortArgs)
Mono<Long>
AbstractRedisReactiveCommands. sort(ValueStreamingChannel<V> channel, K key)
Mono<Long>
AbstractRedisReactiveCommands. sort(ValueStreamingChannel<V> channel, K key, SortArgs sortArgs)
RedisFuture<Long>
AbstractRedisAsyncCommands. sortReadOnly(ValueStreamingChannel<V> channel, K key)
RedisFuture<Long>
AbstractRedisAsyncCommands. sortReadOnly(ValueStreamingChannel<V> channel, K key, SortArgs sortArgs)
Mono<Long>
AbstractRedisReactiveCommands. sortReadOnly(ValueStreamingChannel<V> channel, K key)
Mono<Long>
AbstractRedisReactiveCommands. sortReadOnly(ValueStreamingChannel<V> channel, K key, SortArgs sortArgs)
RedisFuture<Long>
AbstractRedisAsyncCommands. srandmember(ValueStreamingChannel<V> channel, K key, long count)
Mono<Long>
AbstractRedisReactiveCommands. srandmember(ValueStreamingChannel<V> channel, K key, long count)
RedisFuture<StreamScanCursor>
AbstractRedisAsyncCommands. sscan(ValueStreamingChannel<V> channel, K key)
RedisFuture<StreamScanCursor>
AbstractRedisAsyncCommands. sscan(ValueStreamingChannel<V> channel, K key, ScanArgs scanArgs)
RedisFuture<StreamScanCursor>
AbstractRedisAsyncCommands. sscan(ValueStreamingChannel<V> channel, K key, ScanCursor scanCursor)
RedisFuture<StreamScanCursor>
AbstractRedisAsyncCommands. sscan(ValueStreamingChannel<V> channel, K key, ScanCursor scanCursor, ScanArgs scanArgs)
Mono<StreamScanCursor>
AbstractRedisReactiveCommands. sscan(ValueStreamingChannel<V> channel, K key)
Mono<StreamScanCursor>
AbstractRedisReactiveCommands. sscan(ValueStreamingChannel<V> channel, K key, ScanArgs scanArgs)
Mono<StreamScanCursor>
AbstractRedisReactiveCommands. sscan(ValueStreamingChannel<V> channel, K key, ScanCursor scanCursor)
Mono<StreamScanCursor>
AbstractRedisReactiveCommands. sscan(ValueStreamingChannel<V> channel, K key, ScanCursor scanCursor, ScanArgs scanArgs)
RedisFuture<Long>
AbstractRedisAsyncCommands. sunion(ValueStreamingChannel<V> channel, K... keys)
Mono<Long>
AbstractRedisReactiveCommands. sunion(ValueStreamingChannel<V> channel, K... keys)
RedisFuture<Long>
AbstractRedisAsyncCommands. zrange(ValueStreamingChannel<V> channel, K key, long start, long stop)
Mono<Long>
AbstractRedisReactiveCommands. zrange(ValueStreamingChannel<V> channel, K key, long start, long stop)
RedisFuture<Long>
AbstractRedisAsyncCommands. zrangebyscore(ValueStreamingChannel<V> channel, K key, double min, double max)
RedisFuture<Long>
AbstractRedisAsyncCommands. zrangebyscore(ValueStreamingChannel<V> channel, K key, double min, double max, long offset, long count)
RedisFuture<Long>
AbstractRedisAsyncCommands. zrangebyscore(ValueStreamingChannel<V> channel, K key, Range<? extends Number> range)
RedisFuture<Long>
AbstractRedisAsyncCommands. zrangebyscore(ValueStreamingChannel<V> channel, K key, Range<? extends Number> range, Limit limit)
RedisFuture<Long>
AbstractRedisAsyncCommands. zrangebyscore(ValueStreamingChannel<V> channel, K key, String min, String max)
RedisFuture<Long>
AbstractRedisAsyncCommands. zrangebyscore(ValueStreamingChannel<V> channel, K key, String min, String max, long offset, long count)
Mono<Long>
AbstractRedisReactiveCommands. zrangebyscore(ValueStreamingChannel<V> channel, K key, double min, double max)
Mono<Long>
AbstractRedisReactiveCommands. zrangebyscore(ValueStreamingChannel<V> channel, K key, double min, double max, long offset, long count)
Mono<Long>
AbstractRedisReactiveCommands. zrangebyscore(ValueStreamingChannel<V> channel, K key, Range<? extends Number> range)
Mono<Long>
AbstractRedisReactiveCommands. zrangebyscore(ValueStreamingChannel<V> channel, K key, Range<? extends Number> range, Limit limit)
Mono<Long>
AbstractRedisReactiveCommands. zrangebyscore(ValueStreamingChannel<V> channel, K key, String min, String max)
Mono<Long>
AbstractRedisReactiveCommands. zrangebyscore(ValueStreamingChannel<V> channel, K key, String min, String max, long offset, long count)
RedisFuture<Long>
AbstractRedisAsyncCommands. zrevrange(ValueStreamingChannel<V> channel, K key, long start, long stop)
Mono<Long>
AbstractRedisReactiveCommands. zrevrange(ValueStreamingChannel<V> channel, K key, long start, long stop)
RedisFuture<Long>
AbstractRedisAsyncCommands. zrevrangebyscore(ValueStreamingChannel<V> channel, K key, double max, double min)
RedisFuture<Long>
AbstractRedisAsyncCommands. zrevrangebyscore(ValueStreamingChannel<V> channel, K key, double max, double min, long offset, long count)
RedisFuture<Long>
AbstractRedisAsyncCommands. zrevrangebyscore(ValueStreamingChannel<V> channel, K key, Range<? extends Number> range)
RedisFuture<Long>
AbstractRedisAsyncCommands. zrevrangebyscore(ValueStreamingChannel<V> channel, K key, Range<? extends Number> range, Limit limit)
RedisFuture<Long>
AbstractRedisAsyncCommands. zrevrangebyscore(ValueStreamingChannel<V> channel, K key, String max, String min)
RedisFuture<Long>
AbstractRedisAsyncCommands. zrevrangebyscore(ValueStreamingChannel<V> channel, K key, String max, String min, long offset, long count)
Mono<Long>
AbstractRedisReactiveCommands. zrevrangebyscore(ValueStreamingChannel<V> channel, K key, double max, double min)
Mono<Long>
AbstractRedisReactiveCommands. zrevrangebyscore(ValueStreamingChannel<V> channel, K key, double max, double min, long offset, long count)
Mono<Long>
AbstractRedisReactiveCommands. zrevrangebyscore(ValueStreamingChannel<V> channel, K key, Range<? extends Number> range)
Mono<Long>
AbstractRedisReactiveCommands. zrevrangebyscore(ValueStreamingChannel<V> channel, K key, Range<? extends Number> range, Limit limit)
Mono<Long>
AbstractRedisReactiveCommands. zrevrangebyscore(ValueStreamingChannel<V> channel, K key, String max, String min)
Mono<Long>
AbstractRedisReactiveCommands. zrevrangebyscore(ValueStreamingChannel<V> channel, K key, String max, String min, long offset, long count)
-
Uses of ValueStreamingChannel in io.lettuce.core.api.async
Methods in io.lettuce.core.api.async with parameters of type ValueStreamingChannel Modifier and Type Method Description RedisFuture<Long>
RedisHashAsyncCommands. hvals(ValueStreamingChannel<V> channel, K key)
Stream over all the values in a hash.RedisFuture<Long>
RedisListAsyncCommands. lrange(ValueStreamingChannel<V> channel, K key, long start, long stop)
Get a range of elements from a list.RedisFuture<Long>
RedisSetAsyncCommands. sdiff(ValueStreamingChannel<V> channel, K... keys)
Subtract multiple sets.RedisFuture<Long>
RedisSetAsyncCommands. sinter(ValueStreamingChannel<V> channel, K... keys)
Intersect multiple sets.RedisFuture<Long>
RedisSetAsyncCommands. smembers(ValueStreamingChannel<V> channel, K key)
Get all the members in a set.RedisFuture<Long>
RedisKeyAsyncCommands. sort(ValueStreamingChannel<V> channel, K key)
Sort the elements in a list, set or sorted set.RedisFuture<Long>
RedisKeyAsyncCommands. sort(ValueStreamingChannel<V> channel, K key, SortArgs sortArgs)
Sort the elements in a list, set or sorted set.RedisFuture<Long>
RedisKeyAsyncCommands. sortReadOnly(ValueStreamingChannel<V> channel, K key)
Sort the elements in a list, set or sorted set.RedisFuture<Long>
RedisKeyAsyncCommands. sortReadOnly(ValueStreamingChannel<V> channel, K key, SortArgs sortArgs)
Sort the elements in a list, set or sorted set.RedisFuture<Long>
RedisSetAsyncCommands. srandmember(ValueStreamingChannel<V> channel, K key, long count)
Get one or multiple random members from a set.RedisFuture<StreamScanCursor>
RedisSetAsyncCommands. sscan(ValueStreamingChannel<V> channel, K key)
Incrementally iterate Set elements.RedisFuture<StreamScanCursor>
RedisSetAsyncCommands. sscan(ValueStreamingChannel<V> channel, K key, ScanArgs scanArgs)
Incrementally iterate Set elements.RedisFuture<StreamScanCursor>
RedisSetAsyncCommands. sscan(ValueStreamingChannel<V> channel, K key, ScanCursor scanCursor)
Incrementally iterate Set elements.RedisFuture<StreamScanCursor>
RedisSetAsyncCommands. sscan(ValueStreamingChannel<V> channel, K key, ScanCursor scanCursor, ScanArgs scanArgs)
Incrementally iterate Set elements.RedisFuture<Long>
RedisSetAsyncCommands. sunion(ValueStreamingChannel<V> channel, K... keys)
Add multiple sets.RedisFuture<Long>
RedisSortedSetAsyncCommands. zrange(ValueStreamingChannel<V> channel, K key, long start, long stop)
Return a range of members in a sorted set, by index.RedisFuture<Long>
RedisSortedSetAsyncCommands. zrangebyscore(ValueStreamingChannel<V> channel, K key, double min, double max)
RedisFuture<Long>
RedisSortedSetAsyncCommands. zrangebyscore(ValueStreamingChannel<V> channel, K key, double min, double max, long offset, long count)
RedisFuture<Long>
RedisSortedSetAsyncCommands. zrangebyscore(ValueStreamingChannel<V> channel, K key, Range<? extends Number> range)
Stream over a range of members in a sorted set, by score.RedisFuture<Long>
RedisSortedSetAsyncCommands. zrangebyscore(ValueStreamingChannel<V> channel, K key, Range<? extends Number> range, Limit limit)
Stream over a range of members in a sorted set, by score.RedisFuture<Long>
RedisSortedSetAsyncCommands. zrangebyscore(ValueStreamingChannel<V> channel, K key, String min, String max)
RedisFuture<Long>
RedisSortedSetAsyncCommands. zrangebyscore(ValueStreamingChannel<V> channel, K key, String min, String max, long offset, long count)
RedisFuture<Long>
RedisSortedSetAsyncCommands. zrevrange(ValueStreamingChannel<V> channel, K key, long start, long stop)
Stream over a range of members in a sorted set, by index, with scores ordered from high to low.RedisFuture<Long>
RedisSortedSetAsyncCommands. zrevrangebyscore(ValueStreamingChannel<V> channel, K key, double max, double min)
RedisFuture<Long>
RedisSortedSetAsyncCommands. zrevrangebyscore(ValueStreamingChannel<V> channel, K key, double max, double min, long offset, long count)
RedisFuture<Long>
RedisSortedSetAsyncCommands. zrevrangebyscore(ValueStreamingChannel<V> channel, K key, Range<? extends Number> range)
Stream over a range of members in a sorted set, by score, with scores ordered from high to low.RedisFuture<Long>
RedisSortedSetAsyncCommands. zrevrangebyscore(ValueStreamingChannel<V> channel, K key, Range<? extends Number> range, Limit limit)
Stream over a range of members in a sorted set, by score, with scores ordered from high to low.RedisFuture<Long>
RedisSortedSetAsyncCommands. zrevrangebyscore(ValueStreamingChannel<V> channel, K key, String max, String min)
RedisFuture<Long>
RedisSortedSetAsyncCommands. zrevrangebyscore(ValueStreamingChannel<V> channel, K key, String max, String min, long offset, long count)
-
Uses of ValueStreamingChannel in io.lettuce.core.api.reactive
Methods in io.lettuce.core.api.reactive with parameters of type ValueStreamingChannel Modifier and Type Method Description Mono<Long>
RedisHashReactiveCommands. hvals(ValueStreamingChannel<V> channel, K key)
Deprecated.since 6.0 in favor of consuming large results through thePublisher
returned byRedisHashReactiveCommands.hvals(K)
.Mono<Long>
RedisListReactiveCommands. lrange(ValueStreamingChannel<V> channel, K key, long start, long stop)
Deprecated.since 6.0 in favor of consuming large results through thePublisher
returned byRedisListReactiveCommands.lrange(K, long, long)
.Mono<Long>
RedisSetReactiveCommands. sdiff(ValueStreamingChannel<V> channel, K... keys)
Deprecated.since 6.0 in favor of consuming large results through thePublisher
returned byRedisSetReactiveCommands.sdiff(K...)
.Mono<Long>
RedisSetReactiveCommands. sinter(ValueStreamingChannel<V> channel, K... keys)
Deprecated.since 6.0 in favor of consuming large results through thePublisher
returned byRedisSetReactiveCommands.sinter(K...)
.Mono<Long>
RedisSetReactiveCommands. smembers(ValueStreamingChannel<V> channel, K key)
Deprecated.since 6.0 in favor of consuming large results through thePublisher
returned byRedisSetReactiveCommands.smembers(K)
.Mono<Long>
RedisKeyReactiveCommands. sort(ValueStreamingChannel<V> channel, K key)
Deprecated.since 6.0 in favor of consuming large results through thePublisher
returned byRedisKeyReactiveCommands.sort(K)
.Mono<Long>
RedisKeyReactiveCommands. sort(ValueStreamingChannel<V> channel, K key, SortArgs sortArgs)
Deprecated.since 6.0 in favor of consuming large results through thePublisher
returned byRedisKeyReactiveCommands.sort(K)
.Mono<Long>
RedisKeyReactiveCommands. sortReadOnly(ValueStreamingChannel<V> channel, K key)
Deprecated.since 6.0 in favor of consuming large results through thePublisher
returned byRedisKeyReactiveCommands.sortReadOnly(K)
.Mono<Long>
RedisKeyReactiveCommands. sortReadOnly(ValueStreamingChannel<V> channel, K key, SortArgs sortArgs)
Deprecated.since 6.0 in favor of consuming large results through thePublisher
returned byRedisKeyReactiveCommands.sortReadOnly(K)
.Mono<Long>
RedisSetReactiveCommands. srandmember(ValueStreamingChannel<V> channel, K key, long count)
Deprecated.since 6.0 in favor of consuming large results through thePublisher
returned byRedisSetReactiveCommands.srandmember(K)
.Mono<StreamScanCursor>
RedisSetReactiveCommands. sscan(ValueStreamingChannel<V> channel, K key)
Deprecated.since 6.0 in favor of consuming large results through thePublisher
returned byRedisSetReactiveCommands.sscan(K)
.Mono<StreamScanCursor>
RedisSetReactiveCommands. sscan(ValueStreamingChannel<V> channel, K key, ScanArgs scanArgs)
Deprecated.since 6.0 in favor of consuming large results through thePublisher
returned byRedisSetReactiveCommands.sscan(K)
.Mono<StreamScanCursor>
RedisSetReactiveCommands. sscan(ValueStreamingChannel<V> channel, K key, ScanCursor scanCursor)
Deprecated.since 6.0 in favor of consuming large results through thePublisher
returned byRedisSetReactiveCommands.sscan(K)
.Mono<StreamScanCursor>
RedisSetReactiveCommands. sscan(ValueStreamingChannel<V> channel, K key, ScanCursor scanCursor, ScanArgs scanArgs)
Deprecated.since 6.0 in favor of consuming large results through thePublisher
returned byRedisSetReactiveCommands.sscan(K)
.Mono<Long>
RedisSetReactiveCommands. sunion(ValueStreamingChannel<V> channel, K... keys)
Deprecated.since 6.0 in favor of consuming large results through thePublisher
returned byRedisSetReactiveCommands.sunion(K...)
.Mono<Long>
RedisSortedSetReactiveCommands. zrange(ValueStreamingChannel<V> channel, K key, long start, long stop)
Deprecated.since 6.0 in favor of consuming large results through thePublisher
returned byRedisSortedSetReactiveCommands.zrange(K, long, long)
.Mono<Long>
RedisSortedSetReactiveCommands. zrangebyscore(ValueStreamingChannel<V> channel, K key, double min, double max)
Mono<Long>
RedisSortedSetReactiveCommands. zrangebyscore(ValueStreamingChannel<V> channel, K key, double min, double max, long offset, long count)
Mono<Long>
RedisSortedSetReactiveCommands. zrangebyscore(ValueStreamingChannel<V> channel, K key, Range<? extends Number> range)
Deprecated.since 6.0 in favor of consuming large results through thePublisher
returned byRedisSortedSetReactiveCommands.zrangebyscore(K, double, double)
.Mono<Long>
RedisSortedSetReactiveCommands. zrangebyscore(ValueStreamingChannel<V> channel, K key, Range<? extends Number> range, Limit limit)
Deprecated.since 6.0 in favor of consuming large results through thePublisher
returned byRedisSortedSetReactiveCommands.zrangebyscore(K, double, double)
.Mono<Long>
RedisSortedSetReactiveCommands. zrangebyscore(ValueStreamingChannel<V> channel, K key, String min, String max)
Mono<Long>
RedisSortedSetReactiveCommands. zrangebyscore(ValueStreamingChannel<V> channel, K key, String min, String max, long offset, long count)
Mono<Long>
RedisSortedSetReactiveCommands. zrevrange(ValueStreamingChannel<V> channel, K key, long start, long stop)
Deprecated.since 6.0 in favor of consuming large results through thePublisher
returned byRedisSortedSetReactiveCommands.zrevrange(K, long, long)
.Mono<Long>
RedisSortedSetReactiveCommands. zrevrangebyscore(ValueStreamingChannel<V> channel, K key, double max, double min)
Mono<Long>
RedisSortedSetReactiveCommands. zrevrangebyscore(ValueStreamingChannel<V> channel, K key, double max, double min, long offset, long count)
Mono<Long>
RedisSortedSetReactiveCommands. zrevrangebyscore(ValueStreamingChannel<V> channel, K key, Range<? extends Number> range)
Deprecated.since 6.0 in favor of consuming large results through thePublisher
returned byRedisSortedSetReactiveCommands.zrevrangebyscore(K, double, double)
.Mono<Long>
RedisSortedSetReactiveCommands. zrevrangebyscore(ValueStreamingChannel<V> channel, K key, Range<? extends Number> range, Limit limit)
Deprecated.since 6.0 in favor of consuming large results through thePublisher
returned byRedisSortedSetReactiveCommands.zrevrangebyscore(K, double, double)
.Mono<Long>
RedisSortedSetReactiveCommands. zrevrangebyscore(ValueStreamingChannel<V> channel, K key, String max, String min)
Mono<Long>
RedisSortedSetReactiveCommands. zrevrangebyscore(ValueStreamingChannel<V> channel, K key, String max, String min, long offset, long count)
-
Uses of ValueStreamingChannel in io.lettuce.core.api.sync
Methods in io.lettuce.core.api.sync with parameters of type ValueStreamingChannel Modifier and Type Method Description Long
RedisHashCommands. hvals(ValueStreamingChannel<V> channel, K key)
Stream over all the values in a hash.Long
RedisListCommands. lrange(ValueStreamingChannel<V> channel, K key, long start, long stop)
Get a range of elements from a list.Long
RedisSetCommands. sdiff(ValueStreamingChannel<V> channel, K... keys)
Subtract multiple sets.Long
RedisSetCommands. sinter(ValueStreamingChannel<V> channel, K... keys)
Intersect multiple sets.Long
RedisSetCommands. smembers(ValueStreamingChannel<V> channel, K key)
Get all the members in a set.Long
RedisKeyCommands. sort(ValueStreamingChannel<V> channel, K key)
Sort the elements in a list, set or sorted set.Long
RedisKeyCommands. sort(ValueStreamingChannel<V> channel, K key, SortArgs sortArgs)
Sort the elements in a list, set or sorted set.Long
RedisKeyCommands. sortReadOnly(ValueStreamingChannel<V> channel, K key)
Sort the elements in a list, set or sorted set.Long
RedisKeyCommands. sortReadOnly(ValueStreamingChannel<V> channel, K key, SortArgs sortArgs)
Sort the elements in a list, set or sorted set.Long
RedisSetCommands. srandmember(ValueStreamingChannel<V> channel, K key, long count)
Get one or multiple random members from a set.StreamScanCursor
RedisSetCommands. sscan(ValueStreamingChannel<V> channel, K key)
Incrementally iterate Set elements.StreamScanCursor
RedisSetCommands. sscan(ValueStreamingChannel<V> channel, K key, ScanArgs scanArgs)
Incrementally iterate Set elements.StreamScanCursor
RedisSetCommands. sscan(ValueStreamingChannel<V> channel, K key, ScanCursor scanCursor)
Incrementally iterate Set elements.StreamScanCursor
RedisSetCommands. sscan(ValueStreamingChannel<V> channel, K key, ScanCursor scanCursor, ScanArgs scanArgs)
Incrementally iterate Set elements.Long
RedisSetCommands. sunion(ValueStreamingChannel<V> channel, K... keys)
Add multiple sets.Long
RedisSortedSetCommands. zrange(ValueStreamingChannel<V> channel, K key, long start, long stop)
Return a range of members in a sorted set, by index.Long
RedisSortedSetCommands. zrangebyscore(ValueStreamingChannel<V> channel, K key, double min, double max)
Long
RedisSortedSetCommands. zrangebyscore(ValueStreamingChannel<V> channel, K key, double min, double max, long offset, long count)
Long
RedisSortedSetCommands. zrangebyscore(ValueStreamingChannel<V> channel, K key, Range<? extends Number> range)
Stream over a range of members in a sorted set, by score.Long
RedisSortedSetCommands. zrangebyscore(ValueStreamingChannel<V> channel, K key, Range<? extends Number> range, Limit limit)
Stream over a range of members in a sorted set, by score.Long
RedisSortedSetCommands. zrangebyscore(ValueStreamingChannel<V> channel, K key, String min, String max)
Long
RedisSortedSetCommands. zrangebyscore(ValueStreamingChannel<V> channel, K key, String min, String max, long offset, long count)
Long
RedisSortedSetCommands. zrevrange(ValueStreamingChannel<V> channel, K key, long start, long stop)
Stream over a range of members in a sorted set, by index, with scores ordered from high to low.Long
RedisSortedSetCommands. zrevrangebyscore(ValueStreamingChannel<V> channel, K key, double max, double min)
Deprecated.Long
RedisSortedSetCommands. zrevrangebyscore(ValueStreamingChannel<V> channel, K key, double max, double min, long offset, long count)
Long
RedisSortedSetCommands. zrevrangebyscore(ValueStreamingChannel<V> channel, K key, Range<? extends Number> range)
Stream over a range of members in a sorted set, by score, with scores ordered from high to low.Long
RedisSortedSetCommands. zrevrangebyscore(ValueStreamingChannel<V> channel, K key, Range<? extends Number> range, Limit limit)
Stream over a range of members in a sorted set, by score, with scores ordered from high to low.Long
RedisSortedSetCommands. zrevrangebyscore(ValueStreamingChannel<V> channel, K key, String max, String min)
Deprecated.Long
RedisSortedSetCommands. zrevrangebyscore(ValueStreamingChannel<V> channel, K key, String max, String min, long offset, long count)
-
Uses of ValueStreamingChannel in io.lettuce.core.cluster.api.async
Methods in io.lettuce.core.cluster.api.async with parameters of type ValueStreamingChannel Modifier and Type Method Description AsyncExecutions<Long>
NodeSelectionHashAsyncCommands. hvals(ValueStreamingChannel<V> channel, K key)
Stream over all the values in a hash.AsyncExecutions<Long>
NodeSelectionListAsyncCommands. lrange(ValueStreamingChannel<V> channel, K key, long start, long stop)
Get a range of elements from a list.AsyncExecutions<Long>
NodeSelectionSetAsyncCommands. sdiff(ValueStreamingChannel<V> channel, K... keys)
Subtract multiple sets.AsyncExecutions<Long>
NodeSelectionSetAsyncCommands. sinter(ValueStreamingChannel<V> channel, K... keys)
Intersect multiple sets.AsyncExecutions<Long>
NodeSelectionSetAsyncCommands. smembers(ValueStreamingChannel<V> channel, K key)
Get all the members in a set.AsyncExecutions<Long>
NodeSelectionKeyAsyncCommands. sort(ValueStreamingChannel<V> channel, K key)
Sort the elements in a list, set or sorted set.AsyncExecutions<Long>
NodeSelectionKeyAsyncCommands. sort(ValueStreamingChannel<V> channel, K key, SortArgs sortArgs)
Sort the elements in a list, set or sorted set.AsyncExecutions<Long>
NodeSelectionKeyAsyncCommands. sortReadOnly(ValueStreamingChannel<V> channel, K key)
Sort the elements in a list, set or sorted set.AsyncExecutions<Long>
NodeSelectionKeyAsyncCommands. sortReadOnly(ValueStreamingChannel<V> channel, K key, SortArgs sortArgs)
Sort the elements in a list, set or sorted set.AsyncExecutions<Long>
NodeSelectionSetAsyncCommands. srandmember(ValueStreamingChannel<V> channel, K key, long count)
Get one or multiple random members from a set.AsyncExecutions<StreamScanCursor>
NodeSelectionSetAsyncCommands. sscan(ValueStreamingChannel<V> channel, K key)
Incrementally iterate Set elements.AsyncExecutions<StreamScanCursor>
NodeSelectionSetAsyncCommands. sscan(ValueStreamingChannel<V> channel, K key, ScanArgs scanArgs)
Incrementally iterate Set elements.AsyncExecutions<StreamScanCursor>
NodeSelectionSetAsyncCommands. sscan(ValueStreamingChannel<V> channel, K key, ScanCursor scanCursor)
Incrementally iterate Set elements.AsyncExecutions<StreamScanCursor>
NodeSelectionSetAsyncCommands. sscan(ValueStreamingChannel<V> channel, K key, ScanCursor scanCursor, ScanArgs scanArgs)
Incrementally iterate Set elements.AsyncExecutions<Long>
NodeSelectionSetAsyncCommands. sunion(ValueStreamingChannel<V> channel, K... keys)
Add multiple sets.AsyncExecutions<Long>
NodeSelectionSortedSetAsyncCommands. zrange(ValueStreamingChannel<V> channel, K key, long start, long stop)
Return a range of members in a sorted set, by index.AsyncExecutions<Long>
NodeSelectionSortedSetAsyncCommands. zrangebyscore(ValueStreamingChannel<V> channel, K key, double min, double max)
AsyncExecutions<Long>
NodeSelectionSortedSetAsyncCommands. zrangebyscore(ValueStreamingChannel<V> channel, K key, double min, double max, long offset, long count)
AsyncExecutions<Long>
NodeSelectionSortedSetAsyncCommands. zrangebyscore(ValueStreamingChannel<V> channel, K key, Range<? extends Number> range)
Stream over a range of members in a sorted set, by score.AsyncExecutions<Long>
NodeSelectionSortedSetAsyncCommands. zrangebyscore(ValueStreamingChannel<V> channel, K key, Range<? extends Number> range, Limit limit)
Stream over a range of members in a sorted set, by score.AsyncExecutions<Long>
NodeSelectionSortedSetAsyncCommands. zrangebyscore(ValueStreamingChannel<V> channel, K key, String min, String max)
AsyncExecutions<Long>
NodeSelectionSortedSetAsyncCommands. zrangebyscore(ValueStreamingChannel<V> channel, K key, String min, String max, long offset, long count)
AsyncExecutions<Long>
NodeSelectionSortedSetAsyncCommands. zrevrange(ValueStreamingChannel<V> channel, K key, long start, long stop)
Stream over a range of members in a sorted set, by index, with scores ordered from high to low.AsyncExecutions<Long>
NodeSelectionSortedSetAsyncCommands. zrevrangebyscore(ValueStreamingChannel<V> channel, K key, double max, double min)
AsyncExecutions<Long>
NodeSelectionSortedSetAsyncCommands. zrevrangebyscore(ValueStreamingChannel<V> channel, K key, double max, double min, long offset, long count)
AsyncExecutions<Long>
NodeSelectionSortedSetAsyncCommands. zrevrangebyscore(ValueStreamingChannel<V> channel, K key, Range<? extends Number> range)
Stream over a range of members in a sorted set, by score, with scores ordered from high to low.AsyncExecutions<Long>
NodeSelectionSortedSetAsyncCommands. zrevrangebyscore(ValueStreamingChannel<V> channel, K key, Range<? extends Number> range, Limit limit)
Stream over a range of members in a sorted set, by score, with scores ordered from high to low.AsyncExecutions<Long>
NodeSelectionSortedSetAsyncCommands. zrevrangebyscore(ValueStreamingChannel<V> channel, K key, String max, String min)
AsyncExecutions<Long>
NodeSelectionSortedSetAsyncCommands. zrevrangebyscore(ValueStreamingChannel<V> channel, K key, String max, String min, long offset, long count)
-
Uses of ValueStreamingChannel in io.lettuce.core.cluster.api.sync
Methods in io.lettuce.core.cluster.api.sync with parameters of type ValueStreamingChannel Modifier and Type Method Description Executions<Long>
NodeSelectionHashCommands. hvals(ValueStreamingChannel<V> channel, K key)
Stream over all the values in a hash.Executions<Long>
NodeSelectionListCommands. lrange(ValueStreamingChannel<V> channel, K key, long start, long stop)
Get a range of elements from a list.Executions<Long>
NodeSelectionSetCommands. sdiff(ValueStreamingChannel<V> channel, K... keys)
Subtract multiple sets.Executions<Long>
NodeSelectionSetCommands. sinter(ValueStreamingChannel<V> channel, K... keys)
Intersect multiple sets.Executions<Long>
NodeSelectionSetCommands. smembers(ValueStreamingChannel<V> channel, K key)
Get all the members in a set.Executions<Long>
NodeSelectionKeyCommands. sort(ValueStreamingChannel<V> channel, K key)
Sort the elements in a list, set or sorted set.Executions<Long>
NodeSelectionKeyCommands. sort(ValueStreamingChannel<V> channel, K key, SortArgs sortArgs)
Sort the elements in a list, set or sorted set.Executions<Long>
NodeSelectionKeyCommands. sortReadOnly(ValueStreamingChannel<V> channel, K key)
Sort the elements in a list, set or sorted set.Executions<Long>
NodeSelectionKeyCommands. sortReadOnly(ValueStreamingChannel<V> channel, K key, SortArgs sortArgs)
Sort the elements in a list, set or sorted set.Executions<Long>
NodeSelectionSetCommands. srandmember(ValueStreamingChannel<V> channel, K key, long count)
Get one or multiple random members from a set.Executions<StreamScanCursor>
NodeSelectionSetCommands. sscan(ValueStreamingChannel<V> channel, K key)
Incrementally iterate Set elements.Executions<StreamScanCursor>
NodeSelectionSetCommands. sscan(ValueStreamingChannel<V> channel, K key, ScanArgs scanArgs)
Incrementally iterate Set elements.Executions<StreamScanCursor>
NodeSelectionSetCommands. sscan(ValueStreamingChannel<V> channel, K key, ScanCursor scanCursor)
Incrementally iterate Set elements.Executions<StreamScanCursor>
NodeSelectionSetCommands. sscan(ValueStreamingChannel<V> channel, K key, ScanCursor scanCursor, ScanArgs scanArgs)
Incrementally iterate Set elements.Executions<Long>
NodeSelectionSetCommands. sunion(ValueStreamingChannel<V> channel, K... keys)
Add multiple sets.Executions<Long>
NodeSelectionSortedSetCommands. zrange(ValueStreamingChannel<V> channel, K key, long start, long stop)
Return a range of members in a sorted set, by index.Executions<Long>
NodeSelectionSortedSetCommands. zrangebyscore(ValueStreamingChannel<V> channel, K key, double min, double max)
Executions<Long>
NodeSelectionSortedSetCommands. zrangebyscore(ValueStreamingChannel<V> channel, K key, double min, double max, long offset, long count)
Executions<Long>
NodeSelectionSortedSetCommands. zrangebyscore(ValueStreamingChannel<V> channel, K key, Range<? extends Number> range)
Stream over a range of members in a sorted set, by score.Executions<Long>
NodeSelectionSortedSetCommands. zrangebyscore(ValueStreamingChannel<V> channel, K key, Range<? extends Number> range, Limit limit)
Stream over a range of members in a sorted set, by score.Executions<Long>
NodeSelectionSortedSetCommands. zrangebyscore(ValueStreamingChannel<V> channel, K key, String min, String max)
Executions<Long>
NodeSelectionSortedSetCommands. zrangebyscore(ValueStreamingChannel<V> channel, K key, String min, String max, long offset, long count)
Executions<Long>
NodeSelectionSortedSetCommands. zrevrange(ValueStreamingChannel<V> channel, K key, long start, long stop)
Stream over a range of members in a sorted set, by index, with scores ordered from high to low.Executions<Long>
NodeSelectionSortedSetCommands. zrevrangebyscore(ValueStreamingChannel<V> channel, K key, double max, double min)
Executions<Long>
NodeSelectionSortedSetCommands. zrevrangebyscore(ValueStreamingChannel<V> channel, K key, double max, double min, long offset, long count)
Executions<Long>
NodeSelectionSortedSetCommands. zrevrangebyscore(ValueStreamingChannel<V> channel, K key, Range<? extends Number> range)
Stream over a range of members in a sorted set, by score, with scores ordered from high to low.Executions<Long>
NodeSelectionSortedSetCommands. zrevrangebyscore(ValueStreamingChannel<V> channel, K key, Range<? extends Number> range, Limit limit)
Stream over a range of members in a sorted set, by score, with scores ordered from high to low.Executions<Long>
NodeSelectionSortedSetCommands. zrevrangebyscore(ValueStreamingChannel<V> channel, K key, String max, String min)
Executions<Long>
NodeSelectionSortedSetCommands. zrevrangebyscore(ValueStreamingChannel<V> channel, K key, String max, String min, long offset, long count)
-
Uses of ValueStreamingChannel in io.lettuce.core.output
Constructors in io.lettuce.core.output with parameters of type ValueStreamingChannel Constructor Description ValueScanStreamingOutput(RedisCodec<K,V> codec, ValueStreamingChannel<V> channel)
ValueStreamingOutput(RedisCodec<K,V> codec, ValueStreamingChannel<V> channel)
-