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.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.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)
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, keys, mDel, randomKey, 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, keys, keys, mDel, mDel, randomKey, rename, renameNX, 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)

Specified by:

rename in interface ReactiveKeyCommands

Overrides:

rename in class LettuceReactiveKeyCommands

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: