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 | 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 |
MapRecord<S,K,V>
A
Record within the stream backed by a collection of field/value paris. |
interface |
ObjectRecord<S,V>
A
Record within the stream mapped to a single object. |
interface |
StringRecord
|
Modifier and Type | Method and Description |
---|---|
Record<S,V> |
Record.withId(RecordId id)
|
<SK> Record<SK,V> |
Record.withStreamKey(SK key)
Create a new instance of
Record with the given key to store the record at. |
Modifier and Type | Method and Description |
---|---|
static <K> StreamOffset<K> |
StreamOffset.from(Record<K,?> reference)
|
Modifier and Type | Method and Description |
---|---|
default Long |
StreamOperations.acknowledge(String group,
Record<K,?> record)
Acknowledge the given record as processed.
|
default reactor.core.publisher.Mono<Long> |
ReactiveStreamOperations.acknowledge(String group,
Record<K,?> record)
Acknowledge the given record as processed.
|
RecordId |
StreamOperations.add(Record<K,?> record)
Append the record, backed by the given value, to the stream.
|
reactor.core.publisher.Mono<RecordId> |
ReactiveStreamOperations.add(Record<K,?> record)
Append the record, backed by the given value, to the stream.
|
default Long |
StreamOperations.delete(Record<K,?> record)
Removes a given
Record from the stream. |
default reactor.core.publisher.Mono<Long> |
ReactiveStreamOperations.delete(Record<K,?> record)
Removes a given
Record from the stream. |
Modifier and Type | Interface and Description |
---|---|
interface |
StreamListener<K,V extends Record<K,?>>
Listener interface to receive delivery of
messages . |
interface |
StreamMessageListenerContainer<K,V extends Record<K,?>>
Abstraction used by the framework representing a message listener container.
|
static class |
StreamMessageListenerContainer.StreamMessageListenerContainerOptions<K,V extends Record<K,?>>
Options for
StreamMessageListenerContainer . |
static class |
StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<K,V extends Record<K,?>>
|
interface |
StreamReceiver<K,V extends Record<K,?>>
A receiver to consume Redis Streams using reactive infrastructure.
|
static class |
StreamReceiver.StreamReceiverOptions<K,V extends Record<K,?>>
Options for
StreamReceiver . |
static class |
StreamReceiver.StreamReceiverOptionsBuilder<K,V extends Record<K,?>>
Builder for
StreamReceiver.StreamReceiverOptions . |
Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.