org.springframework.data.redis.connection.lettuce

Class LettuceReactiveKeyCommands

java.lang.Object

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

All Implemented Interfaces:

ReactiveKeyCommands

Direct Known Subclasses:

LettuceReactiveClusterKeyCommands

public class LettuceReactiveKeyCommands
extends Object
implements ReactiveKeyCommands

Since:

2.0

Author:

Christoph Strobl

Nested Class Summary

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

ReactiveKeyCommands.RenameCommand

Constructor Summary

Constructors

Constructor and Description
LettuceReactiveKeyCommands(LettuceReactiveRedisConnection connection) Create new LettuceReactiveKeyCommands.

Method Summary

Modifier and Type	Method and Description
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>>	del(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Delete keys one by one.
reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveRedisConnection.KeyCommand>>	exists(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Determine if given key exists.
reactor.core.publisher.Flux<ReactiveRedisConnection.MultiValueResponse<ByteBuffer,ByteBuffer>>	keys(org.reactivestreams.Publisher<ByteBuffer> patterns) Find all keys matching the given pattern.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<List<ByteBuffer>,Long>>	mDel(org.reactivestreams.Publisher<List<ByteBuffer>> keysCollection) Delete multiple keys in batches.
reactor.core.publisher.Mono<ByteBuffer>	randomKey() Return a random key from the keyspace.
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.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,DataType>>	type(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Determine the type stored at key.

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, exists, keys, mDel, rename, renameNX, type

Constructor Detail

LettuceReactiveKeyCommands

public LettuceReactiveKeyCommands(LettuceReactiveRedisConnection connection)

Create new LettuceReactiveKeyCommands.

Parameters:

connection - must not be null.

Method Detail

exists

public reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveRedisConnection.KeyCommand>> exists(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands)

Description copied from interface: ReactiveKeyCommands

Determine if given key exists.

Specified by:

exists in interface ReactiveKeyCommands

Parameters:

commands - must not be null.

Returns:

type

public reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,DataType>> type(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands)

Description copied from interface: ReactiveKeyCommands

Determine the type stored at key.

Specified by:

type in interface ReactiveKeyCommands

Parameters:

commands - must not be null.

Returns:

del

public reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>> del(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands)

Description copied from interface: ReactiveKeyCommands

Delete keys one by one.

Specified by:

del in interface ReactiveKeyCommands

Parameters:

commands - must not be null.

Returns:

Flux of ReactiveRedisConnection.NumericResponse holding the key removed along with the deletion result.

mDel

public reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<List<ByteBuffer>,Long>> mDel(org.reactivestreams.Publisher<List<ByteBuffer>> keysCollection)

Description copied from interface: ReactiveKeyCommands

Delete multiple keys in batches.

Specified by:

mDel in interface ReactiveKeyCommands

Parameters:

keysCollection - must not be null.

Returns:

Flux of ReactiveRedisConnection.NumericResponse holding the keys removed along with the deletion result.

keys

public reactor.core.publisher.Flux<ReactiveRedisConnection.MultiValueResponse<ByteBuffer,ByteBuffer>> keys(org.reactivestreams.Publisher<ByteBuffer> patterns)

Description copied from interface: ReactiveKeyCommands

Find all keys matching the given pattern.

Specified by:

keys in interface ReactiveKeyCommands

Parameters:

patterns - must not be null.

Returns:

randomKey

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

Description copied from interface: ReactiveKeyCommands

Return a random key from the keyspace.

Specified by:

randomKey in interface ReactiveKeyCommands

Returns:

rename

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

Specified by:

rename in interface ReactiveKeyCommands

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

Parameters:

commands - must not be null.

Returns: