クラス ReactiveStreamCommands.AddStreamRecord
java.lang.ObjectSE
org.springframework.data.redis.connection.ReactiveRedisConnection.KeyCommand
org.springframework.data.redis.connection.ReactiveStreamCommands.AddStreamRecord
- 実装されたすべてのインターフェース:
ReactiveRedisConnection.Command
- 含まれているインターフェース:
- ReactiveStreamCommands
public static class ReactiveStreamCommands.AddStreamRecord
extends ReactiveRedisConnection.KeyCommand
XADD
コマンドパラメーター。- 関連事項:
メソッドのサマリー
修飾子と型メソッド説明approximateTrimming
(boolean approximateTrimming) ~
フラグを使用して、上限のあるストリームに効率的なトリミングを適用します。body
(MapSE<ByteBufferSE, ByteBufferSE> body) body
SE を指定して新しいReactiveStreamCommands.AddStreamRecord
を作成します。getBody()
ストリームのサイズを指定された最大要素数に制限します。getMinId()
boolean
boolean
hasMinId()
boolean
boolean
ストリームがまだ存在しない場合は、ストリームの作成を無効にします。makeNoStream
(boolean makeNoStream) ストリームがまだ存在しない場合は、ストリームの作成を無効にします。maxlen
(long maxlen) ストリームのサイズを指定された最大要素数に制限します。指定された ID よりも低い ID を持つエントリを削除するMINID
トリミング戦略を適用します。of
(ByteBufferRecord record) body
SE を指定して新しいReactiveStreamCommands.AddStreamRecord
を作成します。to
(ByteBufferSE key) Geo セットキーを適用します。クラス org.springframework.data.redis.connection.ReactiveRedisConnection.KeyCommand から継承されたメソッド
getKey
クラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSE
インターフェース org.springframework.data.redis.connection.ReactiveRedisConnection.Command から継承されたメソッド
getName
メソッドの詳細
of
body
SE を指定して新しいReactiveStreamCommands.AddStreamRecord
を作成します。- パラメーター:
record
- null であってはなりません。- 戻り値:
- 新しい
ReactiveStreamCommands.AddStreamRecord
。
body
body
SE を指定して新しいReactiveStreamCommands.AddStreamRecord
を作成します。- パラメーター:
body
- null であってはなりません。- 戻り値:
Map
SE 用の新しいReactiveStreamCommands.AddStreamRecord
。
to
Geo セットキーを適用します。以前に構成されたすべてのプロパティを使用して、新しいコマンドインスタンスを構築します。- パラメーター:
key
- null であってはなりません。- 戻り値:
- キーが適用された新しい
ReactiveGeoCommands.GeoAddCommand
。
makeNoStream
ストリームがまだ存在しない場合は、ストリームの作成を無効にします。- 戻り値:
ReactiveStreamCommands.AddStreamRecord
の新しいインスタンス。- 導入:
- 2.6
makeNoStream
ストリームがまだ存在しない場合は、ストリームの作成を無効にします。- パラメーター:
makeNoStream
-true
は、ストリームがまだ存在しない場合は作成しません。- 戻り値:
ReactiveStreamCommands.AddStreamRecord
の新しいインスタンス。- 導入:
- 2.6
maxlen
ストリームのサイズを指定された最大要素数に制限します。- 戻り値:
ReactiveStreamCommands.AddStreamRecord
の新しいインスタンス。
minId
指定された ID よりも低い ID を持つエントリを削除するMINID
トリミング戦略を適用します。- パラメーター:
minId
- 保持する最小レコード ID。- 戻り値:
ReactiveStreamCommands.AddStreamRecord
の新しいインスタンス。- 導入:
- 2.7
approximateTrimming
~
フラグを使用して、上限のあるストリームに効率的なトリミングを適用します。- 戻り値:
ReactiveStreamCommands.AddStreamRecord
の新しいインスタンス。
getBody
- 戻り値:
- 実際の
Record.getValue()
getRecord
isNoMkStream
public boolean isNoMkStream()- 戻り値:
- NOMKSTREAM が設定されている場合は true。
- 導入:
- 2.6
getMaxlen
ストリームのサイズを指定された最大要素数に制限します。- 戻り値:
- null でもかまいません。
- 導入:
- 2.3
hasMaxlen
public boolean hasMaxlen()- 戻り値:
- MAXLEN が設定されている場合は true。
- 導入:
- 2.3
isApproximateTrimming
public boolean isApproximateTrimming()- 戻り値:
- approximationTrimming が設定されている場合は true。
- 導入:
- 2.7
getMinId
- 戻り値:
- トリミング中に保持する最小レコード ID。
- 導入:
- 2.7
hasMinId
public boolean hasMinId()- 戻り値:
- MINID が設定されている場合は true。
- 導入:
- 2.7