Uses of Class
org.springframework.data.redis.connection.ReactiveRedisConnection.KeyCommand

Packages that use ReactiveRedisConnection.KeyCommand

Package	Description
org.springframework.data.redis.connection	Connection package providing low-level abstractions for interacting with the various Redis 'drivers'/libraries.

Uses of ReactiveRedisConnection.KeyCommand in org.springframework.data.redis.connection

Subclasses of ReactiveRedisConnection.KeyCommand in org.springframework.data.redis.connection

Modifier and Type	Class and Description
static class	ReactiveGeoCommands.GeoAddCommand GEOADD command parameters.
static class	ReactiveGeoCommands.GeoDistCommand GEODIST command parameters.
static class	ReactiveGeoCommands.GeoHashCommand GEOHASH command parameters.
static class	ReactiveGeoCommands.GeoPosCommand GEOPOS command parameters.
static class	ReactiveGeoCommands.GeoRadiusByMemberCommand GEORADIUSBYMEMBER command parameters.
static class	ReactiveGeoCommands.GeoRadiusCommand GEORADIUS command parameters.
static class	ReactiveHashCommands.HDelCommand
static class	ReactiveHashCommands.HExistsCommand HEXISTS ReactiveRedisConnection.Command.
static class	ReactiveHashCommands.HGetCommand HGET ReactiveRedisConnection.Command.
static class	ReactiveHashCommands.HSetCommand HSET ReactiveRedisConnection.Command.
static class	ReactiveHashCommands.HStrLenCommand
static class	ReactiveHyperLogLogCommands.PfAddCommand PFADD command parameters.
static class	ReactiveHyperLogLogCommands.PfMergeCommand PFMERGE command parameters.
static class	ReactiveKeyCommands.ExpireAtCommand EXPIREAT/PEXPIREAT command parameters.
static class	ReactiveKeyCommands.ExpireCommand EXPIRE/PEXPIRE command parameters.
static class	ReactiveKeyCommands.MoveCommand MOVE command parameters.
static class	ReactiveKeyCommands.RenameCommand RENAME command parameters.
static class	ReactiveListCommands.BRPopLPushCommand BRPOPLPUSH command parameters.
static class	ReactiveListCommands.LIndexCommand LINDEX command parameters.
static class	ReactiveListCommands.LInsertCommand LINSERT command parameters.
static class	ReactiveListCommands.LRemCommand LREM command parameters.
static class	ReactiveListCommands.LSetCommand LSET command parameters.
static class	ReactiveListCommands.PopCommand LPOP/RPOP command parameters.
static class	ReactiveListCommands.PushCommand LPUSH/RPUSH command parameters.
static class	ReactiveListCommands.RPopLPushCommand 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	ReactiveRedisConnection.KeyScanCommand ReactiveRedisConnection.Command for key-bound scan operations like SCAN, HSCAN, SSCAN and ZSCAN.
static class	ReactiveRedisConnection.RangeCommand
static class	ReactiveSetCommands.SAddCommand SADD command parameters.
static class	ReactiveSetCommands.SDiffStoreCommand SDIFFSTORE command parameters.
static class	ReactiveSetCommands.SInterStoreCommand SINTERSTORE command parameters.
static class	ReactiveSetCommands.SIsMemberCommand SISMEMBER command parameters.
static class	ReactiveSetCommands.SMoveCommand SMOVE command parameters.
static class	ReactiveSetCommands.SPopCommand SPOP command parameters.
static class	ReactiveSetCommands.SRandMembersCommand SRANDMEMBER command parameters.
static class	ReactiveSetCommands.SRemCommand SREM command parameters.
static class	ReactiveSetCommands.SUnionStoreCommand SUNIONSTORE command parameters.
static class	ReactiveStreamCommands.AcknowledgeCommand XACK command parameters.
static class	ReactiveStreamCommands.AddStreamRecord XADD command parameters.
static class	ReactiveStreamCommands.DeleteCommand XDEL command parameters.
static class	ReactiveStreamCommands.GroupCommand
static class	ReactiveStreamCommands.PendingRecordsCommand Value Object holding parameters for obtaining pending messages.
static class	ReactiveStreamCommands.RangeCommand XRANGE/XREVRANGE command parameters.
static class	ReactiveStreamCommands.TrimCommand XTRIM command parameters.
static class	ReactiveStreamCommands.XClaimCommand XCLAIM command parameters.
static class	ReactiveStreamCommands.XInfoCommand
static class	ReactiveStringCommands.AppendCommand APPEND command parameters.
static class	ReactiveStringCommands.BitCountCommand BITCOUNT command parameters.
static class	ReactiveStringCommands.BitFieldCommand BITFIELD command parameters.
static class	ReactiveStringCommands.BitPosCommand
static class	ReactiveStringCommands.GetBitCommand GETBIT command parameters.
static class	ReactiveStringCommands.SetBitCommand SETBIT command parameters.
static class	ReactiveStringCommands.SetCommand SET command parameters.
static class	ReactiveStringCommands.SetRangeCommand SETRANGE command parameters.
static class	ReactiveZSetCommands.ZAddCommand ZADD command parameters.
static class	ReactiveZSetCommands.ZCountCommand ZCOUNT command parameters.
static class	ReactiveZSetCommands.ZIncrByCommand ZINCRBY command parameters.
static class	ReactiveZSetCommands.ZInterStoreCommand ZINTERSTORE command parameters.
static class	ReactiveZSetCommands.ZRangeByLexCommand ZRANGEBYLEX/ZREVRANGEBYLEX command parameters.
static class	ReactiveZSetCommands.ZRangeByScoreCommand ZRANGEBYSCORE/ZREVRANGEBYSCORE.
static class	ReactiveZSetCommands.ZRangeCommand ZRANGE/ZREVRANGE command parameters.
static class	ReactiveZSetCommands.ZRankCommand ZRANK/ZREVRANK command parameters.
static class	ReactiveZSetCommands.ZRemCommand ZREM command parameters.
static class	ReactiveZSetCommands.ZRemRangeByRankCommand ZREMRANGEBYRANK command parameters.
static class	ReactiveZSetCommands.ZRemRangeByScoreCommand ZREMRANGEBYSCORE command parameters.
static class	ReactiveZSetCommands.ZScoreCommand ZSCORE command parameters.
static class	ReactiveZSetCommands.ZUnionStoreCommand ZUNIONSTORE command parameters.

Methods in org.springframework.data.redis.connection that return types with arguments of type ReactiveRedisConnection.KeyCommand

Modifier and Type	Method and Description
reactor.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.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 a Flux to iterate over entries in the 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 at getKey()
reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveRedisConnection.KeyCommand>>	ReactiveKeyCommands.persist(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Remove one-by-one the expiration from given key.
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 at getKey().
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 at getKey().
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 getKey()
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,reactor.core.publisher.Flux<ByteBuffer>>>	ReactiveSetCommands.sScan(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyScanCommand> commands) Use a Flux to iterate over members in the set at key.
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 the key 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 at getKey()
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>>	ReactiveStreamCommands.xTrim(org.reactivestreams.Publisher<ReactiveStreamCommands.TrimCommand> commands) Trims the stream to count 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 getKey().
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,reactor.core.publisher.Flux<RedisZSetCommands.Tuple>>>	ReactiveZSetCommands.zScan(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyScanCommand> commands) Use a Flux to iterate over members in the sorted set at key.

Method parameters in org.springframework.data.redis.connection with type arguments of type ReactiveRedisConnection.KeyCommand

Modifier and Type	Method and Description
reactor.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.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 at getKey()
reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveRedisConnection.KeyCommand>>	ReactiveKeyCommands.persist(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Remove one-by-one the expiration from given key.
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 at getKey().
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 at getKey().
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 getKey()
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 the key 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 at getKey()
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>>	ReactiveZSetCommands.zCard(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Get the size of sorted set with getKey().