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
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveStringCommands.AppendCommand,Long>>	ReactiveStringCommands.append(org.reactivestreams.Publisher<ReactiveStringCommands.AppendCommand> commands)	Append a ReactiveStringCommands.AppendCommand.getValue() to the ReactiveRedisConnection.KeyCommand.getKey().
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 given bit 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)	Add RedisGeoCommands.GeoLocations to key.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveGeoCommands.GeoSearchStoreCommand,Long>>	ReactiveGeoCommands.geoSearchStore(org.reactivestreams.Publisher<ReactiveGeoCommands.GeoSearchStoreCommand> commands)	Store the members within given GeoShape from GeoReference 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 with field.
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)	Insert ReactiveListCommands.LInsertCommand.getValue() RedisListCommands.Position.BEFORE or RedisListCommands.Position.AFTER existing ReactiveListCommands.LInsertCommand.getPivot() for ReactiveRedisConnection.KeyCommand.getKey()
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>>	ReactiveListCommands.lLen(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands)	Get the size of list stored at ReactiveRedisConnection.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 at ReactiveRedisConnection.KeyCommand.getKey().
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveListCommands.LRemCommand,Long>>	ReactiveListCommands.lRem(org.reactivestreams.Publisher<ReactiveListCommands.LRemCommand> commands)	Removes the ReactiveListCommands.LRemCommand.getCount() occurrences of ReactiveListCommands.LRemCommand.getValue() from the list stored at ReactiveRedisConnection.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 the keys 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)	Prepend ReactiveListCommands.PushCommand.getValues() to ReactiveRedisConnection.KeyCommand.getKey().
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SAddCommand,Long>>	ReactiveSetCommands.sAdd(org.reactivestreams.Publisher<ReactiveSetCommands.SAddCommand> commands)	Add given ReactiveSetCommands.SAddCommand.getValues() to set at ReactiveRedisConnection.KeyCommand.getKey().
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>>	ReactiveSetCommands.sCard(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands)	Get size of set at ReactiveRedisConnection.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 of ReactiveRedisConnection.KeyCommand.key starting at the specified offset with given ReactiveStringCommands.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 given ReactiveSetCommands.SRemCommand.getValues() from set at ReactiveRedisConnection.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 given key(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 the key 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 at ReactiveRedisConnection.KeyCommand.getKey()
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>>	ReactiveStreamCommands.xTrim(org.reactivestreams.Publisher<ReactiveStreamCommands.TrimCommand> commands)	Trims the stream to count elements.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZAddCommand,Number>>	ReactiveZSetCommands.zAdd(org.reactivestreams.Publisher<ReactiveZSetCommands.ZAddCommand> commands)	Add ReactiveZSetCommands.ZAddCommand.getTuples() to a sorted set at ReactiveRedisConnection.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 within Range.
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 with ReactiveZSetCommands.ZIncrByCommand.getValue() in sorted set by ReactiveZSetCommands.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 between Range#min and Range#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 by ReactiveZSetCommands.ZRankCommand.getDirection().
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZRemCommand,Long>>	ReactiveZSetCommands.zRem(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRemCommand> commands)	Remove ReactiveZSetCommands.ZRemCommand.getValues() from sorted set.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZRemRangeByLexCommand,Long>>	ReactiveZSetCommands.zRemRangeByLex(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRemRangeByLexCommand> commands)	Remove elements in Range from sorted set with ReactiveRedisConnection.KeyCommand.getKey().
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZRemRangeByRankCommand,Long>>	ReactiveZSetCommands.zRemRangeByRank(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRemRangeByRankCommand> commands)	Remove elements in Range from sorted set with ReactiveRedisConnection.KeyCommand.getKey().
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZRemRangeByScoreCommand,Long>>	ReactiveZSetCommands.zRemRangeByScore(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRemRangeByScoreCommand> commands)	Remove elements in Range from sorted set with ReactiveRedisConnection.KeyCommand.getKey().
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZScoreCommand,Double>>	ReactiveZSetCommands.zScore(org.reactivestreams.Publisher<ReactiveZSetCommands.ZScoreCommand> commands)	Get the score of element with ReactiveZSetCommands.ZScoreCommand.getValue() from sorted set with key ReactiveRedisConnection.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.