Uses of Class
io.lettuce.core.XReadArgs.StreamOffset
-
Packages that use XReadArgs.StreamOffset 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.api.async Redis Cluster API for asynchronous executed commands.io.lettuce.core.cluster.api.sync Redis Cluster API for synchronous executed commands. -
-
Uses of XReadArgs.StreamOffset in io.lettuce.core
Methods in io.lettuce.core that return XReadArgs.StreamOffset Modifier and Type Method Description static <K> XReadArgs.StreamOffset<K>
XReadArgs.StreamOffset. from(K name, String offset)
Read all arriving elements from the stream identified byname
starting atoffset
.static <K> XReadArgs.StreamOffset<K>
XReadArgs.StreamOffset. lastConsumed(K name)
Read all new arriving elements from the stream identified byname
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 byname
.Methods in io.lettuce.core with parameters of type XReadArgs.StreamOffset Modifier and Type Method Description RedisFuture<String>
AbstractRedisAsyncCommands. xgroupCreate(XReadArgs.StreamOffset<K> offset, K group)
RedisFuture<String>
AbstractRedisAsyncCommands. xgroupCreate(XReadArgs.StreamOffset<K> offset, K group, XGroupCreateArgs args)
Mono<String>
AbstractRedisReactiveCommands. xgroupCreate(XReadArgs.StreamOffset<K> streamOffset, K group)
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)
RedisFuture<List<StreamMessage<K,V>>>
AbstractRedisAsyncCommands. xread(XReadArgs args, XReadArgs.StreamOffset<K>... streams)
Flux<StreamMessage<K,V>>
AbstractRedisReactiveCommands. xread(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)
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.StreamOffset<K>... streams)
Flux<StreamMessage<K,V>>
AbstractRedisReactiveCommands. xreadgroup(Consumer<K> consumer, XReadArgs args, XReadArgs.StreamOffset<K>... streams)
-
Uses of XReadArgs.StreamOffset in io.lettuce.core.api.async
Methods in io.lettuce.core.api.async with parameters of type XReadArgs.StreamOffset Modifier and Type Method 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 currentgroup
id.RedisFuture<List<StreamMessage<K,V>>>
RedisStreamAsyncCommands. xread(XReadArgs.StreamOffset<K>... streams)
Read messages from one or moreXReadArgs.StreamOffset
s.RedisFuture<List<StreamMessage<K,V>>>
RedisStreamAsyncCommands. xread(XReadArgs args, XReadArgs.StreamOffset<K>... streams)
Read messages from one or moreXReadArgs.StreamOffset
s.RedisFuture<List<StreamMessage<K,V>>>
RedisStreamAsyncCommands. xreadgroup(Consumer<K> consumer, XReadArgs.StreamOffset<K>... streams)
Read messages from one or moreXReadArgs.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 moreXReadArgs.StreamOffset
s using a consumer group. -
Uses of XReadArgs.StreamOffset in io.lettuce.core.api.reactive
Methods in io.lettuce.core.api.reactive with parameters of type XReadArgs.StreamOffset Modifier and Type Method 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 currentgroup
id.Flux<StreamMessage<K,V>>
RedisStreamReactiveCommands. xread(XReadArgs.StreamOffset<K>... streams)
Read messages from one or moreXReadArgs.StreamOffset
s.Flux<StreamMessage<K,V>>
RedisStreamReactiveCommands. xread(XReadArgs args, XReadArgs.StreamOffset<K>... streams)
Read messages from one or moreXReadArgs.StreamOffset
s.Flux<StreamMessage<K,V>>
RedisStreamReactiveCommands. xreadgroup(Consumer<K> consumer, XReadArgs.StreamOffset<K>... streams)
Read messages from one or moreXReadArgs.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 moreXReadArgs.StreamOffset
s using a consumer group. -
Uses of XReadArgs.StreamOffset in io.lettuce.core.api.sync
Methods in io.lettuce.core.api.sync with parameters of type XReadArgs.StreamOffset Modifier and Type Method 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 currentgroup
id.List<StreamMessage<K,V>>
RedisStreamCommands. xread(XReadArgs.StreamOffset<K>... streams)
Read messages from one or moreXReadArgs.StreamOffset
s.List<StreamMessage<K,V>>
RedisStreamCommands. xread(XReadArgs args, XReadArgs.StreamOffset<K>... streams)
Read messages from one or moreXReadArgs.StreamOffset
s.List<StreamMessage<K,V>>
RedisStreamCommands. xreadgroup(Consumer<K> consumer, XReadArgs.StreamOffset<K>... streams)
Read messages from one or moreXReadArgs.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 moreXReadArgs.StreamOffset
s using a consumer group. -
Uses of XReadArgs.StreamOffset in io.lettuce.core.cluster.api.async
Methods in io.lettuce.core.cluster.api.async with parameters of type XReadArgs.StreamOffset Modifier and Type Method 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 currentgroup
id.AsyncExecutions<List<StreamMessage<K,V>>>
NodeSelectionStreamAsyncCommands. xread(XReadArgs.StreamOffset<K>... streams)
Read messages from one or moreXReadArgs.StreamOffset
s.AsyncExecutions<List<StreamMessage<K,V>>>
NodeSelectionStreamAsyncCommands. xread(XReadArgs args, XReadArgs.StreamOffset<K>... streams)
Read messages from one or moreXReadArgs.StreamOffset
s.AsyncExecutions<List<StreamMessage<K,V>>>
NodeSelectionStreamAsyncCommands. xreadgroup(Consumer<K> consumer, XReadArgs.StreamOffset<K>... streams)
Read messages from one or moreXReadArgs.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 moreXReadArgs.StreamOffset
s using a consumer group. -
Uses of XReadArgs.StreamOffset in io.lettuce.core.cluster.api.sync
Methods in io.lettuce.core.cluster.api.sync with parameters of type XReadArgs.StreamOffset Modifier and Type Method 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 currentgroup
id.Executions<List<StreamMessage<K,V>>>
NodeSelectionStreamCommands. xread(XReadArgs.StreamOffset<K>... streams)
Read messages from one or moreXReadArgs.StreamOffset
s.Executions<List<StreamMessage<K,V>>>
NodeSelectionStreamCommands. xread(XReadArgs args, XReadArgs.StreamOffset<K>... streams)
Read messages from one or moreXReadArgs.StreamOffset
s.Executions<List<StreamMessage<K,V>>>
NodeSelectionStreamCommands. xreadgroup(Consumer<K> consumer, XReadArgs.StreamOffset<K>... streams)
Read messages from one or moreXReadArgs.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 moreXReadArgs.StreamOffset
s using a consumer group.
-