Uses of Class
org.springframework.data.redis.connection.ReactiveRedisConnection.KeyCommand
Package
Description
Connection package providing low-level abstractions for interacting with the various Redis 'drivers'/libraries.
-
Uses of ReactiveRedisConnection.KeyCommand in org.springframework.data.redis.connection
Modifier and TypeClassDescriptionstatic class
GEOADD
command parameters.static class
GEODIST
command parameters.static class
GEOHASH
command parameters.static class
GEOPOS
command parameters.static class
GEORADIUSBYMEMBER
command parameters.static class
GEORADIUS
command parameters.static class
GEOSEARCH
command parameters.static class
GEOSEARCHSTORE
command parameters.static class
static class
HEXISTSReactiveRedisConnection.Command
.static class
static class
HRANDFIELDReactiveRedisConnection.Command
.static class
static class
static class
PFADD
command parameters.static class
PFMERGE
command parameters.static class
MOVE
command parameters.static class
EXPIREAT
/PEXPIREAT
command parameters.static class
EXPIRE
/PEXPIRE
command parameters.static class
MOVE
command parameters.static class
RENAME
command parameters.static class
BLMOVE
command parameters.static class
BRPOPLPUSH
command parameters.static class
LINDEX
command parameters.static class
LINSERT
command parameters.static class
LMOVE
command parameters.static class
LPOS
command parameters.static class
LREM
command parameters.static class
LSET
command parameters.static class
LPOP
/RPOP command parameters.static class
LPUSH
/RPUSH command parameters.static class
RPOPLPUSH
command parameters.static class
ReactiveNumberCommands.DecrByCommand<T extends Number>
DECRBY
command parameters.static class
ReactiveNumberCommands.HIncrByCommand<T extends Number>
HINCRBY
command parameters.static class
ReactiveNumberCommands.IncrByCommand<T extends Number>
INCRBY
command parameters.static class
static class
static class
SADD
command parameters.static class
SDIFFSTORE
command parameters.static class
SINTERSTORE
command parameters.static class
SISMEMBER
command parameters.static class
SMISMEMBER
command parameters.static class
SMOVE
command parameters.static class
SPOP
command parameters.static class
SRANDMEMBER
command parameters.static class
SREM
command parameters.static class
SUNIONSTORE
command parameters.static class
XACK
command parameters.static class
XADD
command parameters.static class
XDEL
command parameters.static class
static class
Value Object holding parameters for obtaining pending messages.static class
XRANGE
/XREVRANGE
command parameters.static class
XTRIM
command parameters.static class
XCLAIM
command parameters.static class
static class
APPEND
command parameters.static class
BITCOUNT
command parameters.static class
BITFIELD
command parameters.static class
static class
GETBIT
command parameters.static class
ReactiveRedisConnection.Command
forGETEX
.static class
SETBIT
command parameters.static class
SET
command parameters.static class
SETRANGE
command parameters.static class
BZPOPMIN
/BZPOPMAX command parameters.static class
ZADD
command parameters.static class
ZINTERSTORE
/ZUNIONSTORE
command parameters.static class
ZCOUNT
command parameters.static class
ZDIFFSTORE
command parameters.static class
ZINCRBY
command parameters.static class
ZINTERSTORE
command parameters.static class
ZLEXCOUNT
command parameters.static class
ZMSCORE
command parameters.static class
ZPOPMIN
/ZPOPMAX command parameters.static class
ZRANDMEMBER
command parameters.static class
ZRANGEBYLEX
/ZREVRANGEBYLEX command parameters.static class
ZRANGEBYSCORE/ZREVRANGEBYSCORE.static class
ZRANGE
/ZREVRANGE command parameters.static class
ZRANGESTORE
command parameters.static class
ZRANK
/ZREVRANK command parameters.static class
ZREM
command parameters.static class
ZREMRANGEBYLEX
command parameters.static class
ZREMRANGEBYRANK
command parameters.static class
ZREMRANGEBYSCORE
command parameters.static class
ZSCORE
command parameters.static class
ZUNIONSTORE
command parameters.Modifier and TypeMethodDescriptionreactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,
Long>> ReactiveNumberCommands.decr
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> keys) Decrement value of key by 1.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,
Long>> ReactiveKeyCommands.del
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> keys) Delete 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.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.CommandResponse<ReactiveRedisConnection.KeyCommand,
reactor.core.publisher.Flux<Map.Entry<ByteBuffer, ByteBuffer>>>> ReactiveHashCommands.hGetAll
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Get entire hash stored at key.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,
reactor.core.publisher.Flux<ByteBuffer>>> ReactiveHashCommands.hKeys
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Get key set (fields) of hash at key.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,
Long>> ReactiveHashCommands.hLen
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Get size of hash at key.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,
reactor.core.publisher.Flux<Map.Entry<ByteBuffer, ByteBuffer>>>> ReactiveHashCommands.hScan
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyScanCommand> commands) Use aFlux
to iterate over entries in the hash atkey
.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,
reactor.core.publisher.Flux<ByteBuffer>>> ReactiveHashCommands.hVals
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Get entry set (values) of hash at key.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,
Long>> ReactiveNumberCommands.incr
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> keys) Increment value of key by 1.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,
Long>> ReactiveListCommands.lLen
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Get the size of list stored atgetKey()
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.NumericResponse<ReactiveRedisConnection.KeyCommand,
Long>> ReactiveKeyCommands.pTtl
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Get one-by-one the time to live for keys.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,
Long>> ReactiveSetCommands.sCard
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Get size of set atgetKey()
.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,
reactor.core.publisher.Flux<ByteBuffer>>> ReactiveSetCommands.sMembers
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Get all elements of set atgetKey()
.reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveRedisConnection.KeyCommand>>
ReactiveSetCommands.sPop
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Remove and return a random member from set atgetKey()
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,
reactor.core.publisher.Flux<ByteBuffer>>> ReactiveSetCommands.sScan
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyScanCommand> commands) Use aFlux
to iterate over members in the set atkey
.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,
Long>> ReactiveStringCommands.strLen
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> keys) Get the length of the value stored at key.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,
Long>> ReactiveKeyCommands.ttl
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Get one-by-one the time to live for keys.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,
DataType>> ReactiveKeyCommands.type
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> keys) Determine the type stored at key.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,
Long>> ReactiveKeyCommands.unlink
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> keys) Unlink thekey
from the keyspace.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,
Long>> ReactiveStreamCommands.xLen
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Get the size of the stream stored atgetKey()
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,
Long>> ReactiveStreamCommands.xTrim
(org.reactivestreams.Publisher<ReactiveStreamCommands.TrimCommand> commands) Trims the stream tocount
elements.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,
Long>> ReactiveZSetCommands.zCard
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Get the size of sorted set with .reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,
reactor.core.publisher.Flux<Tuple>>> ReactiveZSetCommands.zScan
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyScanCommand> commands) Use aFlux
to iterate over members in the sorted set atkey
.Modifier and TypeMethodDescriptionreactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,
Long>> ReactiveNumberCommands.decr
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> keys) Decrement value of key by 1.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,
Long>> ReactiveKeyCommands.del
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> keys) Delete 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.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.CommandResponse<ReactiveRedisConnection.KeyCommand,
reactor.core.publisher.Flux<Map.Entry<ByteBuffer, ByteBuffer>>>> ReactiveHashCommands.hGetAll
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Get entire hash stored at key.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,
reactor.core.publisher.Flux<ByteBuffer>>> ReactiveHashCommands.hKeys
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Get key set (fields) of hash at key.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,
Long>> ReactiveHashCommands.hLen
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Get size of hash at key.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,
reactor.core.publisher.Flux<ByteBuffer>>> ReactiveHashCommands.hVals
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Get entry set (values) of hash at key.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,
Long>> ReactiveNumberCommands.incr
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> keys) Increment value of key by 1.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,
Long>> ReactiveListCommands.lLen
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Get the size of list stored atgetKey()
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.NumericResponse<ReactiveRedisConnection.KeyCommand,
Long>> ReactiveKeyCommands.pTtl
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Get one-by-one the time to live for keys.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,
Long>> ReactiveSetCommands.sCard
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Get size of set atgetKey()
.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,
reactor.core.publisher.Flux<ByteBuffer>>> ReactiveSetCommands.sMembers
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Get all elements of set atgetKey()
.reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveRedisConnection.KeyCommand>>
ReactiveSetCommands.sPop
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Remove and return a random member from set atgetKey()
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,
Long>> ReactiveStringCommands.strLen
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> keys) Get the length of the value stored at key.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,
Long>> ReactiveKeyCommands.ttl
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Get one-by-one the time to live for keys.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,
DataType>> ReactiveKeyCommands.type
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> keys) Determine the type stored at key.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,
Long>> ReactiveKeyCommands.unlink
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> keys) Unlink thekey
from the keyspace.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,
Long>> ReactiveStreamCommands.xLen
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Get the size of the stream stored atgetKey()
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,
Long>> ReactiveZSetCommands.zCard
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Get the size of sorted set with .