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> XReadArgs.StreamOffset<K> |
XReadArgs.StreamOffset.from(K name,
String offset)
Read all arriving elements from the stream identified by
name starting at offset . |
static <K> XReadArgs.StreamOffset<K> |
XReadArgs.StreamOffset.lastConsumed(K name)
Read all new arriving elements from the stream identified by
name with ids greater than the last one consumed
by the consumer group. |
static <K> XReadArgs.StreamOffset<K> |
XReadArgs.StreamOffset.latest(K name)
Read all new arriving elements from the stream identified by
name . |
Modifier and Type | Method and Description |
---|---|
RedisFuture<String> |
AbstractRedisAsyncCommands.xgroupCreate(XReadArgs.StreamOffset<K> offset,
K group) |
Mono<String> |
AbstractRedisReactiveCommands.xgroupCreate(XReadArgs.StreamOffset<K> streamOffset,
K group) |
RedisFuture<String> |
AbstractRedisAsyncCommands.xgroupCreate(XReadArgs.StreamOffset<K> offset,
K group,
XGroupCreateArgs args) |
Mono<String> |
AbstractRedisReactiveCommands.xgroupCreate(XReadArgs.StreamOffset<K> streamOffset,
K group,
XGroupCreateArgs args) |
RedisFuture<String> |
AbstractRedisAsyncCommands.xgroupSetid(XReadArgs.StreamOffset<K> offset,
K group) |
Mono<String> |
AbstractRedisReactiveCommands.xgroupSetid(XReadArgs.StreamOffset<K> streamOffset,
K group) |
RedisFuture<List<StreamMessage<K,V>>> |
AbstractRedisAsyncCommands.xread(XReadArgs.StreamOffset<K>... streams) |
Flux<StreamMessage<K,V>> |
AbstractRedisReactiveCommands.xread(XReadArgs.StreamOffset<K>... streams) |
RedisFuture<List<StreamMessage<K,V>>> |
AbstractRedisAsyncCommands.xread(XReadArgs args,
XReadArgs.StreamOffset<K>... streams) |
Flux<StreamMessage<K,V>> |
AbstractRedisReactiveCommands.xread(XReadArgs args,
XReadArgs.StreamOffset<K>... streams) |
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<String> |
RedisStreamAsyncCommands.xgroupCreate(XReadArgs.StreamOffset<K> streamOffset,
K group)
Create a consumer group.
|
RedisFuture<String> |
RedisStreamAsyncCommands.xgroupCreate(XReadArgs.StreamOffset<K> streamOffset,
K group,
XGroupCreateArgs args)
Create a consumer group.
|
RedisFuture<String> |
RedisStreamAsyncCommands.xgroupSetid(XReadArgs.StreamOffset<K> streamOffset,
K group)
Set the current
group id. |
RedisFuture<List<StreamMessage<K,V>>> |
RedisStreamAsyncCommands.xread(XReadArgs.StreamOffset<K>... streams)
Read messages from one or more
XReadArgs.StreamOffset s. |
RedisFuture<List<StreamMessage<K,V>>> |
RedisStreamAsyncCommands.xread(XReadArgs args,
XReadArgs.StreamOffset<K>... streams)
Read messages from one or more
XReadArgs.StreamOffset s. |
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 |
---|---|
Mono<String> |
RedisStreamReactiveCommands.xgroupCreate(XReadArgs.StreamOffset<K> streamOffset,
K group)
Create a consumer group.
|
Mono<String> |
RedisStreamReactiveCommands.xgroupCreate(XReadArgs.StreamOffset<K> streamOffset,
K group,
XGroupCreateArgs args)
Create a consumer group.
|
Mono<String> |
RedisStreamReactiveCommands.xgroupSetid(XReadArgs.StreamOffset<K> streamOffset,
K group)
Set the current
group id. |
Flux<StreamMessage<K,V>> |
RedisStreamReactiveCommands.xread(XReadArgs.StreamOffset<K>... streams)
Read messages from one or more
XReadArgs.StreamOffset s. |
Flux<StreamMessage<K,V>> |
RedisStreamReactiveCommands.xread(XReadArgs args,
XReadArgs.StreamOffset<K>... streams)
Read messages from one or more
XReadArgs.StreamOffset s. |
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 |
---|---|
String |
RedisStreamCommands.xgroupCreate(XReadArgs.StreamOffset<K> streamOffset,
K group)
Create a consumer group.
|
String |
RedisStreamCommands.xgroupCreate(XReadArgs.StreamOffset<K> streamOffset,
K group,
XGroupCreateArgs args)
Create a consumer group.
|
String |
RedisStreamCommands.xgroupSetid(XReadArgs.StreamOffset<K> streamOffset,
K group)
Set the current
group id. |
List<StreamMessage<K,V>> |
RedisStreamCommands.xread(XReadArgs.StreamOffset<K>... streams)
Read messages from one or more
XReadArgs.StreamOffset s. |
List<StreamMessage<K,V>> |
RedisStreamCommands.xread(XReadArgs args,
XReadArgs.StreamOffset<K>... streams)
Read messages from one or more
XReadArgs.StreamOffset s. |
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<String> |
NodeSelectionStreamAsyncCommands.xgroupCreate(XReadArgs.StreamOffset<K> streamOffset,
K group)
Create a consumer group.
|
AsyncExecutions<String> |
NodeSelectionStreamAsyncCommands.xgroupCreate(XReadArgs.StreamOffset<K> streamOffset,
K group,
XGroupCreateArgs args)
Create a consumer group.
|
AsyncExecutions<String> |
NodeSelectionStreamAsyncCommands.xgroupSetid(XReadArgs.StreamOffset<K> streamOffset,
K group)
Set the current
group id. |
AsyncExecutions<List<StreamMessage<K,V>>> |
NodeSelectionStreamAsyncCommands.xread(XReadArgs.StreamOffset<K>... streams)
Read messages from one or more
XReadArgs.StreamOffset s. |
AsyncExecutions<List<StreamMessage<K,V>>> |
NodeSelectionStreamAsyncCommands.xread(XReadArgs args,
XReadArgs.StreamOffset<K>... streams)
Read messages from one or more
XReadArgs.StreamOffset s. |
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<String> |
NodeSelectionStreamCommands.xgroupCreate(XReadArgs.StreamOffset<K> streamOffset,
K group)
Create a consumer group.
|
Executions<String> |
NodeSelectionStreamCommands.xgroupCreate(XReadArgs.StreamOffset<K> streamOffset,
K group,
XGroupCreateArgs args)
Create a consumer group.
|
Executions<String> |
NodeSelectionStreamCommands.xgroupSetid(XReadArgs.StreamOffset<K> streamOffset,
K group)
Set the current
group id. |
Executions<List<StreamMessage<K,V>>> |
NodeSelectionStreamCommands.xread(XReadArgs.StreamOffset<K>... streams)
Read messages from one or more
XReadArgs.StreamOffset s. |
Executions<List<StreamMessage<K,V>>> |
NodeSelectionStreamCommands.xread(XReadArgs args,
XReadArgs.StreamOffset<K>... streams)
Read messages from one or more
XReadArgs.StreamOffset s. |
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 © 2024 lettuce.io. All rights reserved.