Package | Description |
---|---|
io.lettuce.core |
The Redis client package containing
RedisClient 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.
|
Modifier and Type | Method and Description |
---|---|
XPendingArgs<K> |
XPendingArgs.consumer(Consumer<K> consumer) |
XPendingArgs<K> |
XPendingArgs.group(K group) |
XPendingArgs<K> |
XPendingArgs.idle(Duration timeout)
Include only entries that are idle for
Duration . |
XPendingArgs<K> |
XPendingArgs.idle(long milliseconds)
Include only entries that are idle for
milliseconds . |
XPendingArgs<K> |
XPendingArgs.limit(Limit limit) |
XPendingArgs<K> |
XPendingArgs.range(Range<String> range) |
static <K> XPendingArgs<K> |
XPendingArgs.Builder.xpending(Consumer<K> consumer,
Range<String> range,
Limit limit)
Create a new
XPendingArgs . |
static <K> XPendingArgs<K> |
XPendingArgs.Builder.xpending(K group,
Range<String> range,
Limit limit)
Create a new
XPendingArgs . |
Modifier and Type | Method and Description |
---|---|
RedisFuture<List<PendingMessage>> |
AbstractRedisAsyncCommands.xpending(K key,
XPendingArgs<K> args) |
Flux<PendingMessage> |
AbstractRedisReactiveCommands.xpending(K key,
XPendingArgs<K> args) |
Modifier and Type | Method and Description |
---|---|
RedisFuture<List<PendingMessage>> |
RedisStreamAsyncCommands.xpending(K key,
XPendingArgs<K> args)
Read pending messages from a stream within a specific
XPendingArgs . |
Modifier and Type | Method and Description |
---|---|
Flux<PendingMessage> |
RedisStreamReactiveCommands.xpending(K key,
XPendingArgs<K> args)
Read pending messages from a stream within a specific
XPendingArgs . |
Modifier and Type | Method and Description |
---|---|
List<PendingMessage> |
RedisStreamCommands.xpending(K key,
XPendingArgs<K> args)
Read pending messages from a stream within a specific
XPendingArgs . |
Modifier and Type | Method and Description |
---|---|
AsyncExecutions<List<PendingMessage>> |
NodeSelectionStreamAsyncCommands.xpending(K key,
XPendingArgs<K> args)
Read pending messages from a stream within a specific
XPendingArgs . |
Modifier and Type | Method and Description |
---|---|
Executions<List<PendingMessage>> |
NodeSelectionStreamCommands.xpending(K key,
XPendingArgs<K> args)
Read pending messages from a stream within a specific
XPendingArgs . |
Copyright © 2024 lettuce.io. All rights reserved.