Uses of Class
org.springframework.data.redis.connection.ReactiveStreamCommands.AddStreamRecord
Package
Description
Connection package providing low-level abstractions for interacting with the various Redis 'drivers'/libraries.
-
Uses of ReactiveStreamCommands.AddStreamRecord in org.springframework.data.redis.connection
Modifier and TypeMethodDescriptionReactiveStreamCommands.AddStreamRecord.approximateTrimming
(boolean approximateTrimming) Apply efficient trimming for capped streams using the~
flag.ReactiveStreamCommands.AddStreamRecord.body
(Map<ByteBuffer, ByteBuffer> body) Creates a newReactiveStreamCommands.AddStreamRecord
givenbody
.ReactiveStreamCommands.AddStreamRecord.makeNoStream()
Disable creation of stream if it does not already exist.ReactiveStreamCommands.AddStreamRecord.makeNoStream
(boolean makeNoStream) Disable creation of stream if it does not already exist.ReactiveStreamCommands.AddStreamRecord.maxlen
(long maxlen) Limit the size of the stream to the given maximum number of elements.ApplyMINID
trimming strategy, that evicts entries with IDs lower than the one specified.ReactiveStreamCommands.AddStreamRecord.of
(ByteBufferRecord record) Creates a newReactiveStreamCommands.AddStreamRecord
givenbody
.ReactiveStreamCommands.AddStreamRecord.to
(ByteBuffer key) Applies the Geo set key.Modifier and TypeMethodDescriptionreactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.AddStreamRecord,
RecordId>> ReactiveStreamCommands.xAdd
(org.reactivestreams.Publisher<ReactiveStreamCommands.AddStreamRecord> commands) Add stream record with given body to key.Modifier and TypeMethodDescriptionreactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.AddStreamRecord,
RecordId>> ReactiveStreamCommands.xAdd
(org.reactivestreams.Publisher<ReactiveStreamCommands.AddStreamRecord> commands) Add stream record with given body to key.