インターフェース ReactiveStreamCommands

メソッドの詳細

• xAck

  default reactor.core.publisher.Mono<LongSE> xAck(ByteBufferSE key, StringSE group, StringSE... recordIds)

  1 つ以上のレコードを処理済みとして確認します。

  パラメーター:

  key - ストリームキー。

  group - コンシューマーグループの名前。

  recordIds - 確認する ID を記録します。

  戻り値:

  確認済みメッセージの nr を発行する Mono。

  関連事項:

  • Redis ドキュメント: XADD

• xAck

  default reactor.core.publisher.Mono<LongSE> xAck(ByteBufferSE key, StringSE group, RecordId... recordIds)

  1 つ以上のレコードを処理済みとして確認します。

  パラメーター:

  key - ストリームキー。

  group - コンシューマーグループの名前。

  recordIds - 確認する ID を記録します。

  戻り値:

  確認済みメッセージの nr を発行する Mono。

  関連事項:

  • Redis ドキュメント: XADD

• xAck

  reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveStreamCommands.AcknowledgeCommand,LongSE>> xAck(org.reactivestreams.Publisher<ReactiveStreamCommands.AcknowledgeCommand> commands)

  1 つ以上のレコードを処理済みとして確認します。

  パラメーター:

  commands - null であってはなりません。

  戻り値:

  ReactiveStreamCommands.AcknowledgeCommand ごとに確認済みメッセージの nr を発行する Flux。

  関連事項:

  • Redis ドキュメント: XACK

• xAdd

  default reactor.core.publisher.Mono<RecordId> xAdd(ByteBufferSE key, MapSE<ByteBufferSE,ByteBufferSE> body)

  指定された本文のストリームレコードをキーに追加します。

  パラメーター:

  key - null であってはなりません。

  body - null であってはなりません。

  戻り値:

  サーバーで生成された id を発行する Mono。

  関連事項:

  • Redis ドキュメント: XADD

• xAdd

  default reactor.core.publisher.Mono<RecordId> xAdd(ByteBufferRecord record)

  指定された本文のストリームレコードをキーに追加します。

  パラメーター:

  record - null であってはなりません。

  戻り値:

  Mono id。

  関連事項:

  • Redis ドキュメント: XADD

• xAdd

  reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.AddStreamRecord,RecordId>> xAdd(org.reactivestreams.Publisher<ReactiveStreamCommands.AddStreamRecord> commands)

  指定された本文のストリームレコードをキーに追加します。

  パラメーター:

  commands - null であってはなりません。

  戻り値:

  Flux は、指定された ReactiveStreamCommands.AddStreamRecord コマンドに対して for によって RecordId を発行します。

  関連事項:

  • Redis ドキュメント: XADD

• xClaimJustId

  default reactor.core.publisher.Flux<RecordId> xClaimJustId(ByteBufferSE key, StringSE group, StringSE newOwner, RedisStreamCommands.XClaimOptions options)

  配信数を増やすことなく、指定された新しいコンシューマーへの保留中のメッセージの所有権を変更します。

  パラメーター:

  key - ストリームが保存されているキー。

  group - コンシューマーグループの名前。

  newOwner - 新しいコンシューマーの名前。

  options - null であってはなりません。

  戻り値:

  ユーザーを変更した is を発行する Flux。

  導入:

  2.3

  関連事項:

  • Redis ドキュメント: XCLAIM

• xClaimJustId

  reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XClaimCommand,reactor.core.publisher.Flux<RecordId>>> xClaimJustId(org.reactivestreams.Publisher<ReactiveStreamCommands.XClaimCommand> commands)

  配信数を増やすことなく、指定された新しいコンシューマーへの保留中のメッセージの所有権を変更します。

  パラメーター:

  commands - null であってはなりません。

  戻り値:

  ユーザーを変更した is を発行する Flux。

  導入:

  2.3

  関連事項:

  • Redis ドキュメント: XCLAIM

• xClaim

  default reactor.core.publisher.Flux<ByteBufferRecord> xClaim(ByteBufferSE key, StringSE group, StringSE newOwner, DurationSE minIdleTime, RecordId... recordIds)

  指定された新しいコンシューマーへの保留中のメッセージの所有権を変更します。

  パラメーター:

  key - ストリームが保存されているキー。

  group - コンシューマーグループの名前。

  newOwner - 新しいコンシューマーの名前。

  minIdleTime - null であってはなりません。

  recordIds - null であってはなりません。

  戻り値:

  ユーザーを変更した ByteBufferRecord を発行する Flux。

  導入:

  2.3

  関連事項:

  • Redis ドキュメント: XCLAIM

• xClaim

  default reactor.core.publisher.Flux<ByteBufferRecord> xClaim(ByteBufferSE key, StringSE group, StringSE newOwner, RedisStreamCommands.XClaimOptions options)

  指定された新しいコンシューマーへの保留中のメッセージの所有権を変更します。

  パラメーター:

  key - ストリームが保存されているキー。

  group - コンシューマーグループの名前。

  newOwner - 新しいコンシューマーの名前。

  options - null であってはなりません。

  戻り値:

  ユーザーを変更した ByteBufferRecord を発行する Flux。

  導入:

  2.3

  関連事項:

  • Redis ドキュメント: XCLAIM

• xClaim

  reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XClaimCommand,reactor.core.publisher.Flux<ByteBufferRecord>>> xClaim(org.reactivestreams.Publisher<ReactiveStreamCommands.XClaimCommand> commands)

  指定された新しいコンシューマーへの保留中のメッセージの所有権を変更します。

  パラメーター:

  commands - null であってはなりません。

  戻り値:

  導入:

  2.3

  関連事項:

  • Redis ドキュメント: XCLAIM

• xDel

  default reactor.core.publisher.Mono<LongSE> xDel(ByteBufferSE key, StringSE... recordIds)

  指定されたエントリをストリームから削除します。削除されたアイテムの数を返します。特定の ID が存在しない場合に渡される ID の数とは異なる場合があります。

  パラメーター:

  key - ストリームキー。

  recordIds - ストリームレコード ID。

  戻り値:

  削除されたエントリの数を出力する Mono。

  関連事項:

  • Redis ドキュメント: XDEL

• xDel

  default reactor.core.publisher.Mono<LongSE> xDel(ByteBufferSE key, RecordId... recordIds)

  指定されたエントリをストリームから削除します。削除されたアイテムの数を返します。特定の ID が存在しない場合に渡される ID の数とは異なる場合があります。

  パラメーター:

  key - ストリームキー。

  recordIds - ストリームレコード ID。

  戻り値:

  削除されたエントリの数を出力する Mono。

  関連事項:

  • Redis ドキュメント: XDEL

• xDel

  reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.DeleteCommand,LongSE>> xDel(org.reactivestreams.Publisher<ReactiveStreamCommands.DeleteCommand> commands)

  指定されたエントリをストリームから削除します。削除されたアイテムの数を返します。特定の ID が存在しない場合に渡される ID の数とは異なる場合があります。

  パラメーター:

  commands - null であってはなりません。

  戻り値:

  削除されたエントリの数を出力する Mono。

  関連事項:

  • Redis ドキュメント: XDEL

• xLen

  default reactor.core.publisher.Mono<LongSE> xLen(ByteBufferSE key)

  キーに保存されているストリームのサイズを取得します。

  パラメーター:

  key - null であってはなりません。

  戻り値:

  ストリームの長さを放出する Mono。

  関連事項:

  • Redis ドキュメント: XLEN

• xLen

  reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,LongSE>> xLen(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands)

  ReactiveRedisConnection.KeyCommand.getKey() に保存されているストリームのサイズを取得します

  パラメーター:

  commands - null であってはなりません。

  戻り値:

  ReactiveRedisConnection.KeyCommand ごとのストリームの長さを放出する Flux。

  関連事項:

  • Redis ドキュメント: XLEN

• xPending

  default reactor.core.publisher.Mono<PendingMessagesSummary> xPending(ByteBufferSE key, StringSE groupName)

  特定のコンシューマーグループの PendingMessagesSummary を取得します。

  パラメーター:

  key - ストリームが保存されているキー。null であってはなりません。

  groupName - コンシューマーグループの名前。null であってはなりません。

  戻り値:

  Mono は、指定されたコンシューマーグループ内の保留中のメッセージの要約を発行します。

  導入:

  2.3

  関連事項:

  • Redis ドキュメント: xpending

• xPendingSummary

  reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.PendingRecordsCommand,PendingMessagesSummary>> xPendingSummary(org.reactivestreams.Publisher<ReactiveStreamCommands.PendingRecordsCommand> commands)

  特定のコンシューマーグループの PendingMessagesSummary を取得します。

  パラメーター:

  commands - null であってはなりません。

  戻り値:

  Flux は、指定されたコンシューマーグループ内の保留中のメッセージの要約を 1 つずつ出力します。

  導入:

  2.3

  関連事項:

  • Redis ドキュメント: xpending

• xPending

  @Nullable default reactor.core.publisher.Mono<PendingMessages> xPending(ByteBufferSE key, Consumer consumer)

  特定の Consumer のすべての保留中のメッセージに関する詳細情報を取得しました。

  パラメーター:

  key - ストリームが保存されているキー。null であってはなりません。

  consumer - PendingMessages をフェッチするコンシューマー。null であってはなりません。

  戻り値:

  指定された Consumer に対して保留中のメッセージを発行する Mono。

  導入:

  2.3

  関連事項:

  • Redis ドキュメント: xpending

• xPending

  @Nullable default reactor.core.publisher.Mono<PendingMessages> xPending(ByteBufferSE key, StringSE groupName, StringSE consumerName)

  特定のコンシューマーのすべての保留中のメッセージに関する詳細情報を取得しました。

  パラメーター:

  key - ストリームが保存されているキー。null であってはなりません。

  groupName - コンシューマーグループの名前。null であってはなりません。

  consumerName - PendingMessages をフェッチするコンシューマー。null であってはなりません。

  戻り値:

  指定された Consumer に対して保留中のメッセージを発行する Mono。

  導入:

  2.3

  関連事項:

  • Redis ドキュメント: xpending

• xPending

  default reactor.core.publisher.Mono<PendingMessages> xPending(ByteBufferSE key, StringSE groupName, Range<?> range, LongSE count)

  コンシューマーグループ内の特定の Range の保留中の messages に関する詳細情報を取得します。

  パラメーター:

  key - ストリームが保存されているキー。null であってはなりません。

  groupName - コンシューマーグループの名前。null であってはなりません。

  range - 検索するメッセージ ID の範囲。null であってはなりません。

  count - 結果の数を制限します。null であってはなりません。

  戻り値:

  Mono は、特定のコンシューマーグループに対して保留中のメッセージを発行します。トランザクション。

  導入:

  2.3

  関連事項:

  • Redis ドキュメント: xpending

• xPending

  default reactor.core.publisher.Mono<PendingMessages> xPending(ByteBufferSE key, Consumer consumer, Range<?> range, LongSE count)

  コンシューマーグループ内の特定の Range および Consumer の保留中の messages に関する詳細情報を取得します。

  パラメーター:

  key - ストリームが保存されているキー。null であってはなりません。

  consumer - Consumer の名前。null であってはなりません。

  range - 検索するメッセージ ID の範囲。null であってはなりません。

  count - 結果の数を制限します。null であってはなりません。

  戻り値:

  指定された Consumer に対して保留中のメッセージを発行する Mono。

  導入:

  2.3

  関連事項:

  • Redis ドキュメント: xpending

• xPending

  default reactor.core.publisher.Mono<PendingMessages> xPending(ByteBufferSE key, StringSE groupName, StringSE consumerName, Range<?> range, LongSE count)

  特定の Range およびコンシューマーグループ内のコンシューマーの保留中の messages に関する詳細情報を取得します。

  パラメーター:

  key - ストリームが保存されているキー。null であってはなりません。

  groupName - コンシューマーグループの名前。null であってはなりません。

  consumerName - コンシューマーの名前。null であってはなりません。

  range - 検索するメッセージ ID の範囲。null であってはなりません。

  count - 結果の数を制限します。null であってはなりません。

  戻り値:

  Mono は、特定のコンシューマーグループ内の特定のコンシューマーに対して保留中のメッセージを発行します。

  導入:

  2.3

  関連事項:

  • Redis ドキュメント: xpending

• xPending

  reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.PendingRecordsCommand,PendingMessages>> xPending(org.reactivestreams.Publisher<ReactiveStreamCommands.PendingRecordsCommand> commands)

  指定された options を適用する保留中の messages に関する詳細情報を取得します。

  パラメーター:

  commands - null であってはなりません。

  戻り値:

  Flux は、指定された条件に一致する保留中のメッセージを発行します。

  導入:

  2.3

  関連事項:

  • Redis ドキュメント: xpending

• xRange

  default reactor.core.publisher.Flux<ByteBufferRecord> xRange(ByteBufferSE key, Range<StringSE> range)

  特定の Range 内のストリームからレコードを読み取ります。

  パラメーター:

  key - ストリームキー。

  range - null であってはなりません。

  戻り値:

  ストリームのメンバーと一緒に放出する Flux。

  関連事項:

  • Redis ドキュメント: XRANGE

• xRange

  default reactor.core.publisher.Flux<ByteBufferRecord> xRange(ByteBufferSE key, Range<StringSE> range, Limit limit)

  Limit を適用して、特定の Range 内のストリームからレコードを読み取ります。

  パラメーター:

  key - ストリームキー。

  range - null であってはなりません。

  limit - null であってはなりません。

  戻り値:

  ストリームのメンバーと一緒に放出する Flux。

  関連事項:

  • Redis ドキュメント: XRANGE

• xRange

  reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.RangeCommand,reactor.core.publisher.Flux<ByteBufferRecord>>> xRange(org.reactivestreams.Publisher<ReactiveStreamCommands.RangeCommand> commands)

  Limit を適用して、特定の Range 内のストリームからレコードを読み取ります。

  パラメーター:

  commands - null であってはなりません。

  戻り値:

  ReactiveStreamCommands.RangeCommand ごとにストリームのメンバーとともに放出する Flux。

  関連事項:

  • Redis ドキュメント: XRANGE

• xRead

  default reactor.core.publisher.Flux<ByteBufferRecord> xRead(StreamOffset<ByteBufferSE>... streams)

  1 つ以上の StreamOffset からレコードを読み取ります。

  パラメーター:

  streams - 読み取るストリーム。

  戻り値:

  ストリームのメンバーと一緒に放出する Flux。

  関連事項:

  • Redis ドキュメント: XREAD

• xRead

  default reactor.core.publisher.Flux<ByteBufferRecord> xRead(StreamReadOptions readOptions, StreamOffset<ByteBufferSE>... streams)

  1 つ以上の StreamOffset からレコードを読み取ります。

  パラメーター:

  readOptions - 引数を読み取ります。

  streams - 読み取るストリーム。

  戻り値:

  ストリームのメンバーと一緒に放出する Flux。

  関連事項:

  • Redis ドキュメント: XREAD

• read

  reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.ReadCommand,reactor.core.publisher.Flux<ByteBufferRecord>>> read(org.reactivestreams.Publisher<ReactiveStreamCommands.ReadCommand> commands)

  1 つ以上の StreamOffset からレコードを読み取ります。

  パラメーター:

  commands - null であってはなりません。

  戻り値:

  ReactiveStreamCommands.ReadCommand ごとにストリームのメンバーを放出する Flux。

  関連事項:

  • Redis ドキュメント: XREAD
  • Redis ドキュメント: XREADGROUP

• xInfo

  default reactor.core.publisher.Mono<StreamInfo.XInfoStream> xInfo(ByteBufferSE key)

  指定されたキーに保存されているストリームに関する一般情報を取得します。

  パラメーター:

  key - ストリームが保存されているキー。

  戻り値:

  準備ができたら StreamInfo.XInfoStream を放出する Mono。

  導入:

  2.3

• xInfo

  reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XInfoCommand,StreamInfo.XInfoStream>> xInfo(org.reactivestreams.Publisher<ReactiveStreamCommands.XInfoCommand> commands)

  指定されたキーに保存されているストリームに関する一般情報を取得します。

  パラメーター:

  commands - null であってはなりません。

  戻り値:

  決して null にはなりません。

  導入:

  2.3

• xInfoGroups

  default reactor.core.publisher.Flux<StreamInfo.XInfoGroup> xInfoGroups(ByteBufferSE key)

  指定されたキーに保存されているストリームに関する一般情報を取得します。

  パラメーター:

  key - ストリームが保存されているキー。

  戻り値:

  Flux はコンシューマーグループ情報を 1 つずつ放出します。

  導入:

  2.3

• xInfoGroups

  reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XInfoCommand,reactor.core.publisher.Flux<StreamInfo.XInfoGroup>>> xInfoGroups(org.reactivestreams.Publisher<ReactiveStreamCommands.XInfoCommand> commands)

  指定されたキーに保存されているストリームに関する一般情報を取得します。

  パラメーター:

  commands - null であってはなりません。

  戻り値:

  決して null にはなりません。

  導入:

  2.3

• xInfoConsumers

  default reactor.core.publisher.Flux<StreamInfo.XInfoConsumer> xInfoConsumers(ByteBufferSE key, StringSE groupName)

  指定されたキーに格納されているストリームの特定のコンシューマーグループ内のすべてのコンシューマーに関する情報を取得します。

  パラメーター:

  key - ストリームが保存されているキー。

  groupName - コンシューマーグループの名前。

  戻り値:

  コンシューマー情報を 1 つずつ発信する Flux。

  導入:

  2.3

• xInfoConsumers

  reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XInfoCommand,reactor.core.publisher.Flux<StreamInfo.XInfoConsumer>>> xInfoConsumers(org.reactivestreams.Publisher<ReactiveStreamCommands.XInfoCommand> commands)

  指定されたキーに格納されているストリームの特定のコンシューマーグループ内のすべてのコンシューマーに関する情報を取得します。

  パラメーター:

  commands - null であってはなりません。

  戻り値:

  決して null にはなりません。

  導入:

  2.3

• xGroupCreate

  default reactor.core.publisher.Mono<StringSE> xGroupCreate(ByteBufferSE key, StringSE groupName, ReadOffset readOffset)

  コンシューマーグループを作成します。

  パラメーター:

  key - key ストリームが保存されているキー。

  groupName - 作成するコンシューマーグループの名前。

  readOffset - 開始するオフセット。

  戻り値:

  Mono は、成功した場合は正常に出力します。

• xGroupCreate

  default reactor.core.publisher.Mono<StringSE> xGroupCreate(ByteBufferSE key, StringSE groupName, ReadOffset readOffset, boolean mkStream)

  コンシューマーグループを作成します。

  パラメーター:

  key - key ストリームが保存されているキー。

  groupName - 作成するコンシューマーグループの名前。

  readOffset - 開始するオフセット。

  mkStream - true の場合、グループは必要に応じてストリームを作成します (MKSTREAM)

  戻り値:

  Mono は、成功した場合は正常に出力します。

  導入:

  2.3

• xGroupDelConsumer

  @Nullable default reactor.core.publisher.Mono<StringSE> xGroupDelConsumer(ByteBufferSE key, StringSE groupName, StringSE consumerName)

  コンシューマーグループからコンシューマーを削除します。

  パラメーター:

  key - ストリームが保存されているキー。

  groupName - コンシューマーを削除するグループの名前。

  consumerName - グループから削除するコンシューマーの名前。

  戻り値:

  Mono は、成功した場合は正常に出力します。

• xGroupDelConsumer

  default reactor.core.publisher.Mono<StringSE> xGroupDelConsumer(ByteBufferSE key, Consumer consumer)

  コンシューマーグループからコンシューマーを削除します。

  パラメーター:

  key - ストリームが保存されているキー。

  consumer - Consumer

  戻り値:

  Mono は、成功した場合は正常に出力します。

• xGroupDestroy

  @Nullable default reactor.core.publisher.Mono<StringSE> xGroupDestroy(ByteBufferSE key, StringSE groupName)

  コンシューマーグループを破棄します。

  パラメーター:

  key - ストリームが保存されているキー。

  groupName - コンシューマーグループの名前。

  戻り値:

  Mono は、成功した場合は正常に出力します。

• xGroup

  default reactor.core.publisher.Mono<StringSE> xGroup(ReactiveStreamCommands.GroupCommand command)

  指定された ReactiveStreamCommands.GroupCommand を実行して、グループを作成、破棄、... します。

  パラメーター:

  command - 実行する ReactiveStreamCommands.GroupCommand。

  戻り値:

  コマンド結果を出力する Mono。

• xGroup

  reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.GroupCommand,StringSE>> xGroup(org.reactivestreams.Publisher<ReactiveStreamCommands.GroupCommand> commands)

  指定された ReactiveStreamCommands.GroupCommand を実行して、グループを作成、破棄、... します。

  パラメーター:

  commands -

  戻り値:

  ReactiveStreamCommands.GroupCommand の結果を 1 つずつ放出する Flux。

• xReadGroup

  default reactor.core.publisher.Flux<ByteBufferRecord> xReadGroup(Consumer consumer, StreamOffset<ByteBufferSE>... streams)

  コンシューマーグループを使用して、1 つ以上の StreamOffset からレコードを読み取ります。

  パラメーター:

  consumer - コンシューマー / グループ。

  streams - 読み取るストリーム。

  戻り値:

  ストリームのメンバーを放出する Flux 

  関連事項:

  • Redis ドキュメント: XREADGROUP

• xReadGroup

  default reactor.core.publisher.Flux<ByteBufferRecord> xReadGroup(Consumer consumer, StreamReadOptions readOptions, StreamOffset<ByteBufferSE>... streams)

  コンシューマーグループを使用して、1 つ以上の StreamOffset からレコードを読み取ります。

  パラメーター:

  consumer - コンシューマー / グループ。

  readOptions - 引数を読み取ります。

  streams - 読み取るストリーム。

  戻り値:

  ストリームのメンバーを放出する Flux。

  関連事項:

  • Redis ドキュメント: XREADGROUP

• xRevRange

  default reactor.core.publisher.Flux<ByteBufferRecord> xRevRange(ByteBufferSE key, Range<StringSE> range)

  特定の Range 内のストリームからレコードを逆の順序で読み取ります。

  パラメーター:

  key - ストリームキー。

  range - null であってはなりません。

  戻り値:

  Flux は、ストリームのメンバーを逆に放出します。

  関連事項:

  • Redis ドキュメント: XREVRANGE

• xRevRange

  default reactor.core.publisher.Flux<ByteBufferRecord> xRevRange(ByteBufferSE key, Range<StringSE> range, Limit limit)

  Limit を逆の順序で適用して、特定の Range 内のストリームからレコードを読み取ります。

  パラメーター:

  key - ストリームキー。

  range - null であってはなりません。

  limit - null であってはなりません。

  戻り値:

  Flux は、ストリームのメンバーを逆に放出します。

  関連事項:

  • Redis ドキュメント: XREVRANGE

• xRevRange

  reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.RangeCommand,reactor.core.publisher.Flux<ByteBufferRecord>>> xRevRange(org.reactivestreams.Publisher<ReactiveStreamCommands.RangeCommand> commands)

  Limit を逆の順序で適用して、特定の Range 内のストリームからレコードを読み取ります。

  パラメーター:

  commands - null であってはなりません。

  戻り値:

  Flux は、ストリームのメンバーを逆に放出します。

  関連事項:

  • Redis ドキュメント: XREVRANGE

• xTrim

  default reactor.core.publisher.Mono<LongSE> xTrim(ByteBufferSE key, long count)

  ストリームを count 要素にトリミングします。

  パラメーター:

  key - ストリームキー。

  count - ストリームの長さ。

  戻り値:

  削除されたエントリの数を出力する Mono。

  関連事項:

  • Redis ドキュメント: XTRIM

• xTrim

  default reactor.core.publisher.Mono<LongSE> xTrim(ByteBufferSE key, long count, boolean approximateTrimming)

  ストリームを count 要素にトリミングします。

  パラメーター:

  key - ストリームキー。

  count - ストリームの長さ。

  approximateTrimming - パフォーマンスを最大化するには、おおよその方法でトリミングを実行する必要があります。

  戻り値:

  削除されたエントリの数を出力する Mono。

  導入:

  2.4

  関連事項:

  • Redis ドキュメント: XTRIM

• xTrim

  reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,LongSE>> xTrim(org.reactivestreams.Publisher<ReactiveStreamCommands.TrimCommand> commands)

  ストリームを count 要素にトリミングします。

  パラメーター:

  commands - null であってはなりません。

  戻り値:

  ReactiveStreamCommands.TrimCommand ごとに削除されたエントリの数を出力する Flux。

  関連事項:

  • Redis ドキュメント: XTRIM