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