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	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	ReactiveGeoCommands.GeoSearchCommand	GEOSEARCH command parameters.
static class	ReactiveGeoCommands.GeoSearchStoreCommand	GEOSEARCHSTORE command parameters.
static class	ReactiveHashCommands.HDelCommand
static class	ReactiveHashCommands.HExistsCommand	HEXISTS ReactiveRedisConnection.Command.
static class	ReactiveHashCommands.HGetCommand	HGET ReactiveRedisConnection.Command.
static class	ReactiveHashCommands.HRandFieldCommand	HRANDFIELD 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.CopyCommand	MOVE 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.BLMoveCommand	BLMOVE 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.LMoveCommand	LMOVE command parameters.
static class	ReactiveListCommands.LPosCommand	LPOS 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.SMIsMemberCommand	SMISMEMBER 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.GetExCommand	ReactiveRedisConnection.Command for GETEX.
static class	ReactiveStringCommands.SetBitCommand	SETBIT command parameters.
static class	ReactiveStringCommands.SetCommand	SET command parameters.
static class	ReactiveStringCommands.SetRangeCommand	SETRANGE command parameters.
static class	ReactiveZSetCommands.BZPopCommand	BZPOPMIN/BZPOPMAX command parameters.
static class	ReactiveZSetCommands.ZAddCommand	ZADD command parameters.
static class	ReactiveZSetCommands.ZAggregateStoreCommand	ZINTERSTORE/ZUNIONSTORE command parameters.
static class	ReactiveZSetCommands.ZCountCommand	ZCOUNT command parameters.
static class	ReactiveZSetCommands.ZDiffStoreCommand	ZDIFFSTORE command parameters.
static class	ReactiveZSetCommands.ZIncrByCommand	ZINCRBY command parameters.
static class	ReactiveZSetCommands.ZInterStoreCommand	ZINTERSTORE command parameters.
static class	ReactiveZSetCommands.ZLexCountCommand	ZLEXCOUNT command parameters.
static class	ReactiveZSetCommands.ZMScoreCommand	ZMSCORE command parameters.
static class	ReactiveZSetCommands.ZPopCommand	ZPOPMIN/ZPOPMAX command parameters.
static class	ReactiveZSetCommands.ZRandMemberCommand	ZRANDMEMBER 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.ZRangeStoreCommand	ZRANGESTORE command parameters.
static class	ReactiveZSetCommands.ZRankCommand	ZRANK/ZREVRANK command parameters.
static class	ReactiveZSetCommands.ZRemCommand	ZREM command parameters.
static class	ReactiveZSetCommands.ZRemRangeByLexCommand	ZREMRANGEBYLEX 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	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.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.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 .
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,reactor.core.publisher.Flux<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	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.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.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 .