org.springframework.data.redis.connection.lettuce

Class LettuceReactiveClusterKeyCommands

java.lang.Object

org.springframework.data.redis.connection.lettuce.LettuceReactiveKeyCommands

org.springframework.data.redis.connection.lettuce.LettuceReactiveClusterKeyCommands

All Implemented Interfaces:

ReactiveClusterKeyCommands, ReactiveKeyCommands

public class LettuceReactiveClusterKeyCommands
extends LettuceReactiveKeyCommands
implements ReactiveClusterKeyCommands

Since:

2.0

Author:

Christoph Strobl, Mark Paluch

Nested Class Summary

Nested classes/interfaces inherited from interface org.springframework.data.redis.connection.ReactiveKeyCommands

ReactiveKeyCommands.ExpireAtCommand, ReactiveKeyCommands.ExpireCommand, ReactiveKeyCommands.MoveCommand, ReactiveKeyCommands.RenameCommand

Constructor Summary

Constructors

Constructor and Description
LettuceReactiveClusterKeyCommands(LettuceReactiveRedisClusterConnection connection) Create new LettuceReactiveKeyCommands.

Method Summary

Modifier and Type	Method and Description
reactor.core.publisher.Mono<List<ByteBuffer>>	keys(RedisClusterNode node, ByteBuffer pattern) Retrieve all keys for a given pattern from RedisNode.
reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveKeyCommands.MoveCommand>>	move(org.reactivestreams.Publisher<ReactiveKeyCommands.MoveCommand> commands) Move keys one-by-one between databases.
reactor.core.publisher.Mono<ByteBuffer>	randomKey(RedisClusterNode node) Retrieve a random key from RedisNode.
reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveKeyCommands.RenameCommand>>	rename(org.reactivestreams.Publisher<ReactiveKeyCommands.RenameCommand> commands) Rename key oleName to newName.
reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveKeyCommands.RenameCommand>>	renameNX(org.reactivestreams.Publisher<ReactiveKeyCommands.RenameCommand> commands) Rename key oleName to newName only if newName does not exist.

Methods inherited from class org.springframework.data.redis.connection.lettuce.LettuceReactiveKeyCommands

del, exists, expire, expireAt, keys, mDel, persist, pExpire, pExpireAt, pTtl, randomKey, ttl, type

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.springframework.data.redis.connection.ReactiveKeyCommands

del, del, exists, exists, expire, expire, expireAt, expireAt, keys, keys, mDel, mDel, move, persist, persist, pExpire, pExpire, pExpireAt, pExpireAt, pTtl, pTtl, randomKey, rename, renameNX, ttl, ttl, type, type

Constructor Detail

LettuceReactiveClusterKeyCommands

public LettuceReactiveClusterKeyCommands(LettuceReactiveRedisClusterConnection connection)

Create new LettuceReactiveKeyCommands.

Parameters:

connection - must not be null.

Method Detail

keys

public reactor.core.publisher.Mono<List<ByteBuffer>> keys(RedisClusterNode node,
                                                          ByteBuffer pattern)

Description copied from interface: ReactiveClusterKeyCommands

Retrieve all keys for a given pattern from RedisNode.

Specified by:

keys in interface ReactiveClusterKeyCommands

Parameters:

node - must not be null.

pattern - must not be null.

Returns:

randomKey

public reactor.core.publisher.Mono<ByteBuffer> randomKey(RedisClusterNode node)

Description copied from interface: ReactiveClusterKeyCommands

Retrieve a random key from RedisNode.

Specified by:

randomKey in interface ReactiveClusterKeyCommands

Parameters:

node - must not be null.

Returns:

rename

public reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveKeyCommands.RenameCommand>> rename(org.reactivestreams.Publisher<ReactiveKeyCommands.RenameCommand> commands)

Description copied from interface: ReactiveKeyCommands

Rename key oleName to newName.

Specified by:

rename in interface ReactiveKeyCommands

Overrides:

rename in class LettuceReactiveKeyCommands

Parameters:

commands - must not be null.

Returns:

See Also:

Redis Documentation: RENAME

renameNX

public reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveKeyCommands.RenameCommand>> renameNX(org.reactivestreams.Publisher<ReactiveKeyCommands.RenameCommand> commands)

Description copied from interface: ReactiveKeyCommands

Rename key oleName to newName only if newName does not exist.

Specified by:

renameNX in interface ReactiveKeyCommands

Overrides:

renameNX in class LettuceReactiveKeyCommands

Parameters:

commands - must not be null.

Returns:

See Also:

Redis Documentation: RENAMENX

move

public reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveKeyCommands.MoveCommand>> move(org.reactivestreams.Publisher<ReactiveKeyCommands.MoveCommand> commands)

Description copied from interface: ReactiveKeyCommands

Move keys one-by-one between databases.

Specified by:

move in interface ReactiveKeyCommands

Overrides:

move in class LettuceReactiveKeyCommands

Parameters:

commands - must not be null.

Returns:

Flux of ReactiveRedisConnection.BooleanResponse holding the key to move along with the move result.

See Also:

Redis Documentation: MOVE