Package | Description |
---|---|
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 |
Modifier and Type | Method and Description |
---|---|
static <S,V> ObjectRecord<S,V> |
ObjectRecord.create(S stream,
V value)
|
static <S,V> ObjectRecord<S,V> |
StreamRecords.objectBacked(V value)
Create new
ObjectRecord backed by the given value. |
static <S,V> ObjectRecord<S,V> |
Record.of(V value)
Create a new
ObjectRecord instance backed by the given value. |
<V> ObjectRecord<S,V> |
StreamRecords.RecordBuilder.ofObject(V value)
Create an
ObjectRecord . |
default <OV> ObjectRecord<ByteBuffer,OV> |
ByteBufferRecord.toObjectRecord(HashMapper<? super OV,? super ByteBuffer,? super ByteBuffer> mapper)
Convert a binary
MapRecord into an ObjectRecord . |
default <OV> ObjectRecord<S,OV> |
MapRecord.toObjectRecord(HashMapper<? super OV,? super K,? super V> mapper)
Apply the given
HashMapper to the backing value to create a new MapRecord . |
ObjectRecord<S,V> |
ObjectRecord.withId(RecordId id) |
<SK> ObjectRecord<SK,V> |
ObjectRecord.withStreamKey(SK key) |
Modifier and Type | Method and Description |
---|---|
default <V> reactor.core.publisher.Flux<ObjectRecord<K,V>> |
ReactiveStreamOperations.range(Class<V> targetType,
K key,
Range<String> range)
Read all records from a stream within a specific
Range . |
default <V> List<ObjectRecord<K,V>> |
StreamOperations.range(Class<V> targetType,
K key,
Range<String> range)
Read all records from a stream within a specific
Range as ObjectRecord . |
default <V> reactor.core.publisher.Flux<ObjectRecord<K,V>> |
ReactiveStreamOperations.range(Class<V> targetType,
K key,
Range<String> range,
RedisZSetCommands.Limit limit)
Read records from a stream within a specific
Range applying a RedisZSetCommands.Limit . |
default <V> List<ObjectRecord<K,V>> |
StreamOperations.range(Class<V> targetType,
K key,
Range<String> range,
RedisZSetCommands.Limit limit)
Read records from a stream within a specific
Range applying a RedisZSetCommands.Limit as ObjectRecord . |
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
StreamOffset s using a consumer group as ObjectRecord . |
default <V> List<ObjectRecord<K,V>> |
StreamOperations.read(Class<V> targetType,
Consumer consumer,
StreamOffset<K>... streams)
Read records from one or more
StreamOffset s 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
StreamOffset s 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
StreamOffset s using a consumer group 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
StreamOffset s as ObjectRecord . |
default <V> List<ObjectRecord<K,V>> |
StreamOperations.read(Class<V> targetType,
StreamOffset<K>... streams)
Read records from one or more
StreamOffset s 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,
StreamReadOptions readOptions,
StreamOffset<K>... streams)
Read records from one or more
StreamOffset s as ObjectRecord . |
default <V> List<ObjectRecord<K,V>> |
StreamOperations.read(Class<V> targetType,
StreamReadOptions readOptions,
StreamOffset<K>... streams)
Read records from one or more
StreamOffset s as ObjectRecord . |
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 specific
Range in reverse order as ObjectRecord . |
default <V> List<ObjectRecord<K,V>> |
StreamOperations.reverseRange(Class<V> targetType,
K key,
Range<String> range)
Read records from a stream within a specific
Range in reverse order as ObjectRecord . |
default <V> reactor.core.publisher.Flux<ObjectRecord<K,V>> |
ReactiveStreamOperations.reverseRange(Class<V> targetType,
K key,
Range<String> range,
RedisZSetCommands.Limit limit)
Read records from a stream within a specific
Range applying a RedisZSetCommands.Limit in reverse order as
ObjectRecord . |
default <V> List<ObjectRecord<K,V>> |
StreamOperations.reverseRange(Class<V> targetType,
K key,
Range<String> range,
RedisZSetCommands.Limit limit)
Read records from a stream within a specific
Range applying a RedisZSetCommands.Limit in reverse order as
ObjectRecord . |
Modifier and Type | Method and Description |
---|---|
static <T> StreamReceiver.StreamReceiverOptionsBuilder<String,ObjectRecord<String,T>> |
StreamReceiver.StreamReceiverOptions.builder(HashMapper<T,byte[],byte[]> hashMapper) |
<NV> StreamReceiver.StreamReceiverOptionsBuilder<K,ObjectRecord<K,NV>> |
StreamReceiver.StreamReceiverOptionsBuilder.objectMapper(HashMapper<NV,?,?> hashMapper)
Configure a hash mapper.
|
<NV> StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<K,ObjectRecord<K,NV>> |
StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder.objectMapper(HashMapper<NV,?,?> hashMapper)
Configure a hash mapper.
|
<NV> StreamReceiver.StreamReceiverOptionsBuilder<K,ObjectRecord<K,NV>> |
StreamReceiver.StreamReceiverOptionsBuilder.targetType(Class<NV> targetType)
Configure a hash target type.
|
<NV> StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<K,ObjectRecord<K,NV>> |
StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder.targetType(Class<NV> targetType)
Configure a hash target type.
|
Copyright © 2011–2019 Pivotal Software, Inc.. All rights reserved.