Uses of Class
org.springframework.data.redis.connection.ReactiveRedisConnection.NumericResponse

Packages that use ReactiveRedisConnection.NumericResponse

Package	Description
org.springframework.data.redis.connection	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.NumericResponse

Modifier and Type	Method	Description
Flux<ReactiveRedisConnection.NumericResponse<ReactiveStringCommands.AppendCommand,Long>>	ReactiveStringCommands.append(Publisher<ReactiveStringCommands.AppendCommand> commands)	Append a ReactiveStringCommands.AppendCommand.getValue() to the ReactiveRedisConnection.KeyCommand.getKey().
Flux<ReactiveRedisConnection.NumericResponse<ReactiveHashCommands.HashExpireCommand,Long>>	ReactiveHashCommands.applyHashFieldExpiration(Publisher<ReactiveHashCommands.HashExpireCommand> commands)	Expire a List of field after a given Duration of time, measured in milliseconds, has passed.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveStringCommands.BitCountCommand,Long>>	ReactiveStringCommands.bitCount(Publisher<ReactiveStringCommands.BitCountCommand> commands)	Count the number of set bits (population counting) of value stored at key between start and end.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveStringCommands.BitOpCommand,Long>>	ReactiveStringCommands.bitOp(Publisher<ReactiveStringCommands.BitOpCommand> commands)	Perform bitwise operations between strings.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveStringCommands.BitPosCommand,Long>>	ReactiveStringCommands.bitPos(Publisher<ReactiveStringCommands.BitPosCommand> commands)	Emmit the the position of the first bit set to given bit in a string.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>>	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.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>>	ReactiveKeyCommands.del(Publisher<ReactiveRedisConnection.KeyCommand> keys)	Delete keys one by one.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveGeoCommands.GeoAddCommand,Long>>	ReactiveGeoCommands.geoAdd(Publisher<ReactiveGeoCommands.GeoAddCommand> commands)	Add RedisGeoCommands.GeoLocations to key.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveGeoCommands.GeoSearchStoreCommand,Long>>	ReactiveGeoCommands.geoSearchStore(Publisher<ReactiveGeoCommands.GeoSearchStoreCommand> commands)	Store the members within given GeoShape from GeoReference applying given parameters in a new geo set.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveHashCommands.HDelCommand,Long>>	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.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>>	ReactiveHashCommands.hLen(Publisher<ReactiveRedisConnection.KeyCommand> commands)	Get size of hash at key.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveHashCommands.HashFieldsCommand,Long>>	ReactiveHashCommands.hPersist(Publisher<ReactiveHashCommands.HashFieldsCommand> commands)	Persist a given List of field removing any associated expiration.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveHashCommands.HashFieldsCommand,Long>>	ReactiveHashCommands.hpTtl(Publisher<ReactiveHashCommands.HashFieldsCommand> commands)	Returns the time-to-live of all the given field in the List in milliseconds.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveHashCommands.HStrLenCommand,Long>>	ReactiveHashCommands.hStrLen(Publisher<ReactiveHashCommands.HStrLenCommand> commands)	Get the length of the value associated with field.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveHashCommands.HashFieldsCommand,Long>>	ReactiveHashCommands.hTtl(Publisher<ReactiveHashCommands.HashFieldsCommand> commands)	Returns the time-to-live of all the given field in the List in seconds.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>>	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.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveListCommands.LInsertCommand,Long>>	ReactiveListCommands.lInsert(Publisher<ReactiveListCommands.LInsertCommand> commands)	Insert ReactiveListCommands.LInsertCommand.getValue() RedisListCommands.Position.BEFORE or RedisListCommands.Position.AFTER existing ReactiveListCommands.LInsertCommand.getPivot() for ReactiveRedisConnection.KeyCommand.getKey()
Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>>	ReactiveListCommands.lLen(Publisher<ReactiveRedisConnection.KeyCommand> commands)	Get the size of list stored at ReactiveRedisConnection.KeyCommand.getKey()
Flux<ReactiveRedisConnection.NumericResponse<ReactiveListCommands.LPosCommand,Long>>	ReactiveListCommands.lPos(Publisher<ReactiveListCommands.LPosCommand> commands)	Get indices of the element from list at ReactiveRedisConnection.KeyCommand.getKey().
Flux<ReactiveRedisConnection.NumericResponse<ReactiveListCommands.LRemCommand,Long>>	ReactiveListCommands.lRem(Publisher<ReactiveListCommands.LRemCommand> commands)	Removes the ReactiveListCommands.LRemCommand.getCount() occurrences of ReactiveListCommands.LRemCommand.getValue() from the list stored at ReactiveRedisConnection.KeyCommand.getKey().
Flux<ReactiveRedisConnection.NumericResponse<List<ByteBuffer>,Long>>	ReactiveKeyCommands.mDel(Publisher<List<ByteBuffer>> keys)	Delete multiple keys in batches.
Flux<ReactiveRedisConnection.NumericResponse<List<ByteBuffer>,Long>>	ReactiveKeyCommands.mUnlink(Publisher<List<ByteBuffer>> keys)	Unlink the keys from the keyspace.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveHyperLogLogCommands.PfAddCommand,Long>>	ReactiveHyperLogLogCommands.pfAdd(Publisher<ReactiveHyperLogLogCommands.PfAddCommand> commands)	Adds given values to the HyperLogLog stored at given key.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveHyperLogLogCommands.PfCountCommand,Long>>	ReactiveHyperLogLogCommands.pfCount(Publisher<ReactiveHyperLogLogCommands.PfCountCommand> commands)	Return the approximated cardinality of the structures observed by the HyperLogLog at key(s).
Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>>	ReactiveKeyCommands.pTtl(Publisher<ReactiveRedisConnection.KeyCommand> commands)	Get one-by-one the time to live for keys.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveListCommands.PushCommand,Long>>	ReactiveListCommands.push(Publisher<ReactiveListCommands.PushCommand> commands)	Prepend ReactiveListCommands.PushCommand.getValues() to ReactiveRedisConnection.KeyCommand.getKey().
Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SAddCommand,Long>>	ReactiveSetCommands.sAdd(Publisher<ReactiveSetCommands.SAddCommand> commands)	Add given ReactiveSetCommands.SAddCommand.getValues() to set at ReactiveRedisConnection.KeyCommand.getKey().
Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>>	ReactiveSetCommands.sCard(Publisher<ReactiveRedisConnection.KeyCommand> commands)	Get size of set at ReactiveRedisConnection.KeyCommand.getKey().
Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SDiffStoreCommand,Long>>	ReactiveSetCommands.sDiffStore(Publisher<ReactiveSetCommands.SDiffStoreCommand> commands)	Diff all given sets at keys and store result in destinationKey.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveStringCommands.SetRangeCommand,Long>>	ReactiveStringCommands.setRange(Publisher<ReactiveStringCommands.SetRangeCommand> commands)	Overwrite parts of ReactiveRedisConnection.KeyCommand.key starting at the specified offset with given ReactiveStringCommands.SetRangeCommand.value.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SInterStoreCommand,Long>>	ReactiveSetCommands.sInterStore(Publisher<ReactiveSetCommands.SInterStoreCommand> commands)	Intersect all given sets at keys and store result in destinationKey.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SRemCommand,Long>>	ReactiveSetCommands.sRem(Publisher<ReactiveSetCommands.SRemCommand> commands)	Remove given ReactiveSetCommands.SRemCommand.getValues() from set at ReactiveRedisConnection.KeyCommand.getKey().
Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>>	ReactiveStringCommands.strLen(Publisher<ReactiveRedisConnection.KeyCommand> keys)	Get the length of the value stored at key.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SUnionStoreCommand,Long>>	ReactiveSetCommands.sUnionStore(Publisher<ReactiveSetCommands.SUnionStoreCommand> commands)	Union all given sets at keys and store result in destinationKey.
Flux<ReactiveRedisConnection.NumericResponse<Collection<ByteBuffer>,Long>>	ReactiveKeyCommands.touch(Publisher<Collection<ByteBuffer>> keys)	Alter the last access time of given key(s).
Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>>	ReactiveKeyCommands.ttl(Publisher<ReactiveRedisConnection.KeyCommand> commands)	Get one-by-one the time to live for keys.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>>	ReactiveKeyCommands.unlink(Publisher<ReactiveRedisConnection.KeyCommand> keys)	Unlink the key from the keyspace.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveStreamCommands.AcknowledgeCommand,Long>>	ReactiveStreamCommands.xAck(Publisher<ReactiveStreamCommands.AcknowledgeCommand> commands)	Acknowledge one or more records as processed.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>>	ReactiveStreamCommands.xLen(Publisher<ReactiveRedisConnection.KeyCommand> commands)	Get the size of the stream stored at ReactiveRedisConnection.KeyCommand.getKey()
Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>>	ReactiveStreamCommands.xTrim(Publisher<ReactiveStreamCommands.TrimCommand> commands)	Trims the stream to count elements.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZAddCommand,Number>>	ReactiveZSetCommands.zAdd(Publisher<ReactiveZSetCommands.ZAddCommand> commands)	Add ReactiveZSetCommands.ZAddCommand.getTuples() to a sorted set at ReactiveRedisConnection.KeyCommand.getKey(), or update its score if it already exists.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>>	ReactiveZSetCommands.zCard(Publisher<ReactiveRedisConnection.KeyCommand> commands)	Get the size of sorted set with keyCommand#getKey().
Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZCountCommand,Long>>	ReactiveZSetCommands.zCount(Publisher<ReactiveZSetCommands.ZCountCommand> commands)	Count number of elements within sorted set with scores within Range.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZDiffStoreCommand,Long>>	ReactiveZSetCommands.zDiffStore(Publisher<ReactiveZSetCommands.ZDiffStoreCommand> commands)	Diff sorted sets and store result in destination destinationKey.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZIncrByCommand,Double>>	ReactiveZSetCommands.zIncrBy(Publisher<ReactiveZSetCommands.ZIncrByCommand> commands)	Increment the score of element with ReactiveZSetCommands.ZIncrByCommand.getValue() in sorted set by ReactiveZSetCommands.ZIncrByCommand.getIncrement().
Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZAggregateStoreCommand,Long>>	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.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZLexCountCommand,Long>>	ReactiveZSetCommands.zLexCount(Publisher<ReactiveZSetCommands.ZLexCountCommand> commands)	Count number of elements within sorted set with value between Range#min and Range#max applying lexicographical ordering.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZRankCommand,Long>>	ReactiveZSetCommands.zRank(Publisher<ReactiveZSetCommands.ZRankCommand> commands)	Determine the index of element with value in a sorted set when scored by ReactiveZSetCommands.ZRankCommand.getDirection().
Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZRemCommand,Long>>	ReactiveZSetCommands.zRem(Publisher<ReactiveZSetCommands.ZRemCommand> commands)	Remove ReactiveZSetCommands.ZRemCommand.getValues() from sorted set.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZRemRangeByLexCommand,Long>>	ReactiveZSetCommands.zRemRangeByLex(Publisher<ReactiveZSetCommands.ZRemRangeByLexCommand> commands)	Remove elements in Range from sorted set with ReactiveRedisConnection.KeyCommand.getKey().
Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZRemRangeByRankCommand,Long>>	ReactiveZSetCommands.zRemRangeByRank(Publisher<ReactiveZSetCommands.ZRemRangeByRankCommand> commands)	Remove elements in Range from sorted set with ReactiveRedisConnection.KeyCommand.getKey().
Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZRemRangeByScoreCommand,Long>>	ReactiveZSetCommands.zRemRangeByScore(Publisher<ReactiveZSetCommands.ZRemRangeByScoreCommand> commands)	Remove elements in Range from sorted set with ReactiveRedisConnection.KeyCommand.getKey().
Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZScoreCommand,Double>>	ReactiveZSetCommands.zScore(Publisher<ReactiveZSetCommands.ZScoreCommand> commands)	Get the score of element with ReactiveZSetCommands.ZScoreCommand.getValue() from sorted set with key ReactiveRedisConnection.KeyCommand.getKey()
Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZAggregateStoreCommand,Long>>	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.