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 classReactiveRedisConnection.CommandResponseimplementation forByteBufferresponses 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 thefromargument) of the list stored atsourceKey, and pushes the element at the first/last element (head/tail depending on thetoargument) 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 atkeyand delete the key.reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveStringCommands.GetExCommand>>ReactiveStringCommands.getEx(org.reactivestreams.Publisher<ReactiveStringCommands.GetExCommand> commands) Return the value atkeyand 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 thefromargument) of the list stored atsourceKey, and pushes the element at the first/last element (head/tail depending on thetoargument) 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()