Uses of Class
org.springframework.data.redis.connection.stream.ReadOffset

Packages that use ReadOffset

Package	Description
org.springframework.data.redis.connection	Connection package providing low-level abstractions for interacting with the various Redis 'drivers'/libraries.
org.springframework.data.redis.connection.stream	Data structures and interfaces to interact with Redis Streams.
org.springframework.data.redis.core	Core package for integrating Redis with Spring concepts.

Uses of ReadOffset in org.springframework.data.redis.connection

Methods in org.springframework.data.redis.connection that return ReadOffset

Modifier and Type	Method	Description
ReadOffset	ReactiveStreamCommands.GroupCommand.getReadOffset()

Methods in org.springframework.data.redis.connection with parameters of type ReadOffset

Modifier and Type	Method	Description
ReactiveStreamCommands.GroupCommand	ReactiveStreamCommands.GroupCommand.at(ReadOffset offset)
default String	DefaultedRedisConnection.xGroupCreate(byte[] key, String groupName, ReadOffset readOffset)	Deprecated. in favor of RedisCommandsProvider.streamCommands()}.
default String	DefaultedRedisConnection.xGroupCreate(byte[] key, String groupName, ReadOffset readOffset, boolean mkStream)	Deprecated. in favor of RedisCommandsProvider.streamCommands()}.
String	DefaultStringRedisConnection.xGroupCreate(byte[] key, String groupName, ReadOffset readOffset)
String	DefaultStringRedisConnection.xGroupCreate(byte[] key, String groupName, ReadOffset readOffset, boolean mkStream)
String	DefaultStringRedisConnection.xGroupCreate(String key, ReadOffset readOffset, String group)
String	DefaultStringRedisConnection.xGroupCreate(String key, ReadOffset readOffset, String group, boolean mkStream)
default reactor.core.publisher.Mono<String>	ReactiveStreamCommands.xGroupCreate(ByteBuffer key, String groupName, ReadOffset readOffset)	Create a consumer group.
default reactor.core.publisher.Mono<String>	ReactiveStreamCommands.xGroupCreate(ByteBuffer key, String groupName, ReadOffset readOffset, boolean mkStream)	Create a consumer group.
String	RedisStreamCommands.xGroupCreate(byte[] key, String groupName, ReadOffset readOffset)	Create a consumer group.
String	RedisStreamCommands.xGroupCreate(byte[] key, String groupName, ReadOffset readOffset, boolean mkStream)	Create a consumer group.
String	StringRedisConnection.xGroupCreate(String key, ReadOffset readOffset, String group)	Create a consumer group.
String	StringRedisConnection.xGroupCreate(String key, ReadOffset readOffset, String group, boolean mkStream)	Create a consumer group.

Constructors in org.springframework.data.redis.connection with parameters of type ReadOffset

Modifier	Constructor	Description
	GroupCommand(ByteBuffer key, ReactiveStreamCommands.GroupCommand.GroupCommandAction action, String groupName, String consumerName, ReadOffset offset)
	GroupCommand(ByteBuffer key, ReactiveStreamCommands.GroupCommand.GroupCommandAction action, String groupName, String consumerName, ReadOffset offset, boolean mkStream)

Uses of ReadOffset in org.springframework.data.redis.connection.stream

Methods in org.springframework.data.redis.connection.stream that return ReadOffset

Modifier and Type	Method	Description
static ReadOffset	ReadOffset.from(String offset)	Read all arriving elements from the stream starting at offset.
static ReadOffset	ReadOffset.from(RecordId offset)	Read all arriving elements from the stream starting at RecordId.
ReadOffset	StreamOffset.getOffset()
static ReadOffset	ReadOffset.lastConsumed()	Read all new arriving elements with ids greater than the last one consumed by the consumer group.
static ReadOffset	ReadOffset.latest()	Read from the latest offset.

Methods in org.springframework.data.redis.connection.stream with parameters of type ReadOffset

Modifier and Type	Method	Description
static <K> StreamOffset<K>	StreamOffset.create(K stream, ReadOffset readOffset)	Create a StreamOffset given key and ReadOffset.

Uses of ReadOffset in org.springframework.data.redis.core

Methods in org.springframework.data.redis.core with parameters of type ReadOffset

Modifier and Type	Method	Description
String	BoundStreamOperations.createGroup(ReadOffset readOffset, String group)	Create a consumer group.
reactor.core.publisher.Mono<String>	ReactiveStreamOperations.createGroup(K key, ReadOffset readOffset, String group)	Create a consumer group.
String	StreamOperations.createGroup(K key, ReadOffset readOffset, String group)	Create a consumer group.
default List<MapRecord<K,HK,HV>>	BoundStreamOperations.read(Consumer consumer, ReadOffset readOffset)	Read records starting from ReadOffset. using a consumer group.
List<MapRecord<K,HK,HV>>	BoundStreamOperations.read(Consumer consumer, StreamReadOptions readOptions, ReadOffset readOffset)	Read records starting from ReadOffset. using a consumer group.
default List<MapRecord<K,HK,HV>>	BoundStreamOperations.read(ReadOffset readOffset)	Read records from ReadOffset.
List<MapRecord<K,HK,HV>>	BoundStreamOperations.read(StreamReadOptions readOptions, ReadOffset readOffset)	Read records starting from ReadOffset.