Uses of Class
org.springframework.data.redis.connection.ReactiveRedisConnection.NumericResponse
Package
Description
Connection package providing low-level abstractions for interacting with the various Redis 'drivers'/libraries.
-
Uses of ReactiveRedisConnection.NumericResponse in org.springframework.data.redis.connection
Modifier and TypeMethodDescriptionreactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveStringCommands.AppendCommand,
Long>> ReactiveStringCommands.append
(org.reactivestreams.Publisher<ReactiveStringCommands.AppendCommand> commands) reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveStringCommands.BitCountCommand,
Long>> ReactiveStringCommands.bitCount
(org.reactivestreams.Publisher<ReactiveStringCommands.BitCountCommand> commands) Count the number of set bits (population counting) of value stored at key between start and end.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveStringCommands.BitOpCommand,
Long>> ReactiveStringCommands.bitOp
(org.reactivestreams.Publisher<ReactiveStringCommands.BitOpCommand> commands) Perform bitwise operations between strings.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveStringCommands.BitPosCommand,
Long>> ReactiveStringCommands.bitPos
(org.reactivestreams.Publisher<ReactiveStringCommands.BitPosCommand> commands) Emmit the the position of the first bit set to givenbit
in a string.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,
Long>> ReactiveNumberCommands.decr
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> keys) Decrement value of key by 1.<T extends Number>
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveNumberCommands.DecrByCommand<T>,T>> ReactiveNumberCommands.decrBy
(org.reactivestreams.Publisher<ReactiveNumberCommands.DecrByCommand<T>> commands) Decrement value of key by value.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,
Long>> ReactiveKeyCommands.del
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> keys) Delete keys one by one.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveGeoCommands.GeoAddCommand,
Long>> ReactiveGeoCommands.geoAdd
(org.reactivestreams.Publisher<ReactiveGeoCommands.GeoAddCommand> commands) AddRedisGeoCommands.GeoLocation
s to key.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveGeoCommands.GeoSearchStoreCommand,
Long>> ReactiveGeoCommands.geoSearchStore
(org.reactivestreams.Publisher<ReactiveGeoCommands.GeoSearchStoreCommand> commands) Store the members within givenGeoShape
fromGeoReference
applying given parameters in a new geo set.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveHashCommands.HDelCommand,
Long>> ReactiveHashCommands.hDel
(org.reactivestreams.Publisher<ReactiveHashCommands.HDelCommand> commands) Delete given hash fields.<T extends Number>
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveNumberCommands.HIncrByCommand<T>,T>> ReactiveNumberCommands.hIncrBy
(org.reactivestreams.Publisher<ReactiveNumberCommands.HIncrByCommand<T>> commands) Increment value of a hash field by the given value.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,
Long>> ReactiveHashCommands.hLen
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Get size of hash at key.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveHashCommands.HStrLenCommand,
Long>> ReactiveHashCommands.hStrLen
(org.reactivestreams.Publisher<ReactiveHashCommands.HStrLenCommand> commands) Get the length of the value associated withfield
.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,
Long>> ReactiveNumberCommands.incr
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> keys) Increment value of key by 1.<T extends Number>
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveNumberCommands.IncrByCommand<T>,T>> ReactiveNumberCommands.incrBy
(org.reactivestreams.Publisher<ReactiveNumberCommands.IncrByCommand<T>> commands) Increment value of key by value.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveListCommands.LInsertCommand,
Long>> ReactiveListCommands.lInsert
(org.reactivestreams.Publisher<ReactiveListCommands.LInsertCommand> commands) reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,
Long>> ReactiveListCommands.lLen
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Get the size of list stored atReactiveRedisConnection.KeyCommand.getKey()
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveListCommands.LPosCommand,
Long>> ReactiveListCommands.lPos
(org.reactivestreams.Publisher<ReactiveListCommands.LPosCommand> commands) Get indices of the element from list atReactiveRedisConnection.KeyCommand.getKey()
.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveListCommands.LRemCommand,
Long>> ReactiveListCommands.lRem
(org.reactivestreams.Publisher<ReactiveListCommands.LRemCommand> commands) Removes theReactiveListCommands.LRemCommand.getCount()
occurrences ofReactiveListCommands.LRemCommand.getValue()
from the list stored atReactiveRedisConnection.KeyCommand.getKey()
.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<List<ByteBuffer>,
Long>> ReactiveKeyCommands.mDel
(org.reactivestreams.Publisher<List<ByteBuffer>> keys) Delete multiple keys in batches.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<List<ByteBuffer>,
Long>> ReactiveKeyCommands.mUnlink
(org.reactivestreams.Publisher<List<ByteBuffer>> keys) Unlink thekeys
from the keyspace.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveHyperLogLogCommands.PfAddCommand,
Long>> ReactiveHyperLogLogCommands.pfAdd
(org.reactivestreams.Publisher<ReactiveHyperLogLogCommands.PfAddCommand> commands) Adds given values to the HyperLogLog stored at given key.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveHyperLogLogCommands.PfCountCommand,
Long>> ReactiveHyperLogLogCommands.pfCount
(org.reactivestreams.Publisher<ReactiveHyperLogLogCommands.PfCountCommand> commands) Return the approximated cardinality of the structures observed by the HyperLogLog at key(s).reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,
Long>> ReactiveKeyCommands.pTtl
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Get one-by-one the time to live for keys.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveListCommands.PushCommand,
Long>> ReactiveListCommands.push
(org.reactivestreams.Publisher<ReactiveListCommands.PushCommand> commands) reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SAddCommand,
Long>> ReactiveSetCommands.sAdd
(org.reactivestreams.Publisher<ReactiveSetCommands.SAddCommand> commands) Add givenReactiveSetCommands.SAddCommand.getValues()
to set atReactiveRedisConnection.KeyCommand.getKey()
.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,
Long>> ReactiveSetCommands.sCard
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Get size of set atReactiveRedisConnection.KeyCommand.getKey()
.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SDiffStoreCommand,
Long>> ReactiveSetCommands.sDiffStore
(org.reactivestreams.Publisher<ReactiveSetCommands.SDiffStoreCommand> commands) Diff all given sets at keys and store result in destinationKey.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveStringCommands.SetRangeCommand,
Long>> ReactiveStringCommands.setRange
(org.reactivestreams.Publisher<ReactiveStringCommands.SetRangeCommand> commands) Overwrite parts ofReactiveRedisConnection.KeyCommand.key
starting at the specified offset with givenReactiveStringCommands.SetRangeCommand.value
.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SInterStoreCommand,
Long>> ReactiveSetCommands.sInterStore
(org.reactivestreams.Publisher<ReactiveSetCommands.SInterStoreCommand> commands) Intersect all given sets at keys and store result in destinationKey.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SRemCommand,
Long>> ReactiveSetCommands.sRem
(org.reactivestreams.Publisher<ReactiveSetCommands.SRemCommand> commands) Remove givenReactiveSetCommands.SRemCommand.getValues()
from set atReactiveRedisConnection.KeyCommand.getKey()
.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,
Long>> ReactiveStringCommands.strLen
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> keys) Get the length of the value stored at key.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SUnionStoreCommand,
Long>> ReactiveSetCommands.sUnionStore
(org.reactivestreams.Publisher<ReactiveSetCommands.SUnionStoreCommand> commands) Union all given sets at keys and store result in destinationKey.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<Collection<ByteBuffer>,
Long>> ReactiveKeyCommands.touch
(org.reactivestreams.Publisher<Collection<ByteBuffer>> keys) Alter the last access time of givenkey(s)
.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,
Long>> ReactiveKeyCommands.ttl
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Get one-by-one the time to live for keys.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,
Long>> ReactiveKeyCommands.unlink
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> keys) Unlink thekey
from the keyspace.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveStreamCommands.AcknowledgeCommand,
Long>> ReactiveStreamCommands.xAck
(org.reactivestreams.Publisher<ReactiveStreamCommands.AcknowledgeCommand> commands) Acknowledge one or more records as processed.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,
Long>> ReactiveStreamCommands.xLen
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Get the size of the stream stored atReactiveRedisConnection.KeyCommand.getKey()
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,
Long>> ReactiveStreamCommands.xTrim
(org.reactivestreams.Publisher<ReactiveStreamCommands.TrimCommand> commands) Trims the stream tocount
elements.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZAddCommand,
Number>> ReactiveZSetCommands.zAdd
(org.reactivestreams.Publisher<ReactiveZSetCommands.ZAddCommand> commands) AddReactiveZSetCommands.ZAddCommand.getTuples()
to a sorted set atReactiveRedisConnection.KeyCommand.getKey()
, or update its score if it already exists.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,
Long>> ReactiveZSetCommands.zCard
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Get the size of sorted set with .reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZCountCommand,
Long>> ReactiveZSetCommands.zCount
(org.reactivestreams.Publisher<ReactiveZSetCommands.ZCountCommand> commands) Count number of elements within sorted set with scores withinRange
.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZDiffStoreCommand,
Long>> ReactiveZSetCommands.zDiffStore
(org.reactivestreams.Publisher<ReactiveZSetCommands.ZDiffStoreCommand> commands) Diff sorted sets and store result in destination destinationKey.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZIncrByCommand,
Double>> ReactiveZSetCommands.zIncrBy
(org.reactivestreams.Publisher<ReactiveZSetCommands.ZIncrByCommand> commands) Increment the score of element withReactiveZSetCommands.ZIncrByCommand.getValue()
in sorted set byReactiveZSetCommands.ZIncrByCommand.getIncrement()
.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZAggregateStoreCommand,
Long>> ReactiveZSetCommands.zInterStore
(org.reactivestreams.Publisher<? extends ReactiveZSetCommands.ZAggregateStoreCommand> commands) Intersect sorted sets by applying aggregateFunction and store result in destination destinationKey and apply weights to individual sets.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZLexCountCommand,
Long>> ReactiveZSetCommands.zLexCount
(org.reactivestreams.Publisher<ReactiveZSetCommands.ZLexCountCommand> commands) Count number of elements within sorted set with value betweenRange#min
andRange#max
applying lexicographical ordering.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZRankCommand,
Long>> ReactiveZSetCommands.zRank
(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRankCommand> commands) Determine the index of element with value in a sorted set when scored byReactiveZSetCommands.ZRankCommand.getDirection()
.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZRemCommand,
Long>> ReactiveZSetCommands.zRem
(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRemCommand> commands) RemoveReactiveZSetCommands.ZRemCommand.getValues()
from sorted set.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZRemRangeByLexCommand,
Long>> ReactiveZSetCommands.zRemRangeByLex
(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRemRangeByLexCommand> commands) Remove elements inRange
from sorted set withReactiveRedisConnection.KeyCommand.getKey()
.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZRemRangeByRankCommand,
Long>> ReactiveZSetCommands.zRemRangeByRank
(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRemRangeByRankCommand> commands) Remove elements inRange
from sorted set withReactiveRedisConnection.KeyCommand.getKey()
.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZRemRangeByScoreCommand,
Long>> ReactiveZSetCommands.zRemRangeByScore
(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRemRangeByScoreCommand> commands) Remove elements inRange
from sorted set withReactiveRedisConnection.KeyCommand.getKey()
.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZScoreCommand,
Double>> ReactiveZSetCommands.zScore
(org.reactivestreams.Publisher<ReactiveZSetCommands.ZScoreCommand> commands) Get the score of element withReactiveZSetCommands.ZScoreCommand.getValue()
from sorted set with keyReactiveRedisConnection.KeyCommand.getKey()
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZAggregateStoreCommand,
Long>> ReactiveZSetCommands.zUnionStore
(org.reactivestreams.Publisher<? extends ReactiveZSetCommands.ZAggregateStoreCommand> commands) Union sorted sets by applying aggregateFunction and store result in destination destinationKey and apply weights to individual sets.