Class ReactiveStreamCommands.AddStreamRecord
java.lang.Object
org.springframework.data.redis.connection.ReactiveRedisConnection.KeyCommand
org.springframework.data.redis.connection.ReactiveStreamCommands.AddStreamRecord
- All Implemented Interfaces:
ReactiveRedisConnection.Command
- Enclosing interface:
- ReactiveStreamCommands
public static class ReactiveStreamCommands.AddStreamRecord
extends ReactiveRedisConnection.KeyCommand
XADD
command parameters.- See Also:
-
Method Summary
Modifier and TypeMethodDescriptionapproximateTrimming
(boolean approximateTrimming) Apply efficient trimming for capped streams using the~
flag.body
(Map<ByteBuffer, ByteBuffer> body) Creates a newReactiveStreamCommands.AddStreamRecord
givenbody
.getBody()
Limit the size of the stream to the given maximum number of elements.getMinId()
boolean
boolean
hasMinId()
boolean
boolean
Disable creation of stream if it does not already exist.makeNoStream
(boolean makeNoStream) Disable creation of stream if it does not already exist.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.of
(ByteBufferRecord record) Creates a newReactiveStreamCommands.AddStreamRecord
givenbody
.to
(ByteBuffer key) Applies the Geo set key.Methods inherited from class org.springframework.data.redis.connection.ReactiveRedisConnection.KeyCommand
getKey
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.springframework.data.redis.connection.ReactiveRedisConnection.Command
getName
-
Method Details
-
of
Creates a newReactiveStreamCommands.AddStreamRecord
givenbody
.- Parameters:
record
- must not be null.- Returns:
- a new
ReactiveStreamCommands.AddStreamRecord
.
-
body
Creates a newReactiveStreamCommands.AddStreamRecord
givenbody
.- Parameters:
body
- must not be null.- Returns:
- a new
ReactiveStreamCommands.AddStreamRecord
forMap
.
-
to
Applies the Geo set key. Constructs a new command instance with all previously configured properties.- Parameters:
key
- must not be null.- Returns:
- a new
ReactiveGeoCommands.GeoAddCommand
with key applied.
-
makeNoStream
Disable creation of stream if it does not already exist.- Returns:
- new instance of
ReactiveStreamCommands.AddStreamRecord
. - Since:
- 2.6
-
makeNoStream
Disable creation of stream if it does not already exist.- Parameters:
makeNoStream
-true
to not create a stream if it does not already exist.- Returns:
- new instance of
ReactiveStreamCommands.AddStreamRecord
. - Since:
- 2.6
-
maxlen
Limit the size of the stream to the given maximum number of elements.- Returns:
- new instance of
ReactiveStreamCommands.AddStreamRecord
.
-
minId
ApplyMINID
trimming strategy, that evicts entries with IDs lower than the one specified.- Parameters:
minId
- the minimum record Id to retain.- Returns:
- new instance of
ReactiveStreamCommands.AddStreamRecord
. - Since:
- 2.7
-
approximateTrimming
Apply efficient trimming for capped streams using the~
flag.- Returns:
- new instance of
ReactiveStreamCommands.AddStreamRecord
.
-
getBody
- Returns:
- the actual
Record.getValue()
-
getRecord
-
isNoMkStream
public boolean isNoMkStream()- Returns:
- true if NOMKSTREAM is set.
- Since:
- 2.6
-
getMaxlen
Limit the size of the stream to the given maximum number of elements.- Returns:
- can be null.
- Since:
- 2.3
-
hasMaxlen
public boolean hasMaxlen()- Returns:
- true if MAXLEN is set.
- Since:
- 2.3
-
isApproximateTrimming
public boolean isApproximateTrimming()- Returns:
- true if approximateTrimming is set.
- Since:
- 2.7
-
getMinId
- Returns:
- the minimum record Id to retain during trimming.
- Since:
- 2.7
-
hasMinId
public boolean hasMinId()- Returns:
- true if MINID is set.
- Since:
- 2.7
-