Uses of Class
org.springframework.data.redis.connection.stream.StreamOffset
Package
Description
Connection package providing low-level abstractions for interacting with the various Redis 'drivers'/libraries.
Data structures and interfaces to interact with Redis Streams.
Core package for integrating Redis with Spring concepts.
-
Uses of StreamOffset in org.springframework.data.redis.connection
Modifier and TypeMethodDescriptionReactiveStreamCommands.ReadCommand.from
(StreamOffset<ByteBuffer> streamOffset) Creates a newReactiveStreamCommands.ReadCommand
given aStreamOffset
.ReactiveStreamCommands.ReadCommand.from
(StreamOffset<ByteBuffer>... streamOffsets) Creates a newReactiveStreamCommands.ReadCommand
given aStreamOffset
s.default List<ByteRecord>
DefaultedRedisConnection.xRead
(StreamOffset<byte[]>... streams) Deprecated.default List<ByteRecord>
DefaultedRedisConnection.xRead
(StreamReadOptions readOptions, StreamOffset<byte[]>... streams) Deprecated.in favor ofRedisCommandsProvider.streamCommands()
}.DefaultStringRedisConnection.xRead
(StreamReadOptions readOptions, StreamOffset<byte[]>... streams) default reactor.core.publisher.Flux<ByteBufferRecord>
ReactiveStreamCommands.xRead
(StreamOffset<ByteBuffer>... streams) Read records from one or moreStreamOffset
s.default reactor.core.publisher.Flux<ByteBufferRecord>
ReactiveStreamCommands.xRead
(StreamReadOptions readOptions, StreamOffset<ByteBuffer>... streams) Read records from one or moreStreamOffset
s.default List<ByteRecord>
RedisStreamCommands.xRead
(StreamOffset<byte[]>... streams) Read records from one or moreStreamOffset
s.RedisStreamCommands.xRead
(StreamReadOptions readOptions, StreamOffset<byte[]>... streams) Read records from one or moreStreamOffset
s.DefaultStringRedisConnection.xReadAsString
(StreamReadOptions readOptions, StreamOffset<String>... streams) default List<StringRecord>
StringRedisConnection.xReadAsString
(StreamOffset<String> stream) Read records from one or moreStreamOffset
s.default List<StringRecord>
StringRedisConnection.xReadAsString
(StreamOffset<String>... streams) Read records from one or moreStreamOffset
s.default List<StringRecord>
StringRedisConnection.xReadAsString
(StreamReadOptions readOptions, StreamOffset<String> stream) Read records from one or moreStreamOffset
s.StringRedisConnection.xReadAsString
(StreamReadOptions readOptions, StreamOffset<String>... streams) Read records from one or moreStreamOffset
s.default List<ByteRecord>
DefaultedRedisConnection.xReadGroup
(Consumer consumer, StreamOffset<byte[]>... streams) Deprecated.in favor ofRedisCommandsProvider.streamCommands()
}.default List<ByteRecord>
DefaultedRedisConnection.xReadGroup
(Consumer consumer, StreamReadOptions readOptions, StreamOffset<byte[]>... streams) Deprecated.in favor ofRedisCommandsProvider.streamCommands()
}.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 moreStreamOffset
s using a consumer group.default reactor.core.publisher.Flux<ByteBufferRecord>
ReactiveStreamCommands.xReadGroup
(Consumer consumer, StreamReadOptions readOptions, StreamOffset<ByteBuffer>... streams) Read records from one or moreStreamOffset
s using a consumer group.default List<ByteRecord>
RedisStreamCommands.xReadGroup
(Consumer consumer, StreamOffset<byte[]>... streams) Read records from one or moreStreamOffset
s using a consumer group.RedisStreamCommands.xReadGroup
(Consumer consumer, StreamReadOptions readOptions, StreamOffset<byte[]>... streams) Read records from one or moreStreamOffset
s using a consumer group.DefaultStringRedisConnection.xReadGroupAsString
(Consumer consumer, StreamReadOptions readOptions, StreamOffset<String>... streams) default List<StringRecord>
StringRedisConnection.xReadGroupAsString
(Consumer consumer, StreamOffset<String> stream) Read records from one or moreStreamOffset
s using a consumer group.default List<StringRecord>
StringRedisConnection.xReadGroupAsString
(Consumer consumer, StreamOffset<String>... streams) Read records from one or moreStreamOffset
s using a consumer group.default List<StringRecord>
StringRedisConnection.xReadGroupAsString
(Consumer consumer, StreamReadOptions readOptions, StreamOffset<String> stream) Read records from one or moreStreamOffset
s using a consumer group.StringRedisConnection.xReadGroupAsString
(Consumer consumer, StreamReadOptions readOptions, StreamOffset<String>... streams) Read records from one or moreStreamOffset
s using a consumer group.ModifierConstructorDescriptionReadCommand
(List<StreamOffset<ByteBuffer>> streamOffsets, StreamReadOptions readOptions, Consumer consumer) -
Uses of StreamOffset in org.springframework.data.redis.connection.stream
Modifier and TypeMethodDescriptionstatic <K> StreamOffset<K>
StreamOffset.create
(K stream, ReadOffset readOffset) static <K> StreamOffset<K>
static <K> StreamOffset<K>
StreamOffset.fromStart
(K stream) static <K> StreamOffset<K>
StreamOffset.latest
(K stream) -
Uses of StreamOffset in org.springframework.data.redis.core
Modifier and TypeMethodDescriptiondefault <V> reactor.core.publisher.Flux<ObjectRecord<K,
V>> ReactiveStreamOperations.read
(Class<V> targetType, Consumer consumer, StreamOffset<K>... streams) Read records from one or moreStreamOffset
s using a consumer group asObjectRecord
.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 moreStreamOffset
s using a consumer group asObjectRecord
.default <V> reactor.core.publisher.Flux<ObjectRecord<K,
V>> ReactiveStreamOperations.read
(Class<V> targetType, StreamOffset<K> stream) Read records from aStreamOffset
asObjectRecord
.default <V> reactor.core.publisher.Flux<ObjectRecord<K,
V>> ReactiveStreamOperations.read
(Class<V> targetType, StreamOffset<K>... streams) Read records from one or moreStreamOffset
s asObjectRecord
.default <V> reactor.core.publisher.Flux<ObjectRecord<K,
V>> ReactiveStreamOperations.read
(Class<V> targetType, StreamReadOptions readOptions, StreamOffset<K>... streams) Read records from one or moreStreamOffset
s asObjectRecord
.ReactiveStreamOperations.read
(Consumer consumer, StreamOffset<K>... streams) Read records from one or moreStreamOffset
s using a consumer group.ReactiveStreamOperations.read
(Consumer consumer, StreamReadOptions readOptions, StreamOffset<K>... streams) Read records from one or moreStreamOffset
s using a consumer group.ReactiveStreamOperations.read
(StreamOffset<K> stream) Read records from aStreamOffset
asObjectRecord
.ReactiveStreamOperations.read
(StreamOffset<K>... streams) Read records from one or moreStreamOffset
s.ReactiveStreamOperations.read
(StreamReadOptions readOptions, StreamOffset<K>... streams) Read records from one or moreStreamOffset
s.default <V> List<ObjectRecord<K,
V>> StreamOperations.read
(Class<V> targetType, Consumer consumer, StreamOffset<K>... streams) Read records from one or moreStreamOffset
s using a consumer group asObjectRecord
.default <V> List<ObjectRecord<K,
V>> StreamOperations.read
(Class<V> targetType, Consumer consumer, StreamReadOptions readOptions, StreamOffset<K>... streams) Read records from one or moreStreamOffset
s using a consumer group asObjectRecord
.default <V> List<ObjectRecord<K,
V>> StreamOperations.read
(Class<V> targetType, StreamOffset<K>... streams) Read records from one or moreStreamOffset
s asObjectRecord
.default <V> List<ObjectRecord<K,
V>> StreamOperations.read
(Class<V> targetType, StreamReadOptions readOptions, StreamOffset<K>... streams) Read records from one or moreStreamOffset
s asObjectRecord
.StreamOperations.read
(Consumer consumer, StreamOffset<K>... streams) Read records from one or moreStreamOffset
s using a consumer group.StreamOperations.read
(Consumer consumer, StreamReadOptions readOptions, StreamOffset<K>... streams) Read records from one or moreStreamOffset
s using a consumer group.StreamOperations.read
(StreamOffset<K>... streams) Read records from one or moreStreamOffset
s.StreamOperations.read
(StreamReadOptions readOptions, StreamOffset<K>... streams) Read records from one or moreStreamOffset
s. -
Uses of StreamOffset in org.springframework.data.redis.stream
Modifier and TypeMethodDescriptionStreamMessageListenerContainer.StreamReadRequest.getStreamOffset()
Modifier and TypeMethodDescriptionstatic <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) reactor.core.publisher.Flux<V>
StreamReceiver.receive
(StreamOffset<K> streamOffset) 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)
RedisCommandsProvider.streamCommands()
}.