クラスの使用
org.springframework.data.redis.connection.ReactiveRedisConnection.NumericResponse
ReactiveRedisConnection.NumericResponse を使用するパッケージ
パッケージ
説明
さまざまな Redis ' ドライバー '/libraries と対話するための低レベルの抽象化を提供する接続パッケージ。
org.springframework.data.redis.connection 内の ReactiveRedisConnection.NumericResponse 使用
型 ReactiveRedisConnection.NumericResponse の引数を持つ型を返す org.springframework.data.redis.connection のメソッド修飾子と型メソッド説明reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveStringCommands.AppendCommand,LongSE>> ReactiveStringCommands.append(org.reactivestreams.Publisher<ReactiveStringCommands.AppendCommand> commands) reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveStringCommands.BitCountCommand,LongSE>> ReactiveStringCommands.bitCount(org.reactivestreams.Publisher<ReactiveStringCommands.BitCountCommand> commands) キーに格納されている値の開始ビットと終了ビットのセットビット数（ポピュレーションカウント）をカウントします。reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveStringCommands.BitOpCommand,LongSE>> ReactiveStringCommands.bitOp(org.reactivestreams.Publisher<ReactiveStringCommands.BitOpCommand> commands) 文字列間でビット演算を実行します。reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveStringCommands.BitPosCommand,LongSE>> ReactiveStringCommands.bitPos(org.reactivestreams.Publisher<ReactiveStringCommands.BitPosCommand> commands) 文字列内の指定されたbitに設定された最初のビットの位置を出力します。reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,LongSE>> ReactiveNumberCommands.decr(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> keys) キーの値を 1 デクリメントします。<T extends NumberSE>
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveNumberCommands.DecrByCommand<T>,T>> ReactiveNumberCommands.decrBy(org.reactivestreams.Publisher<ReactiveNumberCommands.DecrByCommand<T>> commands) キーの値を値でデクリメントします。reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,LongSE>> ReactiveKeyCommands.del(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> keys) キーを 1 つずつ削除します。reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveGeoCommands.GeoAddCommand,LongSE>> ReactiveGeoCommands.geoAdd(org.reactivestreams.Publisher<ReactiveGeoCommands.GeoAddCommand> commands) キーにRedisGeoCommands.GeoLocationを追加します。reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveGeoCommands.GeoSearchStoreCommand,LongSE>> ReactiveGeoCommands.geoSearchStore(org.reactivestreams.Publisher<ReactiveGeoCommands.GeoSearchStoreCommand> commands) 新しいジオセットに指定されたパラメーターを適用して、GeoReferenceから指定されたGeoShape内にメンバーを格納します。reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveHashCommands.HDelCommand,LongSE>> ReactiveHashCommands.hDel(org.reactivestreams.Publisher<ReactiveHashCommands.HDelCommand> commands) 指定されたハッシュフィールドを削除します。<T extends NumberSE>
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveNumberCommands.HIncrByCommand<T>,T>> ReactiveNumberCommands.hIncrBy(org.reactivestreams.Publisher<ReactiveNumberCommands.HIncrByCommand<T>> commands) ハッシュフィールドの値を指定された値だけインクリメントします。reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,LongSE>> ReactiveHashCommands.hLen(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) キーでハッシュのサイズを取得します。reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveHashCommands.HStrLenCommand,LongSE>> ReactiveHashCommands.hStrLen(org.reactivestreams.Publisher<ReactiveHashCommands.HStrLenCommand> commands) fieldに関連付けられた値の長さを取得します。reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,LongSE>> ReactiveNumberCommands.incr(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> keys) キーの値を 1 インクリメントします。<T extends NumberSE>
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveNumberCommands.IncrByCommand<T>,T>> ReactiveNumberCommands.incrBy(org.reactivestreams.Publisher<ReactiveNumberCommands.IncrByCommand<T>> commands) キーの値を値でインクリメントします。reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveListCommands.LInsertCommand,LongSE>> ReactiveListCommands.lInsert(org.reactivestreams.Publisher<ReactiveListCommands.LInsertCommand> commands) reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,LongSE>> ReactiveListCommands.lLen(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) ReactiveRedisConnection.KeyCommand.getKey()に保存されているリストのサイズを取得しますreactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveListCommands.LPosCommand,LongSE>> ReactiveListCommands.lPos(org.reactivestreams.Publisher<ReactiveListCommands.LPosCommand> commands) ReactiveRedisConnection.KeyCommand.getKey()のリストから要素のインデックスを取得します。reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveListCommands.LRemCommand,LongSE>> ReactiveListCommands.lRem(org.reactivestreams.Publisher<ReactiveListCommands.LRemCommand> commands) reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ListSE<ByteBufferSE>,LongSE>> ReactiveKeyCommands.mDel(org.reactivestreams.Publisher<ListSE<ByteBufferSE>> keys) 複数のキーをまとめて削除します。reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ListSE<ByteBufferSE>,LongSE>> ReactiveKeyCommands.mUnlink(org.reactivestreams.Publisher<ListSE<ByteBufferSE>> keys) キースペースからkeysのリンクを解除します。reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveHyperLogLogCommands.PfAddCommand,LongSE>> ReactiveHyperLogLogCommands.pfAdd(org.reactivestreams.Publisher<ReactiveHyperLogLogCommands.PfAddCommand> commands) 指定されたキーに格納されている HyperLogLog に指定された値を追加します。reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveHyperLogLogCommands.PfCountCommand,LongSE>> ReactiveHyperLogLogCommands.pfCount(org.reactivestreams.Publisher<ReactiveHyperLogLogCommands.PfCountCommand> commands) キーで HyperLogLog によって観測された構造の近似カーディナリティを返します。reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,LongSE>> ReactiveKeyCommands.pTtl(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) キーのために生きる時間を 1 つずつ取得します。reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveListCommands.PushCommand,LongSE>> ReactiveListCommands.push(org.reactivestreams.Publisher<ReactiveListCommands.PushCommand> commands) reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SAddCommand,LongSE>> ReactiveSetCommands.sAdd(org.reactivestreams.Publisher<ReactiveSetCommands.SAddCommand> commands) reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,LongSE>> ReactiveSetCommands.sCard(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) セットのサイズをReactiveRedisConnection.KeyCommand.getKey()で取得します。reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SDiffStoreCommand,LongSE>> ReactiveSetCommands.sDiffStore(org.reactivestreams.Publisher<ReactiveSetCommands.SDiffStoreCommand> commands) 指定されたすべてのセットをキーで比較し、結果を destinationKey に保存します。reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveStringCommands.SetRangeCommand,LongSE>> ReactiveStringCommands.setRange(org.reactivestreams.Publisher<ReactiveStringCommands.SetRangeCommand> commands) 指定されたReactiveStringCommands.SetRangeCommand.valueで、指定されたオフセットから始まるReactiveRedisConnection.KeyCommand.keyの部分を上書きします。reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SInterStoreCommand,LongSE>> ReactiveSetCommands.sInterStore(org.reactivestreams.Publisher<ReactiveSetCommands.SInterStoreCommand> commands) 指定されたすべてのセットをキーで交差させ、結果を destinationKey に保存します。reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SRemCommand,LongSE>> ReactiveSetCommands.sRem(org.reactivestreams.Publisher<ReactiveSetCommands.SRemCommand> commands) 指定されたReactiveSetCommands.SRemCommand.getValues()をReactiveRedisConnection.KeyCommand.getKey()のセットから削除します。reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,LongSE>> ReactiveStringCommands.strLen(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> keys) key に格納されている値の長さを取得します。reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SUnionStoreCommand,LongSE>> ReactiveSetCommands.sUnionStore(org.reactivestreams.Publisher<ReactiveSetCommands.SUnionStoreCommand> commands) 指定されたすべてのセットをキーで結合し、結果を destinationKey に格納します。reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<CollectionSE<ByteBufferSE>,LongSE>> ReactiveKeyCommands.touch(org.reactivestreams.Publisher<CollectionSE<ByteBufferSE>> keys) 指定されたkey(s)の最終アクセス時間を変更します。reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,LongSE>> ReactiveKeyCommands.ttl(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) キーのために生きる時間を 1 つずつ取得します。reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,LongSE>> ReactiveKeyCommands.unlink(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> keys) キースペースからkeyのリンクを解除します。reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveStreamCommands.AcknowledgeCommand,LongSE>> ReactiveStreamCommands.xAck(org.reactivestreams.Publisher<ReactiveStreamCommands.AcknowledgeCommand> commands) 1 つ以上のレコードを処理済みとして確認します。reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,LongSE>> ReactiveStreamCommands.xLen(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) ReactiveRedisConnection.KeyCommand.getKey()に保存されているストリームのサイズを取得しますreactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,LongSE>> ReactiveStreamCommands.xTrim(org.reactivestreams.Publisher<ReactiveStreamCommands.TrimCommand> commands) ストリームをcount要素にトリミングします。reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZAddCommand,NumberSE>> ReactiveZSetCommands.zAdd(org.reactivestreams.Publisher<ReactiveZSetCommands.ZAddCommand> commands) ReactiveZSetCommands.ZAddCommand.getTuples()をReactiveRedisConnection.KeyCommand.getKey()でソートされたセットに追加するか、スコアがすでに存在する場合はそのスコアを更新します。reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,LongSE>> ReactiveZSetCommands.zCard(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) でソートされたセットのサイズを取得します。reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZCountCommand,LongSE>> ReactiveZSetCommands.zCount(org.reactivestreams.Publisher<ReactiveZSetCommands.ZCountCommand> commands) Range内のスコアで、ソートされたセット内の要素の数をカウントします。reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZDiffStoreCommand,LongSE>> ReactiveZSetCommands.zDiffStore(org.reactivestreams.Publisher<ReactiveZSetCommands.ZDiffStoreCommand> commands) ソートされたセットを比較し、結果を宛先 destinationKey に保存します。reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZIncrByCommand,DoubleSE>> ReactiveZSetCommands.zIncrBy(org.reactivestreams.Publisher<ReactiveZSetCommands.ZIncrByCommand> commands) ReactiveZSetCommands.ZIncrByCommand.getIncrement()でソートされたセットのReactiveZSetCommands.ZIncrByCommand.getValue()で要素のスコアをインクリメントします。reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZAggregateStoreCommand,LongSE>> ReactiveZSetCommands.zInterStore(org.reactivestreams.Publisher<? extends ReactiveZSetCommands.ZAggregateStoreCommand> commands) aggregateFunction を適用してソートされたセットを交差させ、結果を宛先 destinationKey に保存し、個々のセットに重みを適用します。reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZLexCountCommand,LongSE>> ReactiveZSetCommands.zLexCount(org.reactivestreams.Publisher<ReactiveZSetCommands.ZLexCountCommand> commands) 辞書式順序を適用して、Range#minとRange#maxの間の値でソートされたセット内の要素の数をカウントします。reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZRankCommand,LongSE>> ReactiveZSetCommands.zRank(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRankCommand> commands) ReactiveZSetCommands.ZRankCommand.getDirection()によってスコアリングされたときに、ソートされたセット内の値を持つ要素のインデックスを決定します。reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZRemCommand,LongSE>> ReactiveZSetCommands.zRem(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRemCommand> commands) ソートされたセットからReactiveZSetCommands.ZRemCommand.getValues()を削除します。reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZRemRangeByLexCommand,LongSE>> ReactiveZSetCommands.zRemRangeByLex(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRemRangeByLexCommand> commands) ReactiveRedisConnection.KeyCommand.getKey()でソートされたセットからRangeの要素を削除します。reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZRemRangeByRankCommand,LongSE>> ReactiveZSetCommands.zRemRangeByRank(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRemRangeByRankCommand> commands) ReactiveRedisConnection.KeyCommand.getKey()でソートされたセットからRangeの要素を削除します。reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZRemRangeByScoreCommand,LongSE>> ReactiveZSetCommands.zRemRangeByScore(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRemRangeByScoreCommand> commands) ReactiveRedisConnection.KeyCommand.getKey()でソートされたセットからRangeの要素を削除します。reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZScoreCommand,DoubleSE>> ReactiveZSetCommands.zScore(org.reactivestreams.Publisher<ReactiveZSetCommands.ZScoreCommand> commands) キーReactiveRedisConnection.KeyCommand.getKey()でソートされたセットからReactiveZSetCommands.ZScoreCommand.getValue()で要素のスコアを取得しますreactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZAggregateStoreCommand,LongSE>> ReactiveZSetCommands.zUnionStore(org.reactivestreams.Publisher<? extends ReactiveZSetCommands.ZAggregateStoreCommand> commands) aggregateFunction を適用してソートされたセットを結合し、結果を宛先 destinationKey に保存し、個々のセットに重みを適用します。