Uses of Interface
io.lettuce.core.output.KeyValueStreamingChannel
-
Packages that use KeyValueStreamingChannel 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.sync Redis Cluster API for synchronous executed commands.io.lettuce.core.output Implementation of different output protocols including the Streaming API. -
-
Uses of KeyValueStreamingChannel in io.lettuce.core
Methods in io.lettuce.core with parameters of type KeyValueStreamingChannel Modifier and Type Method Description RedisFuture<Long>
AbstractRedisAsyncCommands. hgetall(KeyValueStreamingChannel<K,V> channel, K key)
Mono<Long>
AbstractRedisReactiveCommands. hgetall(KeyValueStreamingChannel<K,V> channel, K key)
RedisFuture<Long>
AbstractRedisAsyncCommands. hmget(KeyValueStreamingChannel<K,V> channel, K key, K... fields)
Mono<Long>
AbstractRedisReactiveCommands. hmget(KeyValueStreamingChannel<K,V> channel, K key, K... fields)
RedisFuture<StreamScanCursor>
AbstractRedisAsyncCommands. hscan(KeyValueStreamingChannel<K,V> channel, K key)
RedisFuture<StreamScanCursor>
AbstractRedisAsyncCommands. hscan(KeyValueStreamingChannel<K,V> channel, K key, ScanArgs scanArgs)
RedisFuture<StreamScanCursor>
AbstractRedisAsyncCommands. hscan(KeyValueStreamingChannel<K,V> channel, K key, ScanCursor scanCursor)
RedisFuture<StreamScanCursor>
AbstractRedisAsyncCommands. hscan(KeyValueStreamingChannel<K,V> channel, K key, ScanCursor scanCursor, ScanArgs scanArgs)
Mono<StreamScanCursor>
AbstractRedisReactiveCommands. hscan(KeyValueStreamingChannel<K,V> channel, K key)
Mono<StreamScanCursor>
AbstractRedisReactiveCommands. hscan(KeyValueStreamingChannel<K,V> channel, K key, ScanArgs scanArgs)
Mono<StreamScanCursor>
AbstractRedisReactiveCommands. hscan(KeyValueStreamingChannel<K,V> channel, K key, ScanCursor scanCursor)
Mono<StreamScanCursor>
AbstractRedisReactiveCommands. hscan(KeyValueStreamingChannel<K,V> channel, K key, ScanCursor scanCursor, ScanArgs scanArgs)
RedisFuture<Long>
AbstractRedisAsyncCommands. mget(KeyValueStreamingChannel<K,V> channel, Iterable<K> keys)
RedisFuture<Long>
AbstractRedisAsyncCommands. mget(KeyValueStreamingChannel<K,V> channel, K... keys)
Mono<Long>
AbstractRedisReactiveCommands. mget(KeyValueStreamingChannel<K,V> channel, Iterable<K> keys)
Mono<Long>
AbstractRedisReactiveCommands. mget(KeyValueStreamingChannel<K,V> channel, K... keys)
-
Uses of KeyValueStreamingChannel in io.lettuce.core.api.async
Methods in io.lettuce.core.api.async with parameters of type KeyValueStreamingChannel Modifier and Type Method Description RedisFuture<Long>
RedisHashAsyncCommands. hgetall(KeyValueStreamingChannel<K,V> channel, K key)
Stream over all the fields and values in a hash.RedisFuture<Long>
RedisHashAsyncCommands. hmget(KeyValueStreamingChannel<K,V> channel, K key, K... fields)
Stream over the values of all the given hash fields.RedisFuture<StreamScanCursor>
RedisHashAsyncCommands. hscan(KeyValueStreamingChannel<K,V> channel, K key)
Incrementally iterate hash fields and associated values.RedisFuture<StreamScanCursor>
RedisHashAsyncCommands. hscan(KeyValueStreamingChannel<K,V> channel, K key, ScanArgs scanArgs)
Incrementally iterate hash fields and associated values.RedisFuture<StreamScanCursor>
RedisHashAsyncCommands. hscan(KeyValueStreamingChannel<K,V> channel, K key, ScanCursor scanCursor)
Incrementally iterate hash fields and associated values.RedisFuture<StreamScanCursor>
RedisHashAsyncCommands. hscan(KeyValueStreamingChannel<K,V> channel, K key, ScanCursor scanCursor, ScanArgs scanArgs)
Incrementally iterate hash fields and associated values.RedisFuture<Long>
RedisStringAsyncCommands. mget(KeyValueStreamingChannel<K,V> channel, K... keys)
Stream over the values of all the given keys. -
Uses of KeyValueStreamingChannel in io.lettuce.core.api.reactive
Methods in io.lettuce.core.api.reactive with parameters of type KeyValueStreamingChannel Modifier and Type Method Description Mono<Long>
RedisHashReactiveCommands. hgetall(KeyValueStreamingChannel<K,V> channel, K key)
Deprecated.since 6.0 in favor of consuming large results through thePublisher
returned byRedisHashReactiveCommands.hgetall(K)
.Mono<Long>
RedisHashReactiveCommands. hmget(KeyValueStreamingChannel<K,V> channel, K key, K... fields)
Deprecated.since 6.0 in favor of consuming large results through thePublisher
returned byRedisHashReactiveCommands.hmget(K, K...)
.Mono<StreamScanCursor>
RedisHashReactiveCommands. hscan(KeyValueStreamingChannel<K,V> channel, K key)
Deprecated.since 6.0 in favor of consuming large results through thePublisher
returned byRedisHashReactiveCommands.hscan(K)
.Mono<StreamScanCursor>
RedisHashReactiveCommands. hscan(KeyValueStreamingChannel<K,V> channel, K key, ScanArgs scanArgs)
Deprecated.since 6.0 in favor of consuming large results through thePublisher
returned byRedisHashReactiveCommands.hscan(K)
.Mono<StreamScanCursor>
RedisHashReactiveCommands. hscan(KeyValueStreamingChannel<K,V> channel, K key, ScanCursor scanCursor)
Deprecated.since 6.0 in favor of consuming large results through thePublisher
returned byRedisHashReactiveCommands.hscan(K)
.Mono<StreamScanCursor>
RedisHashReactiveCommands. hscan(KeyValueStreamingChannel<K,V> channel, K key, ScanCursor scanCursor, ScanArgs scanArgs)
Deprecated.since 6.0 in favor of consuming large results through thePublisher
returned byRedisHashReactiveCommands.hscan(K)
.Mono<Long>
RedisStringReactiveCommands. mget(KeyValueStreamingChannel<K,V> channel, K... keys)
Deprecated.since 6.0 in favor of consuming large results through thePublisher
returned byRedisStringReactiveCommands.mget(K...)
. -
Uses of KeyValueStreamingChannel in io.lettuce.core.api.sync
Methods in io.lettuce.core.api.sync with parameters of type KeyValueStreamingChannel Modifier and Type Method Description Long
RedisHashCommands. hgetall(KeyValueStreamingChannel<K,V> channel, K key)
Stream over all the fields and values in a hash.Long
RedisHashCommands. hmget(KeyValueStreamingChannel<K,V> channel, K key, K... fields)
Stream over the values of all the given hash fields.StreamScanCursor
RedisHashCommands. hscan(KeyValueStreamingChannel<K,V> channel, K key)
Incrementally iterate hash fields and associated values.StreamScanCursor
RedisHashCommands. hscan(KeyValueStreamingChannel<K,V> channel, K key, ScanArgs scanArgs)
Incrementally iterate hash fields and associated values.StreamScanCursor
RedisHashCommands. hscan(KeyValueStreamingChannel<K,V> channel, K key, ScanCursor scanCursor)
Incrementally iterate hash fields and associated values.StreamScanCursor
RedisHashCommands. hscan(KeyValueStreamingChannel<K,V> channel, K key, ScanCursor scanCursor, ScanArgs scanArgs)
Incrementally iterate hash fields and associated values.Long
RedisStringCommands. mget(KeyValueStreamingChannel<K,V> channel, K... keys)
Stream over the values of all the given keys. -
Uses of KeyValueStreamingChannel in io.lettuce.core.cluster
Methods in io.lettuce.core.cluster with parameters of type KeyValueStreamingChannel Modifier and Type Method Description RedisFuture<Long>
RedisAdvancedClusterAsyncCommandsImpl. mget(KeyValueStreamingChannel<K,V> channel, Iterable<K> keys)
RedisFuture<Long>
RedisAdvancedClusterAsyncCommandsImpl. mget(KeyValueStreamingChannel<K,V> channel, K... keys)
Mono<Long>
RedisAdvancedClusterReactiveCommandsImpl. mget(KeyValueStreamingChannel<K,V> channel, Iterable<K> keys)
Mono<Long>
RedisAdvancedClusterReactiveCommandsImpl. mget(KeyValueStreamingChannel<K,V> channel, K... keys)
-
Uses of KeyValueStreamingChannel in io.lettuce.core.cluster.api.async
Methods in io.lettuce.core.cluster.api.async with parameters of type KeyValueStreamingChannel Modifier and Type Method Description AsyncExecutions<Long>
NodeSelectionHashAsyncCommands. hgetall(KeyValueStreamingChannel<K,V> channel, K key)
Stream over all the fields and values in a hash.AsyncExecutions<Long>
NodeSelectionHashAsyncCommands. hmget(KeyValueStreamingChannel<K,V> channel, K key, K... fields)
Stream over the values of all the given hash fields.AsyncExecutions<StreamScanCursor>
NodeSelectionHashAsyncCommands. hscan(KeyValueStreamingChannel<K,V> channel, K key)
Incrementally iterate hash fields and associated values.AsyncExecutions<StreamScanCursor>
NodeSelectionHashAsyncCommands. hscan(KeyValueStreamingChannel<K,V> channel, K key, ScanArgs scanArgs)
Incrementally iterate hash fields and associated values.AsyncExecutions<StreamScanCursor>
NodeSelectionHashAsyncCommands. hscan(KeyValueStreamingChannel<K,V> channel, K key, ScanCursor scanCursor)
Incrementally iterate hash fields and associated values.AsyncExecutions<StreamScanCursor>
NodeSelectionHashAsyncCommands. hscan(KeyValueStreamingChannel<K,V> channel, K key, ScanCursor scanCursor, ScanArgs scanArgs)
Incrementally iterate hash fields and associated values.AsyncExecutions<Long>
NodeSelectionStringAsyncCommands. mget(KeyValueStreamingChannel<K,V> channel, K... keys)
Stream over the values of all the given keys. -
Uses of KeyValueStreamingChannel in io.lettuce.core.cluster.api.sync
Methods in io.lettuce.core.cluster.api.sync with parameters of type KeyValueStreamingChannel Modifier and Type Method Description Executions<Long>
NodeSelectionHashCommands. hgetall(KeyValueStreamingChannel<K,V> channel, K key)
Stream over all the fields and values in a hash.Executions<Long>
NodeSelectionHashCommands. hmget(KeyValueStreamingChannel<K,V> channel, K key, K... fields)
Stream over the values of all the given hash fields.Executions<StreamScanCursor>
NodeSelectionHashCommands. hscan(KeyValueStreamingChannel<K,V> channel, K key)
Incrementally iterate hash fields and associated values.Executions<StreamScanCursor>
NodeSelectionHashCommands. hscan(KeyValueStreamingChannel<K,V> channel, K key, ScanArgs scanArgs)
Incrementally iterate hash fields and associated values.Executions<StreamScanCursor>
NodeSelectionHashCommands. hscan(KeyValueStreamingChannel<K,V> channel, K key, ScanCursor scanCursor)
Incrementally iterate hash fields and associated values.Executions<StreamScanCursor>
NodeSelectionHashCommands. hscan(KeyValueStreamingChannel<K,V> channel, K key, ScanCursor scanCursor, ScanArgs scanArgs)
Incrementally iterate hash fields and associated values.Executions<Long>
NodeSelectionStringCommands. mget(KeyValueStreamingChannel<K,V> channel, K... keys)
Stream over the values of all the given keys. -
Uses of KeyValueStreamingChannel in io.lettuce.core.output
Constructors in io.lettuce.core.output with parameters of type KeyValueStreamingChannel Constructor Description KeyValueScanStreamingOutput(RedisCodec<K,V> codec, KeyValueStreamingChannel<K,V> channel)
KeyValueStreamingOutput(RedisCodec<K,V> codec, KeyValueStreamingChannel<K,V> channel)
KeyValueStreamingOutput(RedisCodec<K,V> codec, KeyValueStreamingChannel<K,V> channel, Iterable<K> keys)
-