Uses of Class
org.springframework.data.redis.connection.ReactiveRedisConnection.BooleanResponse
Package
Description
Connection package providing low-level abstractions for interacting with the various Redis 'drivers'/libraries.
-
Uses of ReactiveRedisConnection.BooleanResponse in org.springframework.data.redis.connection
Modifier and TypeMethodDescriptionreactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveKeyCommands.CopyCommand>>
ReactiveKeyCommands.copy
(org.reactivestreams.Publisher<ReactiveKeyCommands.CopyCommand> commands) Copy keys one-by-one.reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveRedisConnection.KeyCommand>>
ReactiveKeyCommands.exists
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> keys) Determine if given key exists.reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveKeyCommands.ExpireCommand>>
ReactiveKeyCommands.expire
(org.reactivestreams.Publisher<ReactiveKeyCommands.ExpireCommand> commands) Expire keys one by one.reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveKeyCommands.ExpireAtCommand>>
ReactiveKeyCommands.expireAt
(org.reactivestreams.Publisher<ReactiveKeyCommands.ExpireAtCommand> commands) Set one-by-one the expiration for givenkey
as a UNIX timestamp.reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveStringCommands.GetBitCommand>>
ReactiveStringCommands.getBit
(org.reactivestreams.Publisher<ReactiveStringCommands.GetBitCommand> commands) Get the bit value at offset of value at key.reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveHashCommands.HExistsCommand>>
ReactiveHashCommands.hExists
(org.reactivestreams.Publisher<ReactiveHashCommands.HExistsCommand> commands) Determine if given hash field exists.reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveHashCommands.HSetCommand>>
ReactiveHashCommands.hSet
(org.reactivestreams.Publisher<ReactiveHashCommands.HSetCommand> commands) Set the value of a hash field.reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveListCommands.LSetCommand>>
ReactiveListCommands.lSet
(org.reactivestreams.Publisher<ReactiveListCommands.LSetCommand> commands) Set theReactiveListCommands.LSetCommand.getValue()
list element atReactiveRedisConnection.KeyCommand.getKey()
.reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveRedisConnection.RangeCommand>>
ReactiveListCommands.lTrim
(org.reactivestreams.Publisher<ReactiveRedisConnection.RangeCommand> commands) Trim list atReactiveRedisConnection.KeyCommand.getKey()
to elements withinReactiveRedisConnection.RangeCommand.getRange()
.reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveKeyCommands.MoveCommand>>
ReactiveKeyCommands.move
(org.reactivestreams.Publisher<ReactiveKeyCommands.MoveCommand> commands) Move keys one-by-one between databases.reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveStringCommands.MSetCommand>>
ReactiveStringCommands.mSet
(org.reactivestreams.Publisher<ReactiveStringCommands.MSetCommand> commands) Set multiple keys to multiple values using key-value pairs provided in commands.reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveStringCommands.MSetCommand>>
ReactiveStringCommands.mSetNX
(org.reactivestreams.Publisher<ReactiveStringCommands.MSetCommand> source) Set multiple keys to multiple values using key-value pairs provided in tuples only if the provided key does not exist.reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveRedisConnection.KeyCommand>>
ReactiveKeyCommands.persist
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Remove one-by-one the expiration from givenkey
.reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveKeyCommands.ExpireCommand>>
ReactiveKeyCommands.pExpire
(org.reactivestreams.Publisher<ReactiveKeyCommands.ExpireCommand> commands) Expire keys one by one.reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveKeyCommands.ExpireAtCommand>>
ReactiveKeyCommands.pExpireAt
(org.reactivestreams.Publisher<ReactiveKeyCommands.ExpireAtCommand> commands) Set one-by-one the expiration for givenkey
as a UNIX timestamp in milliseconds.reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveHyperLogLogCommands.PfMergeCommand>>
ReactiveHyperLogLogCommands.pfMerge
(org.reactivestreams.Publisher<ReactiveHyperLogLogCommands.PfMergeCommand> commands) Merge N different HyperLogLogs at sourceKeys into a single destinationKey.reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveStringCommands.SetCommand>>
ReactiveStringCommands.pSetEX
(org.reactivestreams.Publisher<ReactiveStringCommands.SetCommand> commands) Set key value pairs andExpiration
.reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveKeyCommands.RenameCommand>>
ReactiveKeyCommands.rename
(org.reactivestreams.Publisher<ReactiveKeyCommands.RenameCommand> command) Rename key oldKey to newKey.reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveKeyCommands.RenameCommand>>
ReactiveKeyCommands.renameNX
(org.reactivestreams.Publisher<ReactiveKeyCommands.RenameCommand> command) Rename key oldKey to newKey only if newKey does not exist.reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveStringCommands.SetCommand>>
ReactiveStringCommands.set
(org.reactivestreams.Publisher<ReactiveStringCommands.SetCommand> commands) Set each and every item separately by invokingReactiveStringCommands.SetCommand
.reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveStringCommands.SetBitCommand>>
ReactiveStringCommands.setBit
(org.reactivestreams.Publisher<ReactiveStringCommands.SetBitCommand> commands) Sets the bit at offset in value stored at key and return the original value.reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveStringCommands.SetCommand>>
ReactiveStringCommands.setEX
(org.reactivestreams.Publisher<ReactiveStringCommands.SetCommand> commands) Set key value pairs andExpiration
.reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveStringCommands.SetCommand>>
ReactiveStringCommands.setNX
(org.reactivestreams.Publisher<ReactiveStringCommands.SetCommand> values) Set key value pairs, only if key does not exist.reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveSetCommands.SIsMemberCommand>>
ReactiveSetCommands.sIsMember
(org.reactivestreams.Publisher<ReactiveSetCommands.SIsMemberCommand> commands) Check if set atReactiveRedisConnection.KeyCommand.getKey()
containsReactiveSetCommands.SIsMemberCommand.getValue()
.reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveSetCommands.SMoveCommand>>
ReactiveSetCommands.sMove
(org.reactivestreams.Publisher<ReactiveSetCommands.SMoveCommand> commands)