Uses of Interface
org.springframework.data.redis.connection.stream.Record

Packages that use Record

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

Uses of Record in org.springframework.data.redis.connection.stream

Subinterfaces of Record in org.springframework.data.redis.connection.stream

Modifier and Type	Interface	Description
interface	ByteBufferRecord	A Record within the stream backed by a collection of binary field/value pairs.
interface	ByteRecord	A Record within the stream backed by a collection of binary field/value pairs.
interface	MapRecord<S,K,V>	A Record within the stream backed by a collection of field/value pairs.
interface	ObjectRecord<S,V>	A Record within the stream mapped to a single object.
interface	StringRecord	A Record within the stream backed by a collection of String field/value pairs.

Methods in org.springframework.data.redis.connection.stream that return Record

Modifier and Type	Method	Description
Record<S,V>	Record.withId(RecordId id)	Create a new instance of Record with the given RecordId.
<SK> Record<SK,V>	Record.withStreamKey(SK key)	Create a new instance of Record with the given key to store the record at.

Methods in org.springframework.data.redis.connection.stream with parameters of type Record

Modifier and Type	Method	Description
static <K> StreamOffset<K>	StreamOffset.from(Record<K,?> reference)	Create a StreamOffset from the given record id as reference to create the ReadOffset.from(String).

Uses of Record in org.springframework.data.redis.core

Methods in org.springframework.data.redis.core with parameters of type Record

Modifier and Type	Method	Description
default reactor.core.publisher.Mono<Long>	ReactiveStreamOperations.acknowledge(String group, Record<K,?> record)	Acknowledge the given record as processed.
default Long	StreamOperations.acknowledge(String group, Record<K,?> record)	Acknowledge the given record as processed.
reactor.core.publisher.Mono<RecordId>	ReactiveStreamOperations.add(Record<K,?> record)	Append the record, backed by the given value, to the stream.
RecordId	StreamOperations.add(Record<K,?> record)	Append the record, backed by the given value, to the stream.
default reactor.core.publisher.Mono<Long>	ReactiveStreamOperations.delete(Record<K,?> record)	Removes a given Record from the stream.
default Long	StreamOperations.delete(Record<K,?> record)	Removes a given Record from the stream.

Uses of Record in org.springframework.data.redis.stream

Classes in org.springframework.data.redis.stream with type parameters of type Record

Modifier and Type	Interface	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,?>>	Builder for StreamMessageListenerContainer.StreamMessageListenerContainerOptions.
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.

Methods in org.springframework.data.redis.stream with type parameters of type Record

Modifier and Type	Method	Description
static <K, V extends Record<K, ?>> StreamMessageListenerContainer<K,V>	StreamMessageListenerContainer.create(RedisConnectionFactory connectionFactory, StreamMessageListenerContainer.StreamMessageListenerContainerOptions<K,V> options)	Create a new StreamMessageListenerContainer given RedisConnectionFactory and StreamMessageListenerContainer.StreamMessageListenerContainerOptions.
static <K, V extends Record<K, ?>> StreamReceiver<K,V>	StreamReceiver.create(ReactiveRedisConnectionFactory connectionFactory, StreamReceiver.StreamReceiverOptions<K,V> options)	Create a new StreamReceiver given ReactiveRedisConnectionFactory and StreamReceiver.StreamReceiverOptions.
<NK, NV extends Record<NK, ?>> StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<NK,NV>	StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder.keySerializer(RedisSerializer<NK> serializer)	Configure a key serializer.
<NK, NV extends Record<NK, ?>> StreamReceiver.StreamReceiverOptionsBuilder<NK,NV>	StreamReceiver.StreamReceiverOptionsBuilder.keySerializer(RedisSerializationContext.SerializationPair<NK> pair)	Configure a key serializer.