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

Packages that use StreamOffset

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.
org.springframework.data.redis.stream

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

Methods in org.springframework.data.redis.connection that return types with arguments of type StreamOffset

Modifier and Type	Method	Description
List<StreamOffset<ByteBuffer>>	ReactiveStreamCommands.ReadCommand.getStreamOffsets()

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

Modifier and Type	Method	Description
static ReactiveStreamCommands.ReadCommand	ReactiveStreamCommands.ReadCommand.from(StreamOffset<ByteBuffer> streamOffset)	Creates a new ReactiveStreamCommands.ReadCommand given a StreamOffset.
static ReactiveStreamCommands.ReadCommand	ReactiveStreamCommands.ReadCommand.from(StreamOffset<ByteBuffer>... streamOffsets)	Creates a new ReactiveStreamCommands.ReadCommand given a StreamOffsets.
default List<ByteRecord>	DefaultedRedisConnection.xRead(StreamOffset<byte[]>... streams)	Deprecated. in favor of RedisCommandsProvider.streamCommands()}.
default List<ByteRecord>	DefaultedRedisConnection.xRead(StreamReadOptions readOptions, StreamOffset<byte[]>... streams)	Deprecated. in favor of RedisCommandsProvider.streamCommands()}.
List<ByteRecord>	DefaultStringRedisConnection.xRead(StreamReadOptions readOptions, StreamOffset<byte[]>... streams)
default reactor.core.publisher.Flux<ByteBufferRecord>	ReactiveStreamCommands.xRead(StreamOffset<ByteBuffer>... streams)	Read records from one or more StreamOffsets.
default reactor.core.publisher.Flux<ByteBufferRecord>	ReactiveStreamCommands.xRead(StreamReadOptions readOptions, StreamOffset<ByteBuffer>... streams)	Read records from one or more StreamOffsets.
default List<ByteRecord>	RedisStreamCommands.xRead(StreamOffset<byte[]>... streams)	Read records from one or more StreamOffsets.
List<ByteRecord>	RedisStreamCommands.xRead(StreamReadOptions readOptions, StreamOffset<byte[]>... streams)	Read records from one or more StreamOffsets.
List<StringRecord>	DefaultStringRedisConnection.xReadAsString(StreamReadOptions readOptions, StreamOffset<String>... streams)
default List<StringRecord>	StringRedisConnection.xReadAsString(StreamOffset<String> stream)	Read records from one or more StreamOffsets.
default List<StringRecord>	StringRedisConnection.xReadAsString(StreamOffset<String>... streams)	Read records from one or more StreamOffsets.
default List<StringRecord>	StringRedisConnection.xReadAsString(StreamReadOptions readOptions, StreamOffset<String> stream)	Read records from one or more StreamOffsets.
List<StringRecord>	StringRedisConnection.xReadAsString(StreamReadOptions readOptions, StreamOffset<String>... streams)	Read records from one or more StreamOffsets.
default List<ByteRecord>	DefaultedRedisConnection.xReadGroup(Consumer consumer, StreamOffset<byte[]>... streams)	Deprecated. in favor of RedisCommandsProvider.streamCommands()}.
default List<ByteRecord>	DefaultedRedisConnection.xReadGroup(Consumer consumer, StreamReadOptions readOptions, StreamOffset<byte[]>... streams)	Deprecated. in favor of RedisCommandsProvider.streamCommands()}.
List<ByteRecord>	DefaultStringRedisConnection.xReadGroup(Consumer consumer, StreamReadOptions readOptions, StreamOffset<byte[]>... streams)
default reactor.core.publisher.Flux<ByteBufferRecord>	ReactiveStreamCommands.xReadGroup(Consumer consumer, StreamOffset<ByteBuffer>... streams)	Read records from one or more StreamOffsets using a consumer group.
default reactor.core.publisher.Flux<ByteBufferRecord>	ReactiveStreamCommands.xReadGroup(Consumer consumer, StreamReadOptions readOptions, StreamOffset<ByteBuffer>... streams)	Read records from one or more StreamOffsets using a consumer group.
default List<ByteRecord>	RedisStreamCommands.xReadGroup(Consumer consumer, StreamOffset<byte[]>... streams)	Read records from one or more StreamOffsets using a consumer group.
List<ByteRecord>	RedisStreamCommands.xReadGroup(Consumer consumer, StreamReadOptions readOptions, StreamOffset<byte[]>... streams)	Read records from one or more StreamOffsets using a consumer group.
List<StringRecord>	DefaultStringRedisConnection.xReadGroupAsString(Consumer consumer, StreamReadOptions readOptions, StreamOffset<String>... streams)
default List<StringRecord>	StringRedisConnection.xReadGroupAsString(Consumer consumer, StreamOffset<String> stream)	Read records from one or more StreamOffsets using a consumer group.
default List<StringRecord>	StringRedisConnection.xReadGroupAsString(Consumer consumer, StreamOffset<String>... streams)	Read records from one or more StreamOffsets using a consumer group.
default List<StringRecord>	StringRedisConnection.xReadGroupAsString(Consumer consumer, StreamReadOptions readOptions, StreamOffset<String> stream)	Read records from one or more StreamOffsets using a consumer group.
List<StringRecord>	StringRedisConnection.xReadGroupAsString(Consumer consumer, StreamReadOptions readOptions, StreamOffset<String>... streams)	Read records from one or more StreamOffsets using a consumer group.

Constructor parameters in org.springframework.data.redis.connection with type arguments of type StreamOffset

Modifier	Constructor	Description
	ReadCommand(List<StreamOffset<ByteBuffer>> streamOffsets, StreamReadOptions readOptions, Consumer consumer)

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

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

Modifier and Type	Method	Description
static <K> StreamOffset<K>	StreamOffset.create(K stream, ReadOffset readOffset)	Create a StreamOffset given key and ReadOffset.
static <K> StreamOffset<K>	StreamOffset.from(Record<K,?> reference)	Create a StreamOffset from the given record id as reference to create the ReadOffset.from(String).
static <K> StreamOffset<K>	StreamOffset.fromStart(K stream)	Create a StreamOffset given stream starting at ReadOffset#from("0-0").
static <K> StreamOffset<K>	StreamOffset.latest(K stream)	Create a StreamOffset given key starting at ReadOffset.latest().

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

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

Modifier and Type	Method	Description
default <V> reactor.core.publisher.Flux<ObjectRecord<K,V>>	ReactiveStreamOperations.read(Class<V> targetType, Consumer consumer, StreamOffset<K>... streams)	Read records from one or more StreamOffsets using a consumer group as ObjectRecord.
default <V> reactor.core.publisher.Flux<ObjectRecord<K,V>>	ReactiveStreamOperations.read(Class<V> targetType, Consumer consumer, StreamReadOptions readOptions, StreamOffset<K>... streams)	Read records from one or more StreamOffsets using a consumer group as ObjectRecord.
default <V> reactor.core.publisher.Flux<ObjectRecord<K,V>>	ReactiveStreamOperations.read(Class<V> targetType, StreamOffset<K> stream)	Read records from a StreamOffset as ObjectRecord.
default <V> reactor.core.publisher.Flux<ObjectRecord<K,V>>	ReactiveStreamOperations.read(Class<V> targetType, StreamOffset<K>... streams)	Read records from one or more StreamOffsets as ObjectRecord.
default <V> reactor.core.publisher.Flux<ObjectRecord<K,V>>	ReactiveStreamOperations.read(Class<V> targetType, StreamReadOptions readOptions, StreamOffset<K>... streams)	Read records from one or more StreamOffsets as ObjectRecord.
default reactor.core.publisher.Flux<MapRecord<K,HK,HV>>	ReactiveStreamOperations.read(Consumer consumer, StreamOffset<K>... streams)	Read records from one or more StreamOffsets using a consumer group.
reactor.core.publisher.Flux<MapRecord<K,HK,HV>>	ReactiveStreamOperations.read(Consumer consumer, StreamReadOptions readOptions, StreamOffset<K>... streams)	Read records from one or more StreamOffsets using a consumer group.
default reactor.core.publisher.Flux<MapRecord<K,HK,HV>>	ReactiveStreamOperations.read(StreamOffset<K> stream)	Read records from a StreamOffset as ObjectRecord.
default reactor.core.publisher.Flux<MapRecord<K,HK,HV>>	ReactiveStreamOperations.read(StreamOffset<K>... streams)	Read records from one or more StreamOffsets.
reactor.core.publisher.Flux<MapRecord<K,HK,HV>>	ReactiveStreamOperations.read(StreamReadOptions readOptions, StreamOffset<K>... streams)	Read records from one or more StreamOffsets.
default <V> List<ObjectRecord<K,V>>	StreamOperations.read(Class<V> targetType, Consumer consumer, StreamOffset<K>... streams)	Read records from one or more StreamOffsets using a consumer group as ObjectRecord.
default <V> List<ObjectRecord<K,V>>	StreamOperations.read(Class<V> targetType, Consumer consumer, StreamReadOptions readOptions, StreamOffset<K>... streams)	Read records from one or more StreamOffsets using a consumer group as ObjectRecord.
default <V> List<ObjectRecord<K,V>>	StreamOperations.read(Class<V> targetType, StreamOffset<K>... streams)	Read records from one or more StreamOffsets as ObjectRecord.
default <V> List<ObjectRecord<K,V>>	StreamOperations.read(Class<V> targetType, StreamReadOptions readOptions, StreamOffset<K>... streams)	Read records from one or more StreamOffsets as ObjectRecord.
default List<MapRecord<K,HK,HV>>	StreamOperations.read(Consumer consumer, StreamOffset<K>... streams)	Read records from one or more StreamOffsets using a consumer group.
List<MapRecord<K,HK,HV>>	StreamOperations.read(Consumer consumer, StreamReadOptions readOptions, StreamOffset<K>... streams)	Read records from one or more StreamOffsets using a consumer group.
default List<MapRecord<K,HK,HV>>	StreamOperations.read(StreamOffset<K>... streams)	Read records from one or more StreamOffsets.
List<MapRecord<K,HK,HV>>	StreamOperations.read(StreamReadOptions readOptions, StreamOffset<K>... streams)	Read records from one or more StreamOffsets.

Uses of StreamOffset in org.springframework.data.redis.stream

Methods in org.springframework.data.redis.stream that return StreamOffset

Modifier and Type	Method	Description
StreamOffset<K>	StreamMessageListenerContainer.StreamReadRequest.getStreamOffset()

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

Modifier and Type	Method	Description
static <K> StreamMessageListenerContainer.StreamReadRequestBuilder<K>	StreamMessageListenerContainer.StreamReadRequest.builder(StreamOffset<K> offset)
default Subscription	StreamMessageListenerContainer.receive(Consumer consumer, StreamOffset<K> streamOffset, StreamListener<K,V> listener)	Register a new subscription for a Redis Stream.
default Subscription	StreamMessageListenerContainer.receive(StreamOffset<K> streamOffset, StreamListener<K,V> listener)	Register a new subscription for a Redis Stream.
reactor.core.publisher.Flux<V>	StreamReceiver.receive(Consumer consumer, StreamOffset<K> streamOffset)	Starts a Redis Stream consumer that consumes records from the stream.
reactor.core.publisher.Flux<V>	StreamReceiver.receive(StreamOffset<K> streamOffset)	Starts a Redis Stream consumer that consumes records from the stream.
default Subscription	StreamMessageListenerContainer.receiveAutoAck(Consumer consumer, StreamOffset<K> streamOffset, StreamListener<K,V> listener)	Register a new subscription for a Redis Stream.
reactor.core.publisher.Flux<V>	StreamReceiver.receiveAutoAck(Consumer consumer, StreamOffset<K> streamOffset)	Starts a Redis Stream consumer that consumes records from the stream.