Uses of Class
org.springframework.data.redis.connection.ReactiveRedisConnection.ByteBufferResponse
Packages that use ReactiveRedisConnection.ByteBufferResponse
Package
Description
Connection package providing low-level abstractions for interacting with the various Redis 'drivers'/libraries.
-
Uses of ReactiveRedisConnection.ByteBufferResponse in org.springframework.data.redis.connection
Subclasses of ReactiveRedisConnection.ByteBufferResponse in org.springframework.data.redis.connectionModifier and TypeClassDescriptionstatic class
ReactiveRedisConnection.CommandResponse
implementation forByteBuffer
responses for absent keys.Methods in org.springframework.data.redis.connection that return types with arguments of type ReactiveRedisConnection.ByteBufferResponseModifier and TypeMethodDescriptionreactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveListCommands.BLMoveCommand>>
ReactiveListCommands.bLMove
(org.reactivestreams.Publisher<ReactiveListCommands.BLMoveCommand> commands) Atomically returns and removes the first/last element (head/tail depending on thefrom
argument) of the list stored atsourceKey
, and pushes the element at the first/last element (head/tail depending on theto
argument) of the list stored atdestinationKey
.reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveListCommands.BRPopLPushCommand>>
ReactiveListCommands.bRPopLPush
(org.reactivestreams.Publisher<ReactiveListCommands.BRPopLPushCommand> commands) Remove the last element from list atReactiveRedisConnection.KeyCommand.getKey()
, append it toReactiveListCommands.BRPopLPushCommand.getDestination()
and return its value.reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveRedisConnection.KeyCommand>>
ReactiveStringCommands.get
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> keys) Get elements one by one.reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveRedisConnection.KeyCommand>>
ReactiveStringCommands.getDel
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Return the value atkey
and delete the key.reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveStringCommands.GetExCommand>>
ReactiveStringCommands.getEx
(org.reactivestreams.Publisher<ReactiveStringCommands.GetExCommand> commands) Return the value atkey
and expire the key by applyingExpiration
.reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveRedisConnection.RangeCommand>>
ReactiveStringCommands.getRange
(org.reactivestreams.Publisher<ReactiveRedisConnection.RangeCommand> commands) Get a substring of value of key between start and end.reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveStringCommands.SetCommand>>
ReactiveStringCommands.getSet
(org.reactivestreams.Publisher<ReactiveStringCommands.SetCommand> commands) Set value for key and return the existing value one by one.reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveListCommands.LIndexCommand>>
ReactiveListCommands.lIndex
(org.reactivestreams.Publisher<ReactiveListCommands.LIndexCommand> commands) Get element atReactiveListCommands.LIndexCommand.getIndex()
form list atReactiveRedisConnection.KeyCommand.getKey()
.reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveListCommands.LMoveCommand>>
ReactiveListCommands.lMove
(org.reactivestreams.Publisher<? extends ReactiveListCommands.LMoveCommand> commands) Atomically returns and removes the first/last element (head/tail depending on thefrom
argument) of the list stored atsourceKey
, and pushes the element at the first/last element (head/tail depending on theto
argument) of the list stored atdestinationKey
.reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveListCommands.PopCommand>>
ReactiveListCommands.pop
(org.reactivestreams.Publisher<ReactiveListCommands.PopCommand> commands) Removes and returns last element in list stored atReactiveRedisConnection.KeyCommand.getKey()
reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveListCommands.RPopLPushCommand>>
ReactiveListCommands.rPopLPush
(org.reactivestreams.Publisher<ReactiveListCommands.RPopLPushCommand> commands) Remove the last element from list atReactiveRedisConnection.KeyCommand.getKey()
, append it toReactiveListCommands.RPopLPushCommand.getDestination()
and return its value.reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveRedisConnection.KeyCommand>>
ReactiveSetCommands.sPop
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Remove and return a random member from set atReactiveRedisConnection.KeyCommand.getKey()