public static class ReactiveStreamCommands.AddStreamRecord extends ReactiveRedisConnection.KeyCommand
XADD
command parameters.Modifier and Type | Method and Description |
---|---|
ReactiveStreamCommands.AddStreamRecord |
approximateTrimming(boolean approximateTrimming)
Apply efficient trimming for capped streams using the
~ flag. |
static ReactiveStreamCommands.AddStreamRecord |
body(Map<ByteBuffer,ByteBuffer> body)
Creates a new
ReactiveStreamCommands.AddStreamRecord given body . |
Map<ByteBuffer,ByteBuffer> |
getBody() |
Long |
getMaxlen()
Limit the size of the stream to the given maximum number of elements.
|
RecordId |
getMinId() |
ByteBufferRecord |
getRecord() |
boolean |
hasMaxlen() |
boolean |
hasMinId() |
boolean |
isApproximateTrimming() |
boolean |
isNoMkStream() |
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.
|
ReactiveStreamCommands.AddStreamRecord |
minId(RecordId minId)
Apply
MINID trimming strategy, that evicts entries with IDs lower than the one specified. |
static ReactiveStreamCommands.AddStreamRecord |
of(ByteBufferRecord record)
Creates a new
ReactiveStreamCommands.AddStreamRecord given body . |
ReactiveStreamCommands.AddStreamRecord |
to(ByteBuffer key)
Applies the Geo set key.
|
getKey
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getName
public static ReactiveStreamCommands.AddStreamRecord of(ByteBufferRecord record)
ReactiveStreamCommands.AddStreamRecord
given body
.record
- must not be null.ReactiveStreamCommands.AddStreamRecord
.public static ReactiveStreamCommands.AddStreamRecord body(Map<ByteBuffer,ByteBuffer> body)
ReactiveStreamCommands.AddStreamRecord
given body
.body
- must not be null.ReactiveStreamCommands.AddStreamRecord
for Map
.public ReactiveStreamCommands.AddStreamRecord to(ByteBuffer key)
key
- must not be null.ReactiveGeoCommands.GeoAddCommand
with key applied.public ReactiveStreamCommands.AddStreamRecord makeNoStream()
ReactiveStreamCommands.AddStreamRecord
.public ReactiveStreamCommands.AddStreamRecord makeNoStream(boolean makeNoStream)
makeNoStream
- true
to not create a stream if it does not already exist.ReactiveStreamCommands.AddStreamRecord
.public ReactiveStreamCommands.AddStreamRecord maxlen(long maxlen)
ReactiveStreamCommands.AddStreamRecord
.public ReactiveStreamCommands.AddStreamRecord minId(RecordId minId)
MINID
trimming strategy, that evicts entries with IDs lower than the one specified.minId
- the minimum record Id to retain.ReactiveStreamCommands.AddStreamRecord
.public ReactiveStreamCommands.AddStreamRecord approximateTrimming(boolean approximateTrimming)
~
flag.ReactiveStreamCommands.AddStreamRecord
.public Map<ByteBuffer,ByteBuffer> getBody()
Record.getValue()
public ByteBufferRecord getRecord()
public boolean isNoMkStream()
@Nullable public Long getMaxlen()
public boolean hasMaxlen()
public boolean isApproximateTrimming()
@Nullable public RecordId getMinId()
public boolean hasMinId()
Copyright © 2011–2023 Pivotal Software, Inc.. All rights reserved.