Uses of Interface
org.springframework.data.redis.connection.stream.ObjectRecord
Package
Description
Data structures and interfaces to interact with Redis Streams.
Core package for integrating Redis with Spring concepts.
-
Uses of ObjectRecord in org.springframework.data.redis.connection.stream
Modifier and TypeMethodDescriptionstatic <S,
V> ObjectRecord<S, V> ObjectRecord.create
(S stream, V value) static <S,
V> ObjectRecord<S, V> StreamRecords.objectBacked
(V value) Create newObjectRecord
backed by the given value.static <S,
V> ObjectRecord<S, V> Record.of
(V value) Create a newObjectRecord
instance backed by the given value.<V> ObjectRecord<S,
V> StreamRecords.RecordBuilder.ofObject
(V value) Create anObjectRecord
.default <OV> ObjectRecord<ByteBuffer,
OV> ByteBufferRecord.toObjectRecord
(HashMapper<? super OV, ? super ByteBuffer, ? super ByteBuffer> mapper) Convert a binaryMapRecord
into anObjectRecord
.default <OV> ObjectRecord<S,
OV> MapRecord.toObjectRecord
(HashMapper<? super OV, ? super K, ? super V> mapper) Apply the givenHashMapper
to the backing value to create a newMapRecord
.<SK> ObjectRecord<SK,
V> ObjectRecord.withStreamKey
(SK key) -
Uses of ObjectRecord in org.springframework.data.redis.core
Modifier and TypeMethodDescriptiondefault <V> ObjectRecord<K,
V> Map records fromMapRecord
toObjectRecord
.default <V> ObjectRecord<K,
V> Map record fromMapRecord
toObjectRecord
.Modifier and TypeMethodDescriptiondefault <V> List<ObjectRecord<K,
V>> Map records fromMapRecord
toObjectRecord
s.default <V> reactor.core.publisher.Flux<ObjectRecord<K,
V>> Read all records from a stream within a specificRange
.default <V> reactor.core.publisher.Flux<ObjectRecord<K,
V>> default <V> List<ObjectRecord<K,
V>> Read all records from a stream within a specificRange
asObjectRecord
.default <V> List<ObjectRecord<K,
V>> default <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
.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
.default <V> reactor.core.publisher.Flux<ObjectRecord<K,
V>> ReactiveStreamOperations.reverseRange
(Class<V> targetType, K key, Range<String> range) Read records from a stream within a specificRange
in reverse order asObjectRecord
.default <V> reactor.core.publisher.Flux<ObjectRecord<K,
V>> Read records from a stream within a specificRange
applying aLimit
in reverse order asObjectRecord
.default <V> List<ObjectRecord<K,
V>> StreamOperations.reverseRange
(Class<V> targetType, K key, Range<String> range) Read records from a stream within a specificRange
in reverse order asObjectRecord
.default <V> List<ObjectRecord<K,
V>> Read records from a stream within a specificRange
applying aLimit
in reverse order asObjectRecord
. -
Uses of ObjectRecord in org.springframework.data.redis.stream
Modifier and TypeMethodDescriptionstatic <T> StreamReceiver.StreamReceiverOptionsBuilder<String,
ObjectRecord<String, T>> StreamReceiver.StreamReceiverOptions.builder
(HashMapper<T, byte[], byte[]> hashMapper) <NV> StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<K,
ObjectRecord<K, NV>> StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder.objectMapper
(HashMapper<NV, ?, ?> hashMapper) Configure a hash mapper.StreamReceiver.StreamReceiverOptionsBuilder.objectMapper
(HashMapper<NV, ?, ?> hashMapper) Configure a hash mapper.<NV> StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<K,
ObjectRecord<K, NV>> StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder.targetType
(Class<NV> targetType) Configure a hash target type.StreamReceiver.StreamReceiverOptionsBuilder.targetType
(Class<NV> targetType) Configure a hash target type.