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 |
Modifier and Type | Method and Description |
---|---|
default RecordId |
RedisStreamCommands.xAdd(MapRecord<byte[],byte[],byte[]> record)
Append the given
record to the stream stored at Record.getStream() . |
RecordId |
DefaultStringRedisConnection.xAdd(MapRecord<byte[],byte[],byte[]> record,
RedisStreamCommands.XAddOptions options) |
default RecordId |
DefaultedRedisConnection.xAdd(MapRecord<byte[],byte[],byte[]> record,
RedisStreamCommands.XAddOptions options)
Deprecated.
in favor of
RedisConnection.streamCommands() }. |
RecordId |
RedisStreamCommands.xAdd(MapRecord<byte[],byte[],byte[]> record,
RedisStreamCommands.XAddOptions options)
Append the given
record to the stream stored at Record.getStream() . |
Modifier and Type | Interface and Description |
---|---|
interface |
ByteBufferRecord
A
Record within the stream backed by a collection of binary field/value paris. |
interface |
ByteRecord
A
Record within the stream backed by a collection of binary field/value paris. |
interface |
StringRecord
|
Modifier and Type | Method and Description |
---|---|
static <S,K,V> MapRecord<S,K,V> |
MapRecord.create(S stream,
Map<K,V> map)
|
default <K,HK,HV> MapRecord<K,HK,HV> |
ByteRecord.deserialize(RedisSerializer<? extends K> streamSerializer,
RedisSerializer<? extends HK> fieldSerializer,
RedisSerializer<? extends HV> valueSerializer)
Deserialize
key with the streamSerializer, field names with the
fieldSerializer and values with the valueSerializer. |
default <K,HK,HV> MapRecord<K,HK,HV> |
ByteBufferRecord.deserialize(RedisSerializer<? extends K> streamSerializer,
RedisSerializer<? extends HK> fieldSerializer,
RedisSerializer<? extends HV> valueSerializer)
Deserialize
key with the streamSerializer, field names with the
fieldSerializer and values with the valueSerializer. |
default <T> MapRecord<T,T,T> |
ByteRecord.deserialize(RedisSerializer<T> serializer)
|
default <T> MapRecord<T,T,T> |
ByteBufferRecord.deserialize(RedisSerializer<T> serializer)
|
default <SK,HK,HV> MapRecord<SK,HK,HV> |
MapRecord.map(Function<MapRecord<S,K,V>,MapRecord<SK,HK,HV>> mapFunction)
|
static <S,K,V> MapRecord<S,K,V> |
StreamRecords.mapBacked(Map<K,V> map)
|
default <HK,HV> MapRecord<S,HK,HV> |
MapRecord.mapEntries(Function<Map.Entry<K,V>,Map.Entry<HK,HV>> mapFunction)
Apply the given
mapFunction to each and every entry in the backing collection to create a new
MapRecord . |
static <S,K,V> MapRecord<S,K,V> |
Record.of(Map<K,V> map)
|
<K,V> MapRecord<S,K,V> |
StreamRecords.RecordBuilder.ofMap(Map<K,V> map)
Create a
MapRecord . |
default <HK,HV> MapRecord<S,HK,HV> |
ObjectRecord.toMapRecord(HashMapper<? super V,HK,HV> mapper)
Apply the given
HashMapper to the backing value to create a new MapRecord . |
MapRecord<S,K,V> |
MapRecord.withId(RecordId id) |
<SK> MapRecord<SK,K,V> |
MapRecord.withStreamKey(SK key) |
Modifier and Type | Method and Description |
---|---|
static ByteRecord |
ByteRecord.of(MapRecord<byte[],byte[],byte[]> source)
Convert a binary
MapRecord into a ByteRecord . |
static ByteBufferRecord |
ByteBufferRecord.of(MapRecord<ByteBuffer,ByteBuffer,ByteBuffer> source)
Convert a binary
MapRecord into a ByteRecord . |
static StringRecord |
StringRecord.of(MapRecord<String,String,String> source)
|
Modifier and Type | Method and Description |
---|---|
default <SK,HK,HV> MapRecord<SK,HK,HV> |
MapRecord.map(Function<MapRecord<S,K,V>,MapRecord<SK,HK,HV>> mapFunction)
|
default <SK,HK,HV> MapRecord<SK,HK,HV> |
MapRecord.map(Function<MapRecord<S,K,V>,MapRecord<SK,HK,HV>> mapFunction)
|
Modifier and Type | Method and Description |
---|---|
MapRecord<K,HK,HV> |
ReactiveStreamOperations.deserializeRecord(ByteBufferRecord record)
Deserialize a
ByteBufferRecord using the configured serialization context into a MapRecord . |
MapRecord<K,HK,HV> |
StreamOperations.deserializeRecord(ByteRecord record)
Deserialize a
ByteRecord using the configured serializers into a MapRecord . |
Modifier and Type | Method and Description |
---|---|
default List<MapRecord<K,HK,HV>> |
StreamOperations.range(K key,
Range<String> range)
Read records from a stream within a specific
Range . |
default reactor.core.publisher.Flux<MapRecord<K,HK,HV>> |
ReactiveStreamOperations.range(K key,
Range<String> range)
Read records from a stream within a specific
Range . |
List<MapRecord<K,HK,HV>> |
StreamOperations.range(K key,
Range<String> range,
RedisZSetCommands.Limit limit)
Read records from a stream within a specific
Range applying a RedisZSetCommands.Limit . |
reactor.core.publisher.Flux<MapRecord<K,HK,HV>> |
ReactiveStreamOperations.range(K key,
Range<String> range,
RedisZSetCommands.Limit limit)
Read records from a stream within a specific
Range applying a RedisZSetCommands.Limit . |
default List<MapRecord<K,HK,HV>> |
BoundStreamOperations.range(Range<String> range)
Read records from a stream within a specific
Range . |
List<MapRecord<K,HK,HV>> |
BoundStreamOperations.range(Range<String> range,
RedisZSetCommands.Limit limit)
Read records from a stream within a specific
Range applying a RedisZSetCommands.Limit . |
default List<MapRecord<K,HK,HV>> |
BoundStreamOperations.read(Consumer consumer,
ReadOffset readOffset)
Read records starting from
ReadOffset . using a consumer group. |
default List<MapRecord<K,HK,HV>> |
StreamOperations.read(Consumer consumer,
StreamOffset<K>... streams)
Read records from one or more
StreamOffset s using a consumer group. |
default reactor.core.publisher.Flux<MapRecord<K,HK,HV>> |
ReactiveStreamOperations.read(Consumer consumer,
StreamOffset<K>... streams)
Read records from one or more
StreamOffset s using a consumer group. |
List<MapRecord<K,HK,HV>> |
BoundStreamOperations.read(Consumer consumer,
StreamReadOptions readOptions,
ReadOffset readOffset)
Read records starting from
ReadOffset . using a consumer group. |
List<MapRecord<K,HK,HV>> |
StreamOperations.read(Consumer consumer,
StreamReadOptions readOptions,
StreamOffset<K>... streams)
Read records from one or more
StreamOffset s 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
StreamOffset s using a consumer group. |
default List<MapRecord<K,HK,HV>> |
BoundStreamOperations.read(ReadOffset readOffset)
Read records from
ReadOffset . |
default List<MapRecord<K,HK,HV>> |
StreamOperations.read(StreamOffset<K>... streams)
Read records from one or more
StreamOffset s. |
default reactor.core.publisher.Flux<MapRecord<K,HK,HV>> |
ReactiveStreamOperations.read(StreamOffset<K>... streams)
Read records from one or more
StreamOffset s. |
default reactor.core.publisher.Flux<MapRecord<K,HK,HV>> |
ReactiveStreamOperations.read(StreamOffset<K> stream)
Read records from a
StreamOffset as ObjectRecord . |
List<MapRecord<K,HK,HV>> |
BoundStreamOperations.read(StreamReadOptions readOptions,
ReadOffset readOffset)
Read records starting from
ReadOffset . |
List<MapRecord<K,HK,HV>> |
StreamOperations.read(StreamReadOptions readOptions,
StreamOffset<K>... streams)
Read records from one or more
StreamOffset s. |
reactor.core.publisher.Flux<MapRecord<K,HK,HV>> |
ReactiveStreamOperations.read(StreamReadOptions readOptions,
StreamOffset<K>... streams)
Read records from one or more
StreamOffset s. |
default List<MapRecord<K,HK,HV>> |
StreamOperations.reverseRange(K key,
Range<String> range)
Read records from a stream within a specific
Range in reverse order. |
default reactor.core.publisher.Flux<MapRecord<K,HK,HV>> |
ReactiveStreamOperations.reverseRange(K key,
Range<String> range)
Read records from a stream within a specific
Range in reverse order. |
List<MapRecord<K,HK,HV>> |
StreamOperations.reverseRange(K key,
Range<String> range,
RedisZSetCommands.Limit limit)
Read records from a stream within a specific
Range applying a RedisZSetCommands.Limit in reverse order. |
reactor.core.publisher.Flux<MapRecord<K,HK,HV>> |
ReactiveStreamOperations.reverseRange(K key,
Range<String> range,
RedisZSetCommands.Limit limit)
Read records from a stream within a specific
Range applying a RedisZSetCommands.Limit in reverse order. |
default List<MapRecord<K,HK,HV>> |
BoundStreamOperations.reverseRange(Range<String> range)
Read records from a stream within a specific
Range in reverse order. |
List<MapRecord<K,HK,HV>> |
BoundStreamOperations.reverseRange(Range<String> range,
RedisZSetCommands.Limit limit)
Read records from a stream within a specific
Range applying a RedisZSetCommands.Limit in reverse order. |
Modifier and Type | Method and Description |
---|---|
default RecordId |
StreamOperations.add(MapRecord<K,? extends HK,? extends HV> record)
Append a record, backed by a
Map holding the field/value pairs, to the stream. |
default reactor.core.publisher.Mono<RecordId> |
ReactiveStreamOperations.add(MapRecord<K,? extends HK,? extends HV> record)
Append a record, backed by a
Map holding the field/value pairs, to the stream. |
default <V> ObjectRecord<K,V> |
StreamOperations.map(MapRecord<K,HK,HV> record,
Class<V> targetType)
Map record from
MapRecord to ObjectRecord . |
default <V> ObjectRecord<K,V> |
ReactiveStreamOperations.map(MapRecord<K,HK,HV> record,
Class<V> targetType)
Map records from
MapRecord to ObjectRecord . |
Modifier and Type | Method and Description |
---|---|
default <V> List<ObjectRecord<K,V>> |
StreamOperations.map(List<MapRecord<K,HK,HV>> records,
Class<V> targetType)
Map records from
MapRecord to ObjectRecord s. |
Modifier and Type | Method and Description |
---|---|
static StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<String,MapRecord<String,String,String>> |
StreamMessageListenerContainer.StreamMessageListenerContainerOptions.builder() |
static StreamReceiver.StreamReceiverOptionsBuilder<String,MapRecord<String,String,String>> |
StreamReceiver.StreamReceiverOptions.builder() |
static StreamReceiver<String,MapRecord<String,String,String>> |
StreamReceiver.create(ReactiveRedisConnectionFactory connectionFactory)
|
static StreamMessageListenerContainer<String,MapRecord<String,String,String>> |
StreamMessageListenerContainer.create(RedisConnectionFactory connectionFactory)
|
<HK,HV> StreamReceiver.StreamReceiverOptionsBuilder<K,MapRecord<K,HK,HV>> |
StreamReceiver.StreamReceiverOptionsBuilder.hashKeySerializer(RedisSerializationContext.SerializationPair<HK> pair)
Configure a hash key serializer.
|
<HK,HV> StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<K,MapRecord<K,HK,HV>> |
StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder.hashKeySerializer(RedisSerializer<HK> serializer)
Configure a hash key serializer.
|
<HK,HV> StreamReceiver.StreamReceiverOptionsBuilder<K,MapRecord<K,HK,HV>> |
StreamReceiver.StreamReceiverOptionsBuilder.hashValueSerializer(RedisSerializationContext.SerializationPair<HV> pair)
Configure a hash value serializer.
|
<HK,HV> StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<K,MapRecord<K,HK,HV>> |
StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder.hashValueSerializer(RedisSerializer<HV> serializer)
Configure a hash value serializer.
|
<T> StreamReceiver.StreamReceiverOptionsBuilder<T,MapRecord<T,T,T>> |
StreamReceiver.StreamReceiverOptionsBuilder.serializer(RedisSerializationContext.SerializationPair<T> pair)
Configure a key, hash key and hash value serializer.
|
<T> StreamReceiver.StreamReceiverOptionsBuilder<T,MapRecord<T,T,T>> |
StreamReceiver.StreamReceiverOptionsBuilder.serializer(RedisSerializationContext<T,?> serializationContext)
Configure a key, hash key and hash value serializer.
|
<T> StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<T,MapRecord<T,T,T>> |
StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder.serializer(RedisSerializer<T> serializer)
Configure a key, hash key and hash value serializer.
|
Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.