Package | Description |
---|---|
org.springframework.data.redis.connection |
Connection package providing low-level abstractions for interacting with the various Redis 'drivers'/libraries.
|
Modifier and Type | Class and Description |
---|---|
static class |
ReactiveRedisConnection.AbsentByteBufferResponse<I>
ReactiveRedisConnection.CommandResponse implementation for ByteBuffer responses for absent keys. |
Modifier and Type | Method and Description |
---|---|
reactor.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 the
from argument) of the
list stored at sourceKey , and pushes the element at the first/last element (head/tail depending on the
to argument) of the list stored at destinationKey . |
reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveListCommands.BRPopLPushCommand>> |
ReactiveListCommands.bRPopLPush(org.reactivestreams.Publisher<ReactiveListCommands.BRPopLPushCommand> commands)
Remove the last element from list at
ReactiveRedisConnection.KeyCommand.getKey() , append it to
ReactiveListCommands.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 at
key and delete the key. |
reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveStringCommands.GetExCommand>> |
ReactiveStringCommands.getEx(org.reactivestreams.Publisher<ReactiveStringCommands.GetExCommand> commands)
Return the value at
key and expire the key by applying Expiration . |
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 at
ReactiveListCommands.LIndexCommand.getIndex() form list at ReactiveRedisConnection.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 the
from argument) of the
list stored at sourceKey , and pushes the element at the first/last element (head/tail depending on the
to argument) of the list stored at destinationKey . |
reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveListCommands.PopCommand>> |
ReactiveListCommands.pop(org.reactivestreams.Publisher<ReactiveListCommands.PopCommand> commands)
Removes and returns last element in list stored at
ReactiveRedisConnection.KeyCommand.getKey() |
reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveListCommands.RPopLPushCommand>> |
ReactiveListCommands.rPopLPush(org.reactivestreams.Publisher<ReactiveListCommands.RPopLPushCommand> commands)
Remove the last element from list at
ReactiveRedisConnection.KeyCommand.getKey() , append it to
ReactiveListCommands.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 at
ReactiveRedisConnection.KeyCommand.getKey() |
Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.