Uses of Class
org.springframework.data.redis.connection.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
Modifier and TypeClassDescriptionstatic class
ReactiveRedisConnection.CommandResponse
implementation forByteBuffer
responses for absent keys.Modifier 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()