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 Flux<ByteBufferRecord>	ReactiveStreamCommands.xRead(StreamOffset<ByteBuffer>... streams)	Read records from one or more StreamOffsets.
default Flux<ByteBufferRecord>	ReactiveStreamCommands.xRead(StreamReadOptions readOptions, StreamOffset<ByteBuffer>... streams)	Read records from one or more StreamOffsets.
List<@NonNull ByteRecord>	RedisStreamCommands.xRead(@NonNull StreamReadOptions readOptions, @NonNull StreamOffset<byte[]> @NonNull ... streams)	Read records from one or more StreamOffsets.
default List<@NonNull ByteRecord>	RedisStreamCommands.xRead(StreamOffset<byte @NonNull []> @NonNull ... streams)	Read records from one or more StreamOffsets.
List<StringRecord>	DefaultStringRedisConnection.xReadAsString(StreamReadOptions readOptions, StreamOffset<String>... streams)
default List<StringRecord>	StringRedisConnection.xReadAsString(@NonNull StreamOffset<String> stream)	Read records from one or more StreamOffsets.
default List<StringRecord>	StringRedisConnection.xReadAsString(@NonNull StreamOffset<String>... streams)	Read records from one or more StreamOffsets.
default List<StringRecord>	StringRedisConnection.xReadAsString(@NonNull StreamReadOptions readOptions, @NonNull StreamOffset<String> stream)	Read records from one or more StreamOffsets.
List<StringRecord>	StringRedisConnection.xReadAsString(@NonNull StreamReadOptions readOptions, @NonNull 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 Flux<ByteBufferRecord>	ReactiveStreamCommands.xReadGroup(Consumer consumer, StreamOffset<ByteBuffer>... streams)	Read records from one or more StreamOffsets using a consumer group.
default Flux<ByteBufferRecord>	ReactiveStreamCommands.xReadGroup(Consumer consumer, StreamReadOptions readOptions, StreamOffset<ByteBuffer>... streams)	Read records from one or more StreamOffsets using a consumer group.
default List<@NonNull ByteRecord>	RedisStreamCommands.xReadGroup(@NonNull Consumer consumer, @NonNull StreamOffset<byte[]> @NonNull ... streams)	Read records from one or more StreamOffsets using a consumer group.
List<@NonNull ByteRecord>	RedisStreamCommands.xReadGroup(@NonNull Consumer consumer, @NonNull StreamReadOptions readOptions, @NonNull StreamOffset<byte[]> @NonNull ... 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(@NonNull Consumer consumer, @NonNull StreamOffset<String> stream)	Read records from one or more StreamOffsets using a consumer group.
default List<StringRecord>	StringRedisConnection.xReadGroupAsString(@NonNull Consumer consumer, @NonNull StreamOffset<String> @NonNull ... streams)	Read records from one or more StreamOffsets using a consumer group.
default List<StringRecord>	StringRedisConnection.xReadGroupAsString(@NonNull Consumer consumer, @NonNull StreamReadOptions readOptions, @NonNull StreamOffset<String> stream)	Read records from one or more StreamOffsets using a consumer group.
List<StringRecord>	StringRedisConnection.xReadGroupAsString(@NonNull Consumer consumer, @NonNull StreamReadOptions readOptions, @NonNull StreamOffset<String> @NonNull ... 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, @Nullable StreamReadOptions readOptions, @Nullable 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> Flux<ObjectRecord<K,V>>	ReactiveStreamOperations.read(@NonNull Class<V> targetType, @NonNull Consumer consumer, @NonNull StreamOffset<K> @NonNull ... streams)	Read records from one or more StreamOffsets using a consumer group as ObjectRecord.
default <V> Flux<ObjectRecord<K,V>>	ReactiveStreamOperations.read(@NonNull Class<V> targetType, @NonNull Consumer consumer, @NonNull StreamReadOptions readOptions, @NonNull StreamOffset<K> @NonNull ... streams)	Read records from one or more StreamOffsets using a consumer group as ObjectRecord.
default <V> Flux<ObjectRecord<K,V>>	ReactiveStreamOperations.read(@NonNull Class<V> targetType, @NonNull StreamOffset<K> stream)	Read records from a StreamOffset as ObjectRecord.
default <V> Flux<ObjectRecord<K,V>>	ReactiveStreamOperations.read(@NonNull Class<V> targetType, @NonNull StreamOffset<K>... streams)	Read records from one or more StreamOffsets as ObjectRecord.
default <V> Flux<ObjectRecord<K,V>>	ReactiveStreamOperations.read(@NonNull Class<V> targetType, @NonNull StreamReadOptions readOptions, @NonNull StreamOffset<K> @NonNull ... streams)	Read records from one or more StreamOffsets as ObjectRecord.
default Flux<MapRecord<K,HK,HV>>	ReactiveStreamOperations.read(@NonNull Consumer consumer, @NonNull StreamOffset<K> @NonNull ... streams)	Read records from one or more StreamOffsets using a consumer group.
Flux<MapRecord<K,HK,HV>>	ReactiveStreamOperations.read(@NonNull Consumer consumer, @NonNull StreamReadOptions readOptions, @NonNull StreamOffset<K>... streams)	Read records from one or more StreamOffsets using a consumer group.
default Flux<MapRecord<K,HK,HV>>	ReactiveStreamOperations.read(@NonNull StreamOffset<K> stream)	Read records from a StreamOffset as ObjectRecord.
default Flux<MapRecord<K,HK,HV>>	ReactiveStreamOperations.read(@NonNull StreamOffset<K>... streams)	Read records from one or more StreamOffsets.
Flux<MapRecord<K,HK,HV>>	ReactiveStreamOperations.read(@NonNull StreamReadOptions readOptions, @NonNull StreamOffset<K> @NonNull ... streams)	Read records from one or more StreamOffsets.
default <V> List<ObjectRecord<K,V>>	StreamOperations.read(@NonNull Class<V> targetType, @NonNull Consumer consumer, @NonNull StreamReadOptions readOptions, StreamOffset<@NonNull K> @NonNull ... streams)	Read records from one or more StreamOffsets using a consumer group as ObjectRecord.
default <V> List<ObjectRecord<K,V>>	StreamOperations.read(@NonNull Class<V> targetType, @NonNull Consumer consumer, StreamOffset<@NonNull K> @NonNull ... streams)	Read records from one or more StreamOffsets using a consumer group as ObjectRecord.
default <V> List<@NonNull ObjectRecord<K,V>>	StreamOperations.read(@NonNull Class<V> targetType, @NonNull StreamReadOptions readOptions, StreamOffset<@NonNull K> @NonNull ... streams)	Read records from one or more StreamOffsets as ObjectRecord.
default <V> List<@NonNull ObjectRecord<K,V>>	StreamOperations.read(@NonNull Class<V> targetType, StreamOffset<@NonNull K> @NonNull ... streams)	Read records from one or more StreamOffsets as ObjectRecord.
List<@NonNull MapRecord<K,HK,HV>>	StreamOperations.read(@NonNull Consumer consumer, @NonNull StreamReadOptions readOptions, StreamOffset<@NonNull K> @NonNull ... streams)	Read records from one or more StreamOffsets using a consumer group.
default List<@NonNull MapRecord<K,HK,HV>>	StreamOperations.read(@NonNull Consumer consumer, StreamOffset<@NonNull K> @NonNull ... streams)	Read records from one or more StreamOffsets using a consumer group.
List<@NonNull MapRecord<K,HK,HV>>	StreamOperations.read(@NonNull StreamReadOptions readOptions, StreamOffset<@NonNull K> @NonNull ... streams)	Read records from one or more StreamOffsets.
default List<@NonNull MapRecord<K,HK,HV>>	StreamOperations.read(StreamOffset<@NonNull K> @NonNull ... 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.
Flux<V>	StreamReceiver.receive(Consumer consumer, StreamOffset<K> streamOffset)	Starts a Redis Stream consumer that consumes records from the stream.
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.
Flux<V>	StreamReceiver.receiveAutoAck(Consumer consumer, StreamOffset<K> streamOffset)	Starts a Redis Stream consumer that consumes records from the stream.