Uses of Interface
org.springframework.data.redis.connection.stream.ByteBufferRecord
Package
Description
Connection package providing low-level abstractions for interacting with the various Redis 'drivers'/libraries.
Data structures and interfaces to interact with Redis Streams.
Core package for integrating Redis with Spring concepts.
-
Uses of ByteBufferRecord in org.springframework.data.redis.connection
Modifier and TypeMethodDescriptionreactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.ReadCommand,
reactor.core.publisher.Flux<ByteBufferRecord>>> ReactiveStreamCommands.read
(org.reactivestreams.Publisher<ReactiveStreamCommands.ReadCommand> commands) Read records from one or moreStreamOffset
s.default reactor.core.publisher.Flux<ByteBufferRecord>
ReactiveStreamCommands.xClaim
(ByteBuffer key, String group, String newOwner, Duration minIdleTime, RecordId... recordIds) Change the ownership of a pending message to the given new consumer.default reactor.core.publisher.Flux<ByteBufferRecord>
ReactiveStreamCommands.xClaim
(ByteBuffer key, String group, String newOwner, RedisStreamCommands.XClaimOptions options) Change the ownership of a pending message to the given new consumer.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XClaimCommand,
reactor.core.publisher.Flux<ByteBufferRecord>>> ReactiveStreamCommands.xClaim
(org.reactivestreams.Publisher<ReactiveStreamCommands.XClaimCommand> commands) Change the ownership of a pending message to the given new consumer.default reactor.core.publisher.Flux<ByteBufferRecord>
ReactiveStreamCommands.xRange
(ByteBuffer key, Range<String> range) Read records from a stream within a specificRange
.default reactor.core.publisher.Flux<ByteBufferRecord>
ReactiveStreamCommands.xRange
(ByteBuffer key, Range<String> range, Limit limit) reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.RangeCommand,
reactor.core.publisher.Flux<ByteBufferRecord>>> ReactiveStreamCommands.xRange
(org.reactivestreams.Publisher<ReactiveStreamCommands.RangeCommand> commands) default reactor.core.publisher.Flux<ByteBufferRecord>
ReactiveStreamCommands.xRead
(StreamOffset<ByteBuffer>... streams) Read records from one or moreStreamOffset
s.default reactor.core.publisher.Flux<ByteBufferRecord>
ReactiveStreamCommands.xRead
(StreamReadOptions readOptions, StreamOffset<ByteBuffer>... streams) Read records from one or moreStreamOffset
s.default reactor.core.publisher.Flux<ByteBufferRecord>
ReactiveStreamCommands.xReadGroup
(Consumer consumer, StreamOffset<ByteBuffer>... streams) Read records from one or moreStreamOffset
s using a consumer group.default reactor.core.publisher.Flux<ByteBufferRecord>
ReactiveStreamCommands.xReadGroup
(Consumer consumer, StreamReadOptions readOptions, StreamOffset<ByteBuffer>... streams) Read records from one or moreStreamOffset
s using a consumer group.default reactor.core.publisher.Flux<ByteBufferRecord>
ReactiveStreamCommands.xRevRange
(ByteBuffer key, Range<String> range) Read records from a stream within a specificRange
in reverse order.default reactor.core.publisher.Flux<ByteBufferRecord>
ReactiveStreamCommands.xRevRange
(ByteBuffer key, Range<String> range, Limit limit) reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.RangeCommand,
reactor.core.publisher.Flux<ByteBufferRecord>>> ReactiveStreamCommands.xRevRange
(org.reactivestreams.Publisher<ReactiveStreamCommands.RangeCommand> commands) Modifier and TypeMethodDescriptionReactiveStreamCommands.AddStreamRecord.of
(ByteBufferRecord record) Creates a newReactiveStreamCommands.AddStreamRecord
givenbody
.default reactor.core.publisher.Mono<RecordId>
ReactiveStreamCommands.xAdd
(ByteBufferRecord record) Add stream record with given body to key. -
Uses of ByteBufferRecord in org.springframework.data.redis.connection.stream
Modifier and TypeMethodDescriptionstatic ByteBufferRecord
ByteBufferRecord.of
(MapRecord<ByteBuffer, ByteBuffer, ByteBuffer> source) Convert a binaryMapRecord
into aByteRecord
.StreamRecords.RecordBuilder.ofBuffer
(Map<ByteBuffer, ByteBuffer> value) static ByteBufferRecord
StreamRecords.rawBuffer
(Map<ByteBuffer, ByteBuffer> raw) Create a newByteBufferRecord
for the given raw field/value pairs.ByteBufferRecord.withStreamKey
(ByteBuffer key) Create a newByteBufferRecord
with the associated stream key. -
Uses of ByteBufferRecord in org.springframework.data.redis.core
Modifier and TypeMethodDescriptionReactiveStreamOperations.deserializeRecord
(ByteBufferRecord record) Deserialize aByteBufferRecord
using the configured serialization context into aMapRecord
.