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 |
---|---|
static <K> Consumer<K> |
Consumer.from(K group,
K name)
Create a new consumer.
|
Modifier and Type | Method and Description |
---|---|
RedisFuture<List<StreamMessage<K,V>>> |
AbstractRedisAsyncCommands.xclaim(K key,
Consumer<K> consumer,
long minIdleTime,
String... messageIds) |
Flux<StreamMessage<K,V>> |
AbstractRedisReactiveCommands.xclaim(K key,
Consumer<K> consumer,
long minIdleTime,
String... messageIds) |
RedisFuture<List<StreamMessage<K,V>>> |
AbstractRedisAsyncCommands.xclaim(K key,
Consumer<K> consumer,
XClaimArgs args,
String... messageIds) |
Flux<StreamMessage<K,V>> |
AbstractRedisReactiveCommands.xclaim(K key,
Consumer<K> consumer,
XClaimArgs args,
String... messageIds) |
RedisFuture<Boolean> |
AbstractRedisAsyncCommands.xgroupDelconsumer(K key,
Consumer<K> consumer) |
Mono<Boolean> |
AbstractRedisReactiveCommands.xgroupDelconsumer(K key,
Consumer<K> consumer) |
RedisFuture<List<Object>> |
AbstractRedisAsyncCommands.xpending(K key,
Consumer<K> consumer,
Range<String> range,
Limit limit) |
Flux<Object> |
AbstractRedisReactiveCommands.xpending(K key,
Consumer<K> consumer,
Range<String> range,
Limit limit) |
RedisFuture<List<StreamMessage<K,V>>> |
AbstractRedisAsyncCommands.xreadgroup(Consumer<K> consumer,
XReadArgs.StreamOffset<K>... streams) |
Flux<StreamMessage<K,V>> |
AbstractRedisReactiveCommands.xreadgroup(Consumer<K> consumer,
XReadArgs.StreamOffset<K>... streams) |
RedisFuture<List<StreamMessage<K,V>>> |
AbstractRedisAsyncCommands.xreadgroup(Consumer<K> consumer,
XReadArgs args,
XReadArgs.StreamOffset<K>... streams) |
Flux<StreamMessage<K,V>> |
AbstractRedisReactiveCommands.xreadgroup(Consumer<K> consumer,
XReadArgs args,
XReadArgs.StreamOffset<K>... streams) |
Modifier and Type | Method and Description |
---|---|
RedisFuture<List<StreamMessage<K,V>>> |
RedisStreamAsyncCommands.xclaim(K key,
Consumer<K> consumer,
long minIdleTime,
String... messageIds)
Gets ownership of one or multiple messages in the Pending Entries List of a given stream consumer group.
|
RedisFuture<List<StreamMessage<K,V>>> |
RedisStreamAsyncCommands.xclaim(K key,
Consumer<K> consumer,
XClaimArgs args,
String... messageIds)
Gets ownership of one or multiple messages in the Pending Entries List of a given stream consumer group.
|
RedisFuture<Boolean> |
RedisStreamAsyncCommands.xgroupDelconsumer(K key,
Consumer<K> consumer)
Delete a consumer from a consumer group.
|
RedisFuture<List<Object>> |
RedisStreamAsyncCommands.xpending(K key,
Consumer<K> consumer,
Range<String> range,
Limit limit)
Read pending messages from a stream within a specific
Range . |
RedisFuture<List<StreamMessage<K,V>>> |
RedisStreamAsyncCommands.xreadgroup(Consumer<K> consumer,
XReadArgs.StreamOffset<K>... streams)
Read messages from one or more
XReadArgs.StreamOffset s using a consumer group. |
RedisFuture<List<StreamMessage<K,V>>> |
RedisStreamAsyncCommands.xreadgroup(Consumer<K> consumer,
XReadArgs args,
XReadArgs.StreamOffset<K>... streams)
Read messages from one or more
XReadArgs.StreamOffset s using a consumer group. |
Modifier and Type | Method and Description |
---|---|
Flux<StreamMessage<K,V>> |
RedisStreamReactiveCommands.xclaim(K key,
Consumer<K> consumer,
long minIdleTime,
String... messageIds)
Gets ownership of one or multiple messages in the Pending Entries List of a given stream consumer group.
|
Flux<StreamMessage<K,V>> |
RedisStreamReactiveCommands.xclaim(K key,
Consumer<K> consumer,
XClaimArgs args,
String... messageIds)
Gets ownership of one or multiple messages in the Pending Entries List of a given stream consumer group.
|
Mono<Boolean> |
RedisStreamReactiveCommands.xgroupDelconsumer(K key,
Consumer<K> consumer)
Delete a consumer from a consumer group.
|
Flux<Object> |
RedisStreamReactiveCommands.xpending(K key,
Consumer<K> consumer,
Range<String> range,
Limit limit)
Read pending messages from a stream within a specific
Range . |
Flux<StreamMessage<K,V>> |
RedisStreamReactiveCommands.xreadgroup(Consumer<K> consumer,
XReadArgs.StreamOffset<K>... streams)
Read messages from one or more
XReadArgs.StreamOffset s using a consumer group. |
Flux<StreamMessage<K,V>> |
RedisStreamReactiveCommands.xreadgroup(Consumer<K> consumer,
XReadArgs args,
XReadArgs.StreamOffset<K>... streams)
Read messages from one or more
XReadArgs.StreamOffset s using a consumer group. |
Modifier and Type | Method and Description |
---|---|
List<StreamMessage<K,V>> |
RedisStreamCommands.xclaim(K key,
Consumer<K> consumer,
long minIdleTime,
String... messageIds)
Gets ownership of one or multiple messages in the Pending Entries List of a given stream consumer group.
|
List<StreamMessage<K,V>> |
RedisStreamCommands.xclaim(K key,
Consumer<K> consumer,
XClaimArgs args,
String... messageIds)
Gets ownership of one or multiple messages in the Pending Entries List of a given stream consumer group.
|
Boolean |
RedisStreamCommands.xgroupDelconsumer(K key,
Consumer<K> consumer)
Delete a consumer from a consumer group.
|
List<Object> |
RedisStreamCommands.xpending(K key,
Consumer<K> consumer,
Range<String> range,
Limit limit)
Read pending messages from a stream within a specific
Range . |
List<StreamMessage<K,V>> |
RedisStreamCommands.xreadgroup(Consumer<K> consumer,
XReadArgs.StreamOffset<K>... streams)
Read messages from one or more
XReadArgs.StreamOffset s using a consumer group. |
List<StreamMessage<K,V>> |
RedisStreamCommands.xreadgroup(Consumer<K> consumer,
XReadArgs args,
XReadArgs.StreamOffset<K>... streams)
Read messages from one or more
XReadArgs.StreamOffset s using a consumer group. |
Modifier and Type | Method and Description |
---|---|
AsyncExecutions<List<StreamMessage<K,V>>> |
NodeSelectionStreamAsyncCommands.xclaim(K key,
Consumer<K> consumer,
long minIdleTime,
String... messageIds)
Gets ownership of one or multiple messages in the Pending Entries List of a given stream consumer group.
|
AsyncExecutions<List<StreamMessage<K,V>>> |
NodeSelectionStreamAsyncCommands.xclaim(K key,
Consumer<K> consumer,
XClaimArgs args,
String... messageIds)
Gets ownership of one or multiple messages in the Pending Entries List of a given stream consumer group.
|
AsyncExecutions<Boolean> |
NodeSelectionStreamAsyncCommands.xgroupDelconsumer(K key,
Consumer<K> consumer)
Delete a consumer from a consumer group.
|
AsyncExecutions<List<Object>> |
NodeSelectionStreamAsyncCommands.xpending(K key,
Consumer<K> consumer,
Range<String> range,
Limit limit)
Read pending messages from a stream within a specific
Range . |
AsyncExecutions<List<StreamMessage<K,V>>> |
NodeSelectionStreamAsyncCommands.xreadgroup(Consumer<K> consumer,
XReadArgs.StreamOffset<K>... streams)
Read messages from one or more
XReadArgs.StreamOffset s using a consumer group. |
AsyncExecutions<List<StreamMessage<K,V>>> |
NodeSelectionStreamAsyncCommands.xreadgroup(Consumer<K> consumer,
XReadArgs args,
XReadArgs.StreamOffset<K>... streams)
Read messages from one or more
XReadArgs.StreamOffset s using a consumer group. |
Modifier and Type | Method and Description |
---|---|
Executions<List<StreamMessage<K,V>>> |
NodeSelectionStreamCommands.xclaim(K key,
Consumer<K> consumer,
long minIdleTime,
String... messageIds)
Gets ownership of one or multiple messages in the Pending Entries List of a given stream consumer group.
|
Executions<List<StreamMessage<K,V>>> |
NodeSelectionStreamCommands.xclaim(K key,
Consumer<K> consumer,
XClaimArgs args,
String... messageIds)
Gets ownership of one or multiple messages in the Pending Entries List of a given stream consumer group.
|
Executions<Boolean> |
NodeSelectionStreamCommands.xgroupDelconsumer(K key,
Consumer<K> consumer)
Delete a consumer from a consumer group.
|
Executions<List<Object>> |
NodeSelectionStreamCommands.xpending(K key,
Consumer<K> consumer,
Range<String> range,
Limit limit)
Read pending messages from a stream within a specific
Range . |
Executions<List<StreamMessage<K,V>>> |
NodeSelectionStreamCommands.xreadgroup(Consumer<K> consumer,
XReadArgs.StreamOffset<K>... streams)
Read messages from one or more
XReadArgs.StreamOffset s using a consumer group. |
Executions<List<StreamMessage<K,V>>> |
NodeSelectionStreamCommands.xreadgroup(Consumer<K> consumer,
XReadArgs args,
XReadArgs.StreamOffset<K>... streams)
Read messages from one or more
XReadArgs.StreamOffset s using a consumer group. |
Copyright © 2020 lettuce.io. All rights reserved.