Uses of Interface
io.lettuce.core.output.KeyStreamingChannel
-
Packages that use KeyStreamingChannel 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 Client for Redis Cluster, seeRedisClusterClient
.io.lettuce.core.cluster.api.async Redis Cluster API for asynchronous executed commands.io.lettuce.core.cluster.api.reactive Redis Cluster API for reactive command execution.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 KeyStreamingChannel in io.lettuce.core
Methods in io.lettuce.core with parameters of type KeyStreamingChannel Modifier and Type Method Description RedisFuture<Long>
AbstractRedisAsyncCommands. hkeys(KeyStreamingChannel<K> channel, K key)
Mono<Long>
AbstractRedisReactiveCommands. hkeys(KeyStreamingChannel<K> channel, K key)
RedisFuture<Long>
AbstractRedisAsyncCommands. keys(KeyStreamingChannel<K> channel, K pattern)
Mono<Long>
AbstractRedisReactiveCommands. keys(KeyStreamingChannel<K> channel, K pattern)
RedisFuture<StreamScanCursor>
AbstractRedisAsyncCommands. scan(KeyStreamingChannel<K> channel)
RedisFuture<StreamScanCursor>
AbstractRedisAsyncCommands. scan(KeyStreamingChannel<K> channel, ScanArgs scanArgs)
RedisFuture<StreamScanCursor>
AbstractRedisAsyncCommands. scan(KeyStreamingChannel<K> channel, ScanCursor scanCursor)
RedisFuture<StreamScanCursor>
AbstractRedisAsyncCommands. scan(KeyStreamingChannel<K> channel, ScanCursor scanCursor, ScanArgs scanArgs)
Mono<StreamScanCursor>
AbstractRedisReactiveCommands. scan(KeyStreamingChannel<K> channel)
Mono<StreamScanCursor>
AbstractRedisReactiveCommands. scan(KeyStreamingChannel<K> channel, ScanArgs scanArgs)
Mono<StreamScanCursor>
AbstractRedisReactiveCommands. scan(KeyStreamingChannel<K> channel, ScanCursor scanCursor)
Mono<StreamScanCursor>
AbstractRedisReactiveCommands. scan(KeyStreamingChannel<K> channel, ScanCursor scanCursor, ScanArgs scanArgs)
-
Uses of KeyStreamingChannel in io.lettuce.core.api.async
Methods in io.lettuce.core.api.async with parameters of type KeyStreamingChannel Modifier and Type Method Description RedisFuture<Long>
RedisHashAsyncCommands. hkeys(KeyStreamingChannel<K> channel, K key)
Stream over all the fields in a hash.RedisFuture<Long>
RedisKeyAsyncCommands. keys(KeyStreamingChannel<K> channel, K pattern)
Find all keys matching the given pattern.RedisFuture<StreamScanCursor>
RedisKeyAsyncCommands. scan(KeyStreamingChannel<K> channel)
Incrementally iterate the keys space.RedisFuture<StreamScanCursor>
RedisKeyAsyncCommands. scan(KeyStreamingChannel<K> channel, ScanArgs scanArgs)
Incrementally iterate the keys space.RedisFuture<StreamScanCursor>
RedisKeyAsyncCommands. scan(KeyStreamingChannel<K> channel, ScanCursor scanCursor)
Incrementally iterate the keys space.RedisFuture<StreamScanCursor>
RedisKeyAsyncCommands. scan(KeyStreamingChannel<K> channel, ScanCursor scanCursor, ScanArgs scanArgs)
Incrementally iterate the keys space. -
Uses of KeyStreamingChannel in io.lettuce.core.api.reactive
Methods in io.lettuce.core.api.reactive with parameters of type KeyStreamingChannel Modifier and Type Method Description Mono<Long>
RedisHashReactiveCommands. hkeys(KeyStreamingChannel<K> channel, K key)
Deprecated.since 6.0 in favor of consuming large results through thePublisher
returned byRedisHashReactiveCommands.hkeys(K)
.Mono<Long>
RedisKeyReactiveCommands. keys(KeyStreamingChannel<K> channel, K pattern)
Deprecated.since 6.0 in favor of consuming large results through thePublisher
returned byRedisKeyReactiveCommands.keys(K)
.Mono<StreamScanCursor>
RedisKeyReactiveCommands. scan(KeyStreamingChannel<K> channel)
Deprecated.since 6.0 in favor of consuming large results through thePublisher
returned byRedisKeyReactiveCommands.scan()
.Mono<StreamScanCursor>
RedisKeyReactiveCommands. scan(KeyStreamingChannel<K> channel, ScanArgs scanArgs)
Deprecated.since 6.0 in favor of consuming large results through thePublisher
returned byRedisKeyReactiveCommands.scan()
.Mono<StreamScanCursor>
RedisKeyReactiveCommands. scan(KeyStreamingChannel<K> channel, ScanCursor scanCursor)
Deprecated.since 6.0 in favor of consuming large results through thePublisher
returned byRedisKeyReactiveCommands.scan()
.Mono<StreamScanCursor>
RedisKeyReactiveCommands. scan(KeyStreamingChannel<K> channel, ScanCursor scanCursor, ScanArgs scanArgs)
Deprecated.since 6.0 in favor of consuming large results through thePublisher
returned byRedisKeyReactiveCommands.scan()
. -
Uses of KeyStreamingChannel in io.lettuce.core.api.sync
Methods in io.lettuce.core.api.sync with parameters of type KeyStreamingChannel Modifier and Type Method Description Long
RedisHashCommands. hkeys(KeyStreamingChannel<K> channel, K key)
Stream over all the fields in a hash.Long
RedisKeyCommands. keys(KeyStreamingChannel<K> channel, K pattern)
Find all keys matching the given pattern.StreamScanCursor
RedisKeyCommands. scan(KeyStreamingChannel<K> channel)
Incrementally iterate the keys space.StreamScanCursor
RedisKeyCommands. scan(KeyStreamingChannel<K> channel, ScanArgs scanArgs)
Incrementally iterate the keys space.StreamScanCursor
RedisKeyCommands. scan(KeyStreamingChannel<K> channel, ScanCursor scanCursor)
Incrementally iterate the keys space.StreamScanCursor
RedisKeyCommands. scan(KeyStreamingChannel<K> channel, ScanCursor scanCursor, ScanArgs scanArgs)
Incrementally iterate the keys space. -
Uses of KeyStreamingChannel in io.lettuce.core.cluster
Methods in io.lettuce.core.cluster with parameters of type KeyStreamingChannel Modifier and Type Method Description RedisFuture<Long>
RedisAdvancedClusterAsyncCommandsImpl. keys(KeyStreamingChannel<K> channel, K pattern)
Mono<Long>
RedisAdvancedClusterReactiveCommandsImpl. keys(KeyStreamingChannel<K> channel, K pattern)
RedisFuture<StreamScanCursor>
RedisAdvancedClusterAsyncCommandsImpl. scan(KeyStreamingChannel<K> channel)
RedisFuture<StreamScanCursor>
RedisAdvancedClusterAsyncCommandsImpl. scan(KeyStreamingChannel<K> channel, ScanArgs scanArgs)
RedisFuture<StreamScanCursor>
RedisAdvancedClusterAsyncCommandsImpl. scan(KeyStreamingChannel<K> channel, ScanCursor scanCursor)
RedisFuture<StreamScanCursor>
RedisAdvancedClusterAsyncCommandsImpl. scan(KeyStreamingChannel<K> channel, ScanCursor scanCursor, ScanArgs scanArgs)
Mono<StreamScanCursor>
RedisAdvancedClusterReactiveCommandsImpl. scan(KeyStreamingChannel<K> channel)
Mono<StreamScanCursor>
RedisAdvancedClusterReactiveCommandsImpl. scan(KeyStreamingChannel<K> channel, ScanArgs scanArgs)
Mono<StreamScanCursor>
RedisAdvancedClusterReactiveCommandsImpl. scan(KeyStreamingChannel<K> channel, ScanCursor scanCursor)
Mono<StreamScanCursor>
RedisAdvancedClusterReactiveCommandsImpl. scan(KeyStreamingChannel<K> channel, ScanCursor scanCursor, ScanArgs scanArgs)
-
Uses of KeyStreamingChannel in io.lettuce.core.cluster.api.async
Methods in io.lettuce.core.cluster.api.async with parameters of type KeyStreamingChannel Modifier and Type Method Description AsyncExecutions<Long>
NodeSelectionHashAsyncCommands. hkeys(KeyStreamingChannel<K> channel, K key)
Stream over all the fields in a hash.AsyncExecutions<Long>
NodeSelectionKeyAsyncCommands. keys(KeyStreamingChannel<K> channel, K pattern)
Find all keys matching the given pattern.RedisFuture<Long>
RedisAdvancedClusterAsyncCommands. keys(KeyStreamingChannel<K> channel, K pattern)
Find all keys matching the given pattern on all cluster upstream nodes.AsyncExecutions<StreamScanCursor>
NodeSelectionKeyAsyncCommands. scan(KeyStreamingChannel<K> channel)
Incrementally iterate the keys space.AsyncExecutions<StreamScanCursor>
NodeSelectionKeyAsyncCommands. scan(KeyStreamingChannel<K> channel, ScanArgs scanArgs)
Incrementally iterate the keys space.AsyncExecutions<StreamScanCursor>
NodeSelectionKeyAsyncCommands. scan(KeyStreamingChannel<K> channel, ScanCursor scanCursor)
Incrementally iterate the keys space.AsyncExecutions<StreamScanCursor>
NodeSelectionKeyAsyncCommands. scan(KeyStreamingChannel<K> channel, ScanCursor scanCursor, ScanArgs scanArgs)
Incrementally iterate the keys space.RedisFuture<StreamScanCursor>
RedisAdvancedClusterAsyncCommands. scan(KeyStreamingChannel<K> channel)
Incrementally iterate the keys space over the whole Cluster.RedisFuture<StreamScanCursor>
RedisAdvancedClusterAsyncCommands. scan(KeyStreamingChannel<K> channel, ScanArgs scanArgs)
Incrementally iterate the keys space over the whole Cluster.RedisFuture<StreamScanCursor>
RedisAdvancedClusterAsyncCommands. scan(KeyStreamingChannel<K> channel, ScanCursor scanCursor)
Incrementally iterate the keys space over the whole Cluster.RedisFuture<StreamScanCursor>
RedisAdvancedClusterAsyncCommands. scan(KeyStreamingChannel<K> channel, ScanCursor scanCursor, ScanArgs scanArgs)
Incrementally iterate the keys space over the whole Cluster. -
Uses of KeyStreamingChannel in io.lettuce.core.cluster.api.reactive
Methods in io.lettuce.core.cluster.api.reactive with parameters of type KeyStreamingChannel Modifier and Type Method Description Mono<Long>
RedisAdvancedClusterReactiveCommands. keys(KeyStreamingChannel<K> channel, K pattern)
Find all keys matching the given pattern on all cluster masters.Mono<StreamScanCursor>
RedisAdvancedClusterReactiveCommands. scan(KeyStreamingChannel<K> channel)
Incrementally iterate the keys space over the whole Cluster.Mono<StreamScanCursor>
RedisAdvancedClusterReactiveCommands. scan(KeyStreamingChannel<K> channel, ScanArgs scanArgs)
Incrementally iterate the keys space over the whole Cluster.Mono<StreamScanCursor>
RedisAdvancedClusterReactiveCommands. scan(KeyStreamingChannel<K> channel, ScanCursor scanCursor)
Incrementally iterate the keys space over the whole Cluster.Mono<StreamScanCursor>
RedisAdvancedClusterReactiveCommands. scan(KeyStreamingChannel<K> channel, ScanCursor scanCursor, ScanArgs scanArgs)
Incrementally iterate the keys space over the whole Cluster. -
Uses of KeyStreamingChannel in io.lettuce.core.cluster.api.sync
Methods in io.lettuce.core.cluster.api.sync with parameters of type KeyStreamingChannel Modifier and Type Method Description Executions<Long>
NodeSelectionHashCommands. hkeys(KeyStreamingChannel<K> channel, K key)
Stream over all the fields in a hash.Executions<Long>
NodeSelectionKeyCommands. keys(KeyStreamingChannel<K> channel, K pattern)
Find all keys matching the given pattern.Long
RedisAdvancedClusterCommands. keys(KeyStreamingChannel<K> channel, K pattern)
Find all keys matching the given pattern on all cluster upstream nodes.Executions<StreamScanCursor>
NodeSelectionKeyCommands. scan(KeyStreamingChannel<K> channel)
Incrementally iterate the keys space.Executions<StreamScanCursor>
NodeSelectionKeyCommands. scan(KeyStreamingChannel<K> channel, ScanArgs scanArgs)
Incrementally iterate the keys space.Executions<StreamScanCursor>
NodeSelectionKeyCommands. scan(KeyStreamingChannel<K> channel, ScanCursor scanCursor)
Incrementally iterate the keys space.Executions<StreamScanCursor>
NodeSelectionKeyCommands. scan(KeyStreamingChannel<K> channel, ScanCursor scanCursor, ScanArgs scanArgs)
Incrementally iterate the keys space.StreamScanCursor
RedisAdvancedClusterCommands. scan(KeyStreamingChannel<K> channel)
Incrementally iterate the keys space over the whole Cluster.StreamScanCursor
RedisAdvancedClusterCommands. scan(KeyStreamingChannel<K> channel, ScanArgs scanArgs)
Incrementally iterate the keys space over the whole Cluster.StreamScanCursor
RedisAdvancedClusterCommands. scan(KeyStreamingChannel<K> channel, ScanCursor scanCursor)
Incrementally iterate the keys space over the whole Cluster.StreamScanCursor
RedisAdvancedClusterCommands. scan(KeyStreamingChannel<K> channel, ScanCursor scanCursor, ScanArgs scanArgs)
Incrementally iterate the keys space over the whole Cluster. -
Uses of KeyStreamingChannel in io.lettuce.core.output
Constructors in io.lettuce.core.output with parameters of type KeyStreamingChannel Constructor Description KeyScanStreamingOutput(RedisCodec<K,V> codec, KeyStreamingChannel<K> channel)
KeyStreamingOutput(RedisCodec<K,V> codec, KeyStreamingChannel<K> channel)
-