Uses of Interface
org.springframework.data.redis.connection.stream.ByteBufferRecord
Packages that use 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
Methods in org.springframework.data.redis.connection that return ByteBufferRecordMethods in org.springframework.data.redis.connection that return types with arguments of type ByteBufferRecordModifier 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) Methods in org.springframework.data.redis.connection with parameters of type ByteBufferRecordModifier 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
Methods in org.springframework.data.redis.connection.stream that return ByteBufferRecordModifier 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
Methods in org.springframework.data.redis.core with parameters of type ByteBufferRecordModifier and TypeMethodDescriptionReactiveStreamOperations.deserializeRecord
(ByteBufferRecord record) Deserialize aByteBufferRecord
using the configured serialization context into aMapRecord
.