クラスの使用
org.springframework.data.redis.connection.ReactiveRedisConnection.CommandResponse
ReactiveRedisConnection.CommandResponse を使用するパッケージ
パッケージ
説明
さまざまな Redis ' ドライバー '/libraries と対話するための低レベルの抽象化を提供する接続パッケージ。
org.springframework.data.redis.connection 内の ReactiveRedisConnection.CommandResponse 使用
修飾子と型クラス説明static classstatic classキーがない場合のByteBufferSE レスポンスのReactiveRedisConnection.CommandResponse実装。static classBooleanSE レスポンスのReactiveRedisConnection.CommandResponse実装。static classstatic classListSE レスポンスのReactiveRedisConnection.CommandResponse実装。static classReactiveRedisConnection.NumericResponse<I,O extends NumberSE> numericSE レスポンスのReactiveRedisConnection.CommandResponse実装。型 ReactiveRedisConnection.CommandResponse の引数を持つ型を返す org.springframework.data.redis.connection のメソッド修飾子と型メソッド説明reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.BZPopCommand,reactor.core.publisher.Flux<Tuple>>> ReactiveZSetCommands.bZPop(org.reactivestreams.Publisher<ReactiveZSetCommands.BZPopCommand> commands) keyCommand#getKey()SE でソートされたセットから要素を削除して返します。reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveGeoCommands.GeoDistCommand,Distance>> ReactiveGeoCommands.geoDist(org.reactivestreams.Publisher<ReactiveGeoCommands.GeoDistCommand> commands) from と to の間でDistanceを取得します。reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveGeoCommands.GeoRadiusCommand,reactor.core.publisher.Flux<GeoResult<RedisGeoCommands.GeoLocation<ByteBufferSE>>>>> ReactiveGeoCommands.geoRadius(org.reactivestreams.Publisher<ReactiveGeoCommands.GeoRadiusCommand> commands) 指定されたパラメーターを適用して、指定されたCircleの境界内のメンバーを取得します。reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveGeoCommands.GeoRadiusByMemberCommand,reactor.core.publisher.Flux<GeoResult<RedisGeoCommands.GeoLocation<ByteBufferSE>>>>> ReactiveGeoCommands.geoRadiusByMember(org.reactivestreams.Publisher<ReactiveGeoCommands.GeoRadiusByMemberCommand> commands) 指定されたパラメーターを適用するメンバーから、指定されたDistance内のメンバーを取得します。reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveGeoCommands.GeoSearchCommand,reactor.core.publisher.Flux<GeoResult<RedisGeoCommands.GeoLocation<ByteBufferSE>>>>> ReactiveGeoCommands.geoSearch(org.reactivestreams.Publisher<ReactiveGeoCommands.GeoSearchCommand> commands) 指定されたパラメーターを適用して、GeoReferenceから指定されたGeoShape内のメンバーを取得します。reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,reactor.core.publisher.Flux<Map.EntrySE<ByteBufferSE, ByteBufferSE>>>> ReactiveHashCommands.hGetAll(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) キーに保存されているハッシュ全体を取得します。reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,reactor.core.publisher.Flux<ByteBufferSE>>> ReactiveHashCommands.hKeys(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) キーでハッシュのキーセット（フィールド）を取得します。reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveHashCommands.HRandFieldCommand,reactor.core.publisher.Flux<ByteBufferSE>>> ReactiveHashCommands.hRandField(org.reactivestreams.Publisher<ReactiveHashCommands.HRandFieldCommand> commands) キーでハッシュの確率場を取得します。reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveHashCommands.HRandFieldCommand,reactor.core.publisher.Flux<Map.EntrySE<ByteBufferSE, ByteBufferSE>>>> ReactiveHashCommands.hRandFieldWithValues(org.reactivestreams.Publisher<ReactiveHashCommands.HRandFieldCommand> commands) キーのハッシュの値に沿って確率場を取得します。reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,reactor.core.publisher.Flux<Map.EntrySE<ByteBufferSE, ByteBufferSE>>>> ReactiveHashCommands.hScan(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyScanCommand> commands) Fluxを使用して、keyのハッシュ内のエントリを反復処理します。reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,reactor.core.publisher.Flux<ByteBufferSE>>> ReactiveHashCommands.hVals(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) キーでハッシュのエントリセット（値）を取得します。reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.RangeCommand,reactor.core.publisher.Flux<ByteBufferSE>>> ReactiveListCommands.lRange(org.reactivestreams.Publisher<ReactiveRedisConnection.RangeCommand> commands) reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveListCommands.PopCommand,reactor.core.publisher.Flux<ByteBufferSE>>> ReactiveListCommands.popList(org.reactivestreams.Publisher<ReactiveListCommands.PopCommand> commands) ReactiveRedisConnection.KeyCommand.getKey()に保存されているリストの最後の要素を削除して返しますreactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.ReadCommand,reactor.core.publisher.Flux<ByteBufferRecord>>> ReactiveStreamCommands.read(org.reactivestreams.Publisher<ReactiveStreamCommands.ReadCommand> commands) 1 つ以上のStreamOffsetからレコードを読み取ります。reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveSetCommands.SDiffCommand,reactor.core.publisher.Flux<ByteBufferSE>>> ReactiveSetCommands.sDiff(org.reactivestreams.Publisher<ReactiveSetCommands.SDiffCommand> commands) ReactiveSetCommands.SInterCommand.getKeys()で指定されたすべてのセットのメンバーの差分を返します。reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveSetCommands.SInterCommand,reactor.core.publisher.Flux<ByteBufferSE>>> ReactiveSetCommands.sInter(org.reactivestreams.Publisher<ReactiveSetCommands.SInterCommand> commands) ReactiveSetCommands.SInterCommand.getKeys()で指定されたすべてのセットと交差するメンバーを返します。reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,reactor.core.publisher.Flux<ByteBufferSE>>> ReactiveSetCommands.sMembers(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) ReactiveRedisConnection.KeyCommand.getKey()でセットのすべての要素を取得します。reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveSetCommands.SRandMembersCommand,reactor.core.publisher.Flux<ByteBufferSE>>> ReactiveSetCommands.sRandMember(org.reactivestreams.Publisher<ReactiveSetCommands.SRandMembersCommand> commands) reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,reactor.core.publisher.Flux<ByteBufferSE>>> ReactiveSetCommands.sScan(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyScanCommand> commands) Fluxを使用して、keyのセット内のメンバーを反復処理します。reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveSetCommands.SUnionCommand,reactor.core.publisher.Flux<ByteBufferSE>>> ReactiveSetCommands.sUnion(org.reactivestreams.Publisher<ReactiveSetCommands.SUnionCommand> commands) ReactiveSetCommands.SInterCommand.getKeys()で指定されたすべてのセットと交差するメンバーを返します。reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,DataType>> ReactiveKeyCommands.type(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> keys) キーに保存されている型を判別します。reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.AddStreamRecord,RecordId>> ReactiveStreamCommands.xAdd(org.reactivestreams.Publisher<ReactiveStreamCommands.AddStreamRecord> commands) 指定された本文のストリームレコードをキーに追加します。reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XClaimCommand,reactor.core.publisher.Flux<ByteBufferRecord>>> ReactiveStreamCommands.xClaim(org.reactivestreams.Publisher<ReactiveStreamCommands.XClaimCommand> commands) 指定された新しいコンシューマーへの保留中のメッセージの所有権を変更します。reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XClaimCommand,reactor.core.publisher.Flux<RecordId>>> ReactiveStreamCommands.xClaimJustId(org.reactivestreams.Publisher<ReactiveStreamCommands.XClaimCommand> commands) 配信数を増やすことなく、指定された新しいコンシューマーへの保留中のメッセージの所有権を変更します。reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.DeleteCommand,LongSE>> ReactiveStreamCommands.xDel(org.reactivestreams.Publisher<ReactiveStreamCommands.DeleteCommand> commands) 指定されたエントリをストリームから削除します。reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.GroupCommand,StringSE>> ReactiveStreamCommands.xGroup(org.reactivestreams.Publisher<ReactiveStreamCommands.GroupCommand> commands) 指定されたReactiveStreamCommands.GroupCommandを実行して、グループを作成、破棄、... します。reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XInfoCommand,StreamInfo.XInfoStream>> ReactiveStreamCommands.xInfo(org.reactivestreams.Publisher<ReactiveStreamCommands.XInfoCommand> commands) 指定されたキーに保存されているストリームに関する一般情報を取得します。reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XInfoCommand,reactor.core.publisher.Flux<StreamInfo.XInfoConsumer>>> ReactiveStreamCommands.xInfoConsumers(org.reactivestreams.Publisher<ReactiveStreamCommands.XInfoCommand> commands) 指定されたキーに格納されているストリームの特定のコンシューマーグループ内のすべてのコンシューマーに関する情報を取得します。reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XInfoCommand,reactor.core.publisher.Flux<StreamInfo.XInfoGroup>>> ReactiveStreamCommands.xInfoGroups(org.reactivestreams.Publisher<ReactiveStreamCommands.XInfoCommand> commands) 指定されたキーに保存されているストリームに関する一般情報を取得します。reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.PendingRecordsCommand,PendingMessages>> ReactiveStreamCommands.xPending(org.reactivestreams.Publisher<ReactiveStreamCommands.PendingRecordsCommand> commands) reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.PendingRecordsCommand,PendingMessagesSummary>> ReactiveStreamCommands.xPendingSummary(org.reactivestreams.Publisher<ReactiveStreamCommands.PendingRecordsCommand> commands) 特定のコンシューマーグループのPendingMessagesSummaryを取得します。reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.RangeCommand,reactor.core.publisher.Flux<ByteBufferRecord>>> ReactiveStreamCommands.xRange(org.reactivestreams.Publisher<ReactiveStreamCommands.RangeCommand> commands) reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.RangeCommand,reactor.core.publisher.Flux<ByteBufferRecord>>> ReactiveStreamCommands.xRevRange(org.reactivestreams.Publisher<ReactiveStreamCommands.RangeCommand> commands) reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZDiffCommand,reactor.core.publisher.Flux<ByteBufferSE>>> ReactiveZSetCommands.zDiff(org.reactivestreams.Publisher<? extends ReactiveZSetCommands.ZDiffCommand> commands) 差分ソートセット。reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZDiffCommand,reactor.core.publisher.Flux<Tuple>>> ReactiveZSetCommands.zDiffWithScores(org.reactivestreams.Publisher<? extends ReactiveZSetCommands.ZDiffCommand> commands) 差分ソートセット。reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZAggregateCommand,reactor.core.publisher.Flux<ByteBufferSE>>> ReactiveZSetCommands.zInter(org.reactivestreams.Publisher<? extends ReactiveZSetCommands.ZAggregateCommand> commands) aggregateFunction を適用してソートされたセットを交差させ、個々のセットに重みを適用します。reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZAggregateCommand,reactor.core.publisher.Flux<Tuple>>> ReactiveZSetCommands.zInterWithScores(org.reactivestreams.Publisher<? extends ReactiveZSetCommands.ZAggregateCommand> commands) aggregateFunction を適用してソートされたセットを交差させ、個々のセットに重みを適用します。reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZPopCommand,reactor.core.publisher.Flux<Tuple>>> ReactiveZSetCommands.zPop(org.reactivestreams.Publisher<ReactiveZSetCommands.ZPopCommand> commands) keyCommand#getKey()SE でソートされたセットから要素を削除して返します。reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZRandMemberCommand,reactor.core.publisher.Flux<ByteBufferSE>>> ReactiveZSetCommands.zRandMember(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRandMemberCommand> commands) keyでソートされたセットからランダムな要素を取得します。reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZRandMemberCommand,reactor.core.publisher.Flux<Tuple>>> ReactiveZSetCommands.zRandMemberWithScore(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRandMemberCommand> commands) keyでソートされたセットからランダムな要素を取得します。reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZRangeCommand,reactor.core.publisher.Flux<Tuple>>> ReactiveZSetCommands.zRange(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRangeCommand> commands) ソートされたセットから範囲内のTupleのセットを取得します。reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZRangeByLexCommand,reactor.core.publisher.Flux<ByteBufferSE>>> ReactiveZSetCommands.zRangeByLex(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRangeByLexCommand> commands) 辞書式順序のキーでソートされたセットからRangeのすべての要素を取得します。reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZRangeByScoreCommand,reactor.core.publisher.Flux<Tuple>>> ReactiveZSetCommands.zRangeByScore(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRangeByScoreCommand> commands) ソートされたセットから範囲内のTupleを取得します。reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZRangeStoreCommand,reactor.core.publisher.Mono<LongSE>>> ReactiveZSetCommands.zRangeStore(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRangeStoreCommand> commands) ソートされたセットから範囲内のTupleのセットを取得します。reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,reactor.core.publisher.Flux<Tuple>>> ReactiveZSetCommands.zScan(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyScanCommand> commands) Fluxを使用して、keyでソートされたセットのメンバーを反復処理します。reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZAggregateCommand,reactor.core.publisher.Flux<ByteBufferSE>>> ReactiveZSetCommands.zUnion(org.reactivestreams.Publisher<? extends ReactiveZSetCommands.ZAggregateCommand> commands) aggregateFunction を適用してソートされたセットを結合し、個々のセットに重みを適用します。reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZAggregateCommand,reactor.core.publisher.Flux<Tuple>>> ReactiveZSetCommands.zUnionWithScores(org.reactivestreams.Publisher<? extends ReactiveZSetCommands.ZAggregateCommand> commands) aggregateFunction を適用してソートされたセットを結合し、個々のセットに重みを適用します。