インターフェース ReactiveStreamCommands
- すべての既知のサブインターフェース:
ReactiveClusterStreamCommands
public interface ReactiveStreamCommands
リアクティブインフラストラクチャを使用して実行されるストリーム固有の Redis コマンド。
- 導入:
- 2.2
- 作成者:
- Mark Paluch, Christoph Strobl, Tugdual Grall, Dengliming, Mark John Moreno, jinkshower
ネストされたクラスの要約
ネストされたクラス修飾子と型インターフェース説明static classXACKコマンドパラメーター。static classXADDコマンドパラメーター。static classXDELコマンドパラメーター。static classstatic class保留中のメッセージを取得するための値オブジェクト保持パラメーター。static classXRANGE/XREVRANGEコマンドパラメーター。static classXRANGE/XREVRANGEコマンドパラメーター。static classXTRIMコマンドパラメーター。static classXCLAIMコマンドパラメーター。static classメソッドのサマリー
修飾子と型メソッド説明Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.ReadCommand,Flux<ByteBufferRecord>>> read(Publisher<ReactiveStreamCommands.ReadCommand> commands) 1 つ以上のStreamOffsetからレコードを読み取ります。xAck(ByteBufferSE key, StringSE group, StringSE... recordIds) 1 つ以上のレコードを処理済みとして確認します。xAck(ByteBufferSE key, StringSE group, RecordId... recordIds) 1 つ以上のレコードを処理済みとして確認します。1 つ以上のレコードを処理済みとして確認します。xAdd(ByteBufferSE key, MapSE<ByteBufferSE, ByteBufferSE> body) 指定された本文のストリームレコードをキーに追加します。xAdd(Publisher<ReactiveStreamCommands.AddStreamRecord> commands) 指定された本文のストリームレコードをキーに追加します。xAdd(ByteBufferRecord record) 指定された本文のストリームレコードをキーに追加します。xAdd(ByteBufferRecord record, RedisStreamCommands.XAddOptions xAddOptions) 指定されたオプションでストリームレコードを追加します。default Flux<ByteBufferRecord>xClaim(ByteBufferSE key, StringSE group, StringSE newOwner, DurationSE minIdleTime, RecordId... recordIds) 指定された新しいコンシューマーへの保留中のメッセージの所有権を変更します。default Flux<ByteBufferRecord>xClaim(ByteBufferSE key, StringSE group, StringSE newOwner, RedisStreamCommands.XClaimOptions options) 指定された新しいコンシューマーへの保留中のメッセージの所有権を変更します。Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XClaimCommand,Flux<ByteBufferRecord>>> xClaim(Publisher<ReactiveStreamCommands.XClaimCommand> commands) 指定された新しいコンシューマーへの保留中のメッセージの所有権を変更します。xClaimJustId(ByteBufferSE key, StringSE group, StringSE newOwner, RedisStreamCommands.XClaimOptions options) 配信数を増やすことなく、指定された新しいコンシューマーへの保留中のメッセージの所有権を変更します。配信数を増やすことなく、指定された新しいコンシューマーへの保留中のメッセージの所有権を変更します。xDel(ByteBufferSE key, StringSE... recordIds) 指定されたエントリをストリームから削除します。xDel(ByteBufferSE key, RecordId... recordIds) 指定されたエントリをストリームから削除します。xDel(Publisher<ReactiveStreamCommands.DeleteCommand> commands) 指定されたエントリをストリームから削除します。xGroup(Publisher<ReactiveStreamCommands.GroupCommand> commands) 指定されたReactiveStreamCommands.GroupCommandを実行して、グループを作成、破棄、... します。指定されたReactiveStreamCommands.GroupCommandを実行して、グループを作成、破棄、... します。xGroupCreate(ByteBufferSE key, StringSE groupName, ReadOffset readOffset) コンシューマーグループを作成します。xGroupCreate(ByteBufferSE key, StringSE groupName, ReadOffset readOffset, boolean mkStream) コンシューマーグループを作成します。xGroupDelConsumer(ByteBufferSE key, StringSE groupName, StringSE consumerName) コンシューマーグループからコンシューマーを削除します。xGroupDelConsumer(ByteBufferSE key, Consumer consumer) コンシューマーグループからコンシューマーを削除します。xGroupDestroy(ByteBufferSE key, StringSE groupName) コンシューマーグループを破棄します。default Mono<StreamInfo.XInfoStream>xInfo(ByteBufferSE key) 指定されたキーに保存されているストリームに関する一般情報を取得します。Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XInfoCommand,StreamInfo.XInfoStream>> xInfo(Publisher<ReactiveStreamCommands.XInfoCommand> commands) 指定されたキーに保存されているストリームに関する一般情報を取得します。default Flux<StreamInfo.XInfoConsumer>xInfoConsumers(ByteBufferSE key, StringSE groupName) 指定されたキーに格納されているストリームの特定のコンシューマーグループ内のすべてのコンシューマーに関する情報を取得します。Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XInfoCommand,Flux<StreamInfo.XInfoConsumer>>> 指定されたキーに格納されているストリームの特定のコンシューマーグループ内のすべてのコンシューマーに関する情報を取得します。default Flux<StreamInfo.XInfoGroup>xInfoGroups(ByteBufferSE key) 指定されたキーに保存されているストリームに関する一般情報を取得します。Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XInfoCommand,Flux<StreamInfo.XInfoGroup>>> 指定されたキーに保存されているストリームに関する一般情報を取得します。xLen(ByteBufferSE key) キーに保存されているストリームのサイズを取得します。xLen(Publisher<ReactiveRedisConnection.KeyCommand> commands) ReactiveRedisConnection.KeyCommand.getKey()に保存されているストリームのサイズを取得しますdefault Mono<PendingMessagesSummary>xPending(ByteBufferSE key, StringSE groupName) 特定のコンシューマーグループのPendingMessagesSummaryを取得します。default Mono<PendingMessages>xPending(ByteBufferSE key, StringSE groupName, StringSE consumerName) 特定のコンシューマーのすべての保留中のメッセージに関する詳細情報を取得しました。default Mono<PendingMessages>default Mono<PendingMessages>xPending(ByteBufferSE key, StringSE groupName, Range<?> range, LongSE count) default Mono<PendingMessages>xPending(ByteBufferSE key, Consumer consumer) 特定のConsumerのすべての保留中のメッセージに関する詳細情報を取得しました。default Mono<PendingMessages>xPending(ByteBufferSE key, Consumer consumer, Range<?> range, LongSE count) Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.PendingRecordsCommand,PendingMessages>> Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.PendingRecordsCommand,PendingMessagesSummary>> 特定のコンシューマーグループのPendingMessagesSummaryを取得します。default Flux<ByteBufferRecord>xRange(ByteBufferSE key, Range<StringSE> range) 特定のRange内のストリームからレコードを読み取ります。default Flux<ByteBufferRecord>xRange(ByteBufferSE key, Range<StringSE> range, Limit limit) Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.RangeCommand,Flux<ByteBufferRecord>>> xRange(Publisher<ReactiveStreamCommands.RangeCommand> commands) default Flux<ByteBufferRecord>xRead(StreamOffset<ByteBufferSE>... streams) 1 つ以上のStreamOffsetからレコードを読み取ります。default Flux<ByteBufferRecord>xRead(StreamReadOptions readOptions, StreamOffset<ByteBufferSE>... streams) 1 つ以上のStreamOffsetからレコードを読み取ります。default Flux<ByteBufferRecord>xReadGroup(Consumer consumer, StreamOffset<ByteBufferSE>... streams) コンシューマーグループを使用して、1 つ以上のStreamOffsetからレコードを読み取ります。default Flux<ByteBufferRecord>xReadGroup(Consumer consumer, StreamReadOptions readOptions, StreamOffset<ByteBufferSE>... streams) コンシューマーグループを使用して、1 つ以上のStreamOffsetからレコードを読み取ります。default Flux<ByteBufferRecord>xRevRange(ByteBufferSE key, Range<StringSE> range) 特定のRange内のストリームからレコードを逆の順序で読み取ります。default Flux<ByteBufferRecord>xRevRange(ByteBufferSE key, Range<StringSE> range, Limit limit) Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.RangeCommand,Flux<ByteBufferRecord>>> xTrim(ByteBufferSE key, long count) ストリームをcount要素にトリミングします。xTrim(ByteBufferSE key, long count, boolean approximateTrimming) ストリームをcount要素にトリミングします。xTrim(Publisher<ReactiveStreamCommands.TrimCommand> commands) ストリームをcount要素にトリミングします。
メソッドの詳細
xAck
1 つ以上のレコードを処理済みとして確認します。- パラメーター:
key- ストリームキー。group- コンシューマーグループの名前。recordIds- 確認する ID を記録します。- 戻り値:
Monoは確認応答メッセージの nr を送信します。- 関連事項:
xAck
1 つ以上のレコードを処理済みとして確認します。- パラメーター:
key- ストリームキー。group- コンシューマーグループの名前。recordIds- 確認する ID を記録します。- 戻り値:
Monoは確認応答メッセージの nr を送信します。- 関連事項:
xAck
Flux<ReactiveRedisConnection.NumericResponse<ReactiveStreamCommands.AcknowledgeCommand,LongSE>> xAck(Publisher<ReactiveStreamCommands.AcknowledgeCommand> commands) 1 つ以上のレコードを処理済みとして確認します。- パラメーター:
commands- null であってはなりません。- 戻り値:
Fluxは、ReactiveStreamCommands.AcknowledgeCommandごとに確認応答されたメッセージの nr を送信します。- 関連事項:
xAdd
指定された本文のストリームレコードをキーに追加します。xAdd
指定された本文のストリームレコードをキーに追加します。xAdd
指定されたオプションでストリームレコードを追加します。xAdd
Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.AddStreamRecord,RecordId>> xAdd(Publisher<ReactiveStreamCommands.AddStreamRecord> commands) 指定された本文のストリームレコードをキーに追加します。- パラメーター:
commands- null であってはなりません。- 戻り値:
Fluxは、指定されたReactiveStreamCommands.AddStreamRecordコマンドによってRecordIdを送信します。- 関連事項:
xClaimJustId
default Flux<RecordId> xClaimJustId(ByteBufferSE key, StringSE group, StringSE newOwner, RedisStreamCommands.XClaimOptions options) 配信数を増やすことなく、指定された新しいコンシューマーへの保留中のメッセージの所有権を変更します。xClaimJustId
Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XClaimCommand,Flux<RecordId>>> xClaimJustId(Publisher<ReactiveStreamCommands.XClaimCommand> commands) 配信数を増やすことなく、指定された新しいコンシューマーへの保留中のメッセージの所有権を変更します。xClaim
default Flux<ByteBufferRecord> xClaim(ByteBufferSE key, StringSE group, StringSE newOwner, DurationSE minIdleTime, RecordId... recordIds) 指定された新しいコンシューマーへの保留中のメッセージの所有権を変更します。- パラメーター:
key- ストリームが保存されているキー。group- コンシューマーグループの名前。newOwner- 新しいコンシューマーの名前。minIdleTime- null であってはなりません。recordIds- null であってはなりません。- 戻り値:
- ユーザーが変更された
ByteBufferRecordを発信するFlux。 - 導入:
- 2.3
- 関連事項:
xClaim
default Flux<ByteBufferRecord> xClaim(ByteBufferSE key, StringSE group, StringSE newOwner, RedisStreamCommands.XClaimOptions options) 指定された新しいコンシューマーへの保留中のメッセージの所有権を変更します。- パラメーター:
key- ストリームが保存されているキー。group- コンシューマーグループの名前。newOwner- 新しいコンシューマーの名前。options- null であってはなりません。- 戻り値:
- ユーザーが変更された
ByteBufferRecordを発信するFlux。 - 導入:
- 2.3
- 関連事項:
xClaim
Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XClaimCommand,Flux<ByteBufferRecord>>> xClaim(Publisher<ReactiveStreamCommands.XClaimCommand> commands) 指定された新しいコンシューマーへの保留中のメッセージの所有権を変更します。- パラメーター:
commands- null であってはなりません。- 戻り値:
- 導入:
- 2.3
- 関連事項:
xDel
指定されたエントリをストリームから削除します。削除されたアイテムの数を返します。特定の ID が存在しない場合に渡される ID の数とは異なる場合があります。- パラメーター:
key- ストリームキー。recordIds- ストリームレコード ID。- 戻り値:
- 削除されたエントリの数を出力する
Mono。 - 関連事項:
xDel
指定されたエントリをストリームから削除します。削除されたアイテムの数を返します。特定の ID が存在しない場合に渡される ID の数とは異なる場合があります。- パラメーター:
key- ストリームキー。recordIds- ストリームレコード ID。- 戻り値:
- 削除されたエントリの数を出力する
Mono。 - 関連事項:
xDel
Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.DeleteCommand,LongSE>> xDel(Publisher<ReactiveStreamCommands.DeleteCommand> commands) 指定されたエントリをストリームから削除します。削除されたアイテムの数を返します。特定の ID が存在しない場合に渡される ID の数とは異なる場合があります。- パラメーター:
commands- null であってはなりません。- 戻り値:
- 削除されたエントリの数を出力する
Mono。 - 関連事項:
xLen
キーに保存されているストリームのサイズを取得します。- パラメーター:
key- null であってはなりません。- 戻り値:
- ストリームの長さを発信する
Mono。 - 関連事項:
xLen
Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,LongSE>> xLen(Publisher<ReactiveRedisConnection.KeyCommand> commands) ReactiveRedisConnection.KeyCommand.getKey()に保存されているストリームのサイズを取得します- パラメーター:
commands- null であってはなりません。- 戻り値:
Fluxは、ReactiveRedisConnection.KeyCommandごとにストリームの長さを出力します。- 関連事項:
xPending
特定のコンシューマーグループのPendingMessagesSummaryを取得します。- パラメーター:
key- ストリームが保存されているキー。null であってはなりません。groupName- コンシューマーグループの名前。null であってはなりません。- 戻り値:
Monoは、指定されたコンシューマーグループ内の保留中のメッセージの概要を送信します。- 導入:
- 2.3
- 関連事項:
xPendingSummary
Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.PendingRecordsCommand,PendingMessagesSummary>> xPendingSummary(Publisher<ReactiveStreamCommands.PendingRecordsCommand> commands) 特定のコンシューマーグループのPendingMessagesSummaryを取得します。- パラメーター:
commands- null であってはなりません。- 戻り値:
Fluxは、指定されたコンシューマーグループ内の保留中のメッセージの概要を 1 つずつ送信します。- 導入:
- 2.3
- 関連事項:
xPending
特定のConsumerのすべての保留中のメッセージに関する詳細情報を取得しました。- パラメーター:
key- ストリームが保存されているキー。null であってはなりません。consumer-PendingMessagesをフェッチするコンシューマー。null であってはなりません。- 戻り値:
Monoは、指定されたConsumerの保留中のメッセージを送信します。- 導入:
- 2.3
- 関連事項:
xPending
@Nullable default Mono<PendingMessages> xPending(ByteBufferSE key, StringSE groupName, StringSE consumerName) 特定のコンシューマーのすべての保留中のメッセージに関する詳細情報を取得しました。- パラメーター:
key- ストリームが保存されているキー。null であってはなりません。groupName- コンシューマーグループの名前。null であってはなりません。consumerName-PendingMessagesをフェッチするコンシューマー。null であってはなりません。- 戻り値:
Monoは、指定されたConsumerの保留中のメッセージを送信します。- 導入:
- 2.3
- 関連事項:
xPending
default Mono<PendingMessages> xPending(ByteBufferSE key, StringSE groupName, Range<?> range, LongSE count) - パラメーター:
key- ストリームが保存されているキー。null であってはなりません。groupName- コンシューマーグループの名前。null であってはなりません。range- 検索するメッセージ ID の範囲。null であってはなりません。count- 結果の数を制限します。null であってはなりません。- 戻り値:
Monoは、指定されたコンシューマーグループの保留中のメッセージを送信します。トランザクション。- 導入:
- 2.3
- 関連事項:
xPending
default Mono<PendingMessages> xPending(ByteBufferSE key, Consumer consumer, Range<?> range, LongSE count) xPending
default Mono<PendingMessages> xPending(ByteBufferSE key, StringSE groupName, StringSE consumerName, Range<?> range, LongSE count) - パラメーター:
key- ストリームが保存されているキー。null であってはなりません。groupName- コンシューマーグループの名前。null であってはなりません。consumerName- コンシューマーの名前。null であってはなりません。range- 検索するメッセージ ID の範囲。null であってはなりません。count- 結果の数を制限します。null であってはなりません。- 戻り値:
Monoは、指定されたコンシューマーグループ内の指定されたコンシューマーに対して保留中のメッセージを送信します。- 導入:
- 2.3
- 関連事項:
xPending
Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.PendingRecordsCommand,PendingMessages>> xPending(Publisher<ReactiveStreamCommands.PendingRecordsCommand> commands) - パラメーター:
commands- null であってはなりません。- 戻り値:
Fluxは、指定された条件に一致する保留中のメッセージを送信します。- 導入:
- 2.3
- 関連事項:
xRange
特定のRange内のストリームからレコードを読み取ります。- パラメーター:
key- ストリームキー。range- null であってはなりません。- 戻り値:
Fluxがストリームのメンバーとともに発信しています。- 関連事項:
xRange
- パラメーター:
key- ストリームキー。range- null であってはなりません。limit- null であってはなりません。- 戻り値:
Fluxがストリームのメンバーとともに発信しています。- 関連事項:
xRange
Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.RangeCommand,Flux<ByteBufferRecord>>> xRange(Publisher<ReactiveStreamCommands.RangeCommand> commands) - パラメーター:
commands- null であってはなりません。- 戻り値:
Fluxは、ReactiveStreamCommands.RangeCommandごとにストリームのメンバーを送信します。- 関連事項:
xRead
1 つ以上のStreamOffsetからレコードを読み取ります。- パラメーター:
streams- 読み取るストリーム。- 戻り値:
Fluxがストリームのメンバーとともに発信しています。- 関連事項:
xRead
default Flux<ByteBufferRecord> xRead(StreamReadOptions readOptions, StreamOffset<ByteBufferSE>... streams) 1 つ以上のStreamOffsetからレコードを読み取ります。- パラメーター:
readOptions- 引数を読み取ります。streams- 読み取るストリーム。- 戻り値:
Fluxがストリームのメンバーとともに発信しています。- 関連事項:
read
Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.ReadCommand,Flux<ByteBufferRecord>>> read(Publisher<ReactiveStreamCommands.ReadCommand> commands) 1 つ以上のStreamOffsetからレコードを読み取ります。- パラメーター:
commands- null であってはなりません。- 戻り値:
Fluxは、ReactiveStreamCommands.ReadCommandごとにストリームのメンバーを送信します。- 関連事項:
xInfo
指定されたキーに保存されているストリームに関する一般情報を取得します。- パラメーター:
key- ストリームが保存されているキー。- 戻り値:
- 準備ができたら
StreamInfo.XInfoStreamを発信するMono。 - 導入:
- 2.3
xInfo
Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XInfoCommand,StreamInfo.XInfoStream>> xInfo(Publisher<ReactiveStreamCommands.XInfoCommand> commands) 指定されたキーに保存されているストリームに関する一般情報を取得します。- パラメーター:
commands- null であってはなりません。- 戻り値:
- 決して null にはなりません。
- 導入:
- 2.3
xInfoGroups
指定されたキーに保存されているストリームに関する一般情報を取得します。- パラメーター:
key- ストリームが保存されているキー。- 戻り値:
- コンシューマーグループ情報を 1 つずつ送信する
Fluxです。 - 導入:
- 2.3
xInfoGroups
Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XInfoCommand,Flux<StreamInfo.XInfoGroup>>> xInfoGroups(Publisher<ReactiveStreamCommands.XInfoCommand> commands) 指定されたキーに保存されているストリームに関する一般情報を取得します。- パラメーター:
commands- null であってはなりません。- 戻り値:
- 決して null にはなりません。
- 導入:
- 2.3
xInfoConsumers
指定されたキーに格納されているストリームの特定のコンシューマーグループ内のすべてのコンシューマーに関する情報を取得します。- パラメーター:
key- ストリームが保存されているキー。groupName- コンシューマーグループの名前。- 戻り値:
- コンシューマー情報を 1 つずつ発信する
Flux。 - 導入:
- 2.3
xInfoConsumers
Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XInfoCommand,Flux<StreamInfo.XInfoConsumer>>> xInfoConsumers(Publisher<ReactiveStreamCommands.XInfoCommand> commands) 指定されたキーに格納されているストリームの特定のコンシューマーグループ内のすべてのコンシューマーに関する情報を取得します。- パラメーター:
commands- null であってはなりません。- 戻り値:
- 決して null にはなりません。
- 導入:
- 2.3
xGroupCreate
コンシューマーグループを作成します。- パラメーター:
key- key ストリームが保存されているキー。groupName- 作成するコンシューマーグループの名前。readOffset- 開始するオフセット。- 戻り値:
- 成功した場合、
Monoは正常に出力します。
xGroupCreate
default Mono<StringSE> xGroupCreate(ByteBufferSE key, StringSE groupName, ReadOffset readOffset, boolean mkStream) コンシューマーグループを作成します。- パラメーター:
key- key ストリームが保存されているキー。groupName- 作成するコンシューマーグループの名前。readOffset- 開始するオフセット。mkStream- true の場合、グループは必要に応じてストリームを作成します (MKSTREAM)- 戻り値:
- 成功した場合、
Monoは正常に出力します。 - 導入:
- 2.3
xGroupDelConsumer
@Nullable default Mono<StringSE> xGroupDelConsumer(ByteBufferSE key, StringSE groupName, StringSE consumerName) コンシューマーグループからコンシューマーを削除します。- パラメーター:
key- ストリームが保存されているキー。groupName- コンシューマーを削除するグループの名前。consumerName- グループから削除するコンシューマーの名前。- 戻り値:
- 成功した場合、
Monoは正常に出力します。
xGroupDelConsumer
コンシューマーグループからコンシューマーを削除します。xGroupDestroy
コンシューマーグループを破棄します。- パラメーター:
key- ストリームが保存されているキー。groupName- コンシューマーグループの名前。- 戻り値:
- 成功した場合、
Monoは正常に出力します。
xGroup
指定されたReactiveStreamCommands.GroupCommandを実行して、グループを作成、破棄、... します。- パラメーター:
command- 実行するReactiveStreamCommands.GroupCommand。- 戻り値:
- コマンド結果を発行する
Mono。
xGroup
Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.GroupCommand,StringSE>> xGroup(Publisher<ReactiveStreamCommands.GroupCommand> commands) 指定されたReactiveStreamCommands.GroupCommandを実行して、グループを作成、破棄、... します。- パラメーター:
commands-- 戻り値:
FluxはReactiveStreamCommands.GroupCommandの結果を 1 つずつ出力します。
xReadGroup
コンシューマーグループを使用して、1 つ以上のStreamOffsetからレコードを読み取ります。- パラメーター:
consumer- コンシューマー / グループ。streams- 読み取るストリーム。- 戻り値:
Fluxはストリームのメンバーを放出する- 関連事項:
xReadGroup
default Flux<ByteBufferRecord> xReadGroup(Consumer consumer, StreamReadOptions readOptions, StreamOffset<ByteBufferSE>... streams) コンシューマーグループを使用して、1 つ以上のStreamOffsetからレコードを読み取ります。- パラメーター:
consumer- コンシューマー / グループ。readOptions- 引数を読み取ります。streams- 読み取るストリーム。- 戻り値:
Fluxはストリームのメンバーを送信します。- 関連事項:
xRevRange
特定のRange内のストリームからレコードを逆の順序で読み取ります。- パラメーター:
key- ストリームキー。range- null であってはなりません。- 戻り値:
Fluxはストリームのメンバーを逆順に送信します。- 関連事項:
xRevRange
- パラメーター:
key- ストリームキー。range- null であってはなりません。limit- null であってはなりません。- 戻り値:
Fluxはストリームのメンバーを逆順に送信します。- 関連事項:
xRevRange
Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.RangeCommand,Flux<ByteBufferRecord>>> xRevRange(Publisher<ReactiveStreamCommands.RangeCommand> commands) - パラメーター:
commands- null であってはなりません。- 戻り値:
Fluxはストリームのメンバーを逆順に送信します。- 関連事項:
xTrim
ストリームをcount要素にトリミングします。- パラメーター:
key- ストリームキー。count- ストリームの長さ。- 戻り値:
- 削除されたエントリの数を出力する
Mono。 - 関連事項:
xTrim
ストリームをcount要素にトリミングします。- パラメーター:
key- ストリームキー。count- ストリームの長さ。approximateTrimming- パフォーマンスを最大化するには、おおよその方法でトリミングを実行する必要があります。- 戻り値:
- 削除されたエントリの数を出力する
Mono。 - 導入:
- 2.4
- 関連事項:
xTrim
Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,LongSE>> xTrim(Publisher<ReactiveStreamCommands.TrimCommand> commands) ストリームをcount要素にトリミングします。- パラメーター:
commands- null であってはなりません。- 戻り値:
Fluxは、ReactiveStreamCommands.TrimCommandごとに削除されたエントリの数を出力します。- 関連事項: