org.springframework.data.redis.connection

Interface ReactiveKeyCommands

All Known Subinterfaces:

ReactiveClusterKeyCommands

All Known Implementing Classes:

LettuceReactiveClusterKeyCommands, LettuceReactiveKeyCommands

public interface ReactiveKeyCommands

Redis Key commands executed using reactive infrastructure.

Since:

2.0

Author:

Christoph Strobl, Mark Paluch

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	ReactiveKeyCommands.RenameCommand RENAME command parameters.

Method Summary

Modifier and Type	Method and Description
default reactor.core.publisher.Mono<Long>	del(ByteBuffer key) Delete key.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>>	del(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> keys) Delete keys one by one.
default reactor.core.publisher.Mono<Boolean>	exists(ByteBuffer key) Determine if given key exists.
reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveRedisConnection.KeyCommand>>	exists(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> keys) Determine if given key exists.
default reactor.core.publisher.Mono<List<ByteBuffer>>	keys(ByteBuffer pattern) Find all keys matching the given pattern.
reactor.core.publisher.Flux<ReactiveRedisConnection.MultiValueResponse<ByteBuffer,ByteBuffer>>	keys(org.reactivestreams.Publisher<ByteBuffer> patterns) Find all keys matching the given pattern.
default reactor.core.publisher.Mono<Long>	mDel(List<ByteBuffer> keys) Delete multiple keys one in one batch.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<List<ByteBuffer>,Long>>	mDel(org.reactivestreams.Publisher<List<ByteBuffer>> keys) Delete multiple keys in batches.
reactor.core.publisher.Mono<ByteBuffer>	randomKey() Return a random key from the keyspace.
default reactor.core.publisher.Mono<Boolean>	rename(ByteBuffer key, ByteBuffer newName) Rename key oleName to newName.
reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveKeyCommands.RenameCommand>>	rename(org.reactivestreams.Publisher<ReactiveKeyCommands.RenameCommand> cmd)
default reactor.core.publisher.Mono<Boolean>	renameNX(ByteBuffer key, ByteBuffer newName) Rename key oleName to newName only if newName does not exist.
reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveKeyCommands.RenameCommand>>	renameNX(org.reactivestreams.Publisher<ReactiveKeyCommands.RenameCommand> command) Rename key oleName to newName only if newName does not exist.
default reactor.core.publisher.Mono<DataType>	type(ByteBuffer key) Determine the type stored at key.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,DataType>>	type(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> keys) Determine the type stored at key.

Method Detail

exists

default reactor.core.publisher.Mono<Boolean> exists(ByteBuffer key)

Determine if given key exists.

Parameters:

key - must not be null.

Returns:

exists

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

Determine if given key exists.

Parameters:

keys - must not be null.

Returns:

type

default reactor.core.publisher.Mono<DataType> type(ByteBuffer key)

Determine the type stored at key.

Parameters:

key - must not be null.

Returns:

type

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

Determine the type stored at key.

Parameters:

keys - must not be null.

Returns:

keys

default reactor.core.publisher.Mono<List<ByteBuffer>> keys(ByteBuffer pattern)

Find all keys matching the given pattern.

Parameters:

pattern - must not be null.

Returns:

randomKey

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

Return a random key from the keyspace.

Returns:

keys

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

Find all keys matching the given pattern.

Parameters:

patterns - must not be null.

Returns:

rename

default reactor.core.publisher.Mono<Boolean> rename(ByteBuffer key,
                                                    ByteBuffer newName)

Rename key oleName to newName.

Parameters:

key - must not be null.

newName - must not be null.

Returns:

rename

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

renameNX

default reactor.core.publisher.Mono<Boolean> renameNX(ByteBuffer key,
                                                      ByteBuffer newName)

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

Parameters:

key - must not be null.

newName - must not be null.

Returns:

renameNX

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

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

Parameters:

command - must not be null.

Returns:

del

default reactor.core.publisher.Mono<Long> del(ByteBuffer key)

Delete key.

Parameters:

key - must not be null.

Returns:

del

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

Delete keys one by one.

Parameters:

keys - must not be null.

Returns:

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

mDel

default reactor.core.publisher.Mono<Long> mDel(List<ByteBuffer> keys)

Delete multiple keys one in one batch.

Parameters:

keys - must not be null.

Returns:

mDel

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

Delete multiple keys in batches.

Parameters:

keys - must not be null.

Returns:

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