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, 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
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.BooleanResponse<ReactiveKeyCommands.ExpireCommand>>	expire(org.reactivestreams.Publisher<ReactiveKeyCommands.ExpireCommand> commands) Expire keys one by one.
reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveKeyCommands.ExpireAtCommand>>	expireAt(org.reactivestreams.Publisher<ReactiveKeyCommands.ExpireAtCommand> commands) Set one-by-one the expiration for given key as a UNIX timestamp.
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.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveKeyCommands.MoveCommand>>	move(org.reactivestreams.Publisher<ReactiveKeyCommands.MoveCommand> commands) Move keys one-by-one between databases.
reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveRedisConnection.KeyCommand>>	persist(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Remove one-by-one the expiration from given key.
reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveKeyCommands.ExpireCommand>>	pExpire(org.reactivestreams.Publisher<ReactiveKeyCommands.ExpireCommand> commands) Expire keys one by one.
reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveKeyCommands.ExpireAtCommand>>	pExpireAt(org.reactivestreams.Publisher<ReactiveKeyCommands.ExpireAtCommand> commands) Set one-by-one the expiration for given key as a UNIX timestamp in milliseconds.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>>	pTtl(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Get one-by-one the time to live for keys.
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) 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.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>>	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>>	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, expire, expireAt, keys, mDel, move, persist, pExpire, pExpireAt, pTtl, rename, renameNX, ttl, 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:

See Also:

Redis Documentation: EXISTS

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:

See Also:

Redis Documentation: TYPE

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:

See Also:

Redis Documentation: KEYS

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:

See Also:

Redis Documentation: RANDOMKEY

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

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

Parameters:

commands - must not be null.

Returns:

See Also:

Redis Documentation: RENAMENX

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.

See Also:

Redis Documentation: DEL

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.

See Also:

Redis Documentation: DEL

expire

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

Description copied from interface: ReactiveKeyCommands

Expire keys one by one.

Specified by:

expire in interface ReactiveKeyCommands

Parameters:

commands - must not be null.

Returns:

Flux of ReactiveRedisConnection.BooleanResponse holding the key removed along with the expiration result.

See Also:

Redis Documentation: EXPIRE

pExpire

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

Description copied from interface: ReactiveKeyCommands

Expire keys one by one.

Specified by:

pExpire in interface ReactiveKeyCommands

Parameters:

commands - must not be null.

Returns:

Flux of ReactiveRedisConnection.BooleanResponse holding the key removed along with the expiration result.

See Also:

Redis Documentation: PEXPIRE

expireAt

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

Description copied from interface: ReactiveKeyCommands

Set one-by-one the expiration for given key as a UNIX timestamp.

Specified by:

expireAt in interface ReactiveKeyCommands

Parameters:

commands - must not be null.

Returns:

Flux of ReactiveRedisConnection.BooleanResponse holding the key removed along with the expiration result.

See Also:

Redis Documentation: EXPIREAT

pExpireAt

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

Description copied from interface: ReactiveKeyCommands

Set one-by-one the expiration for given key as a UNIX timestamp in milliseconds.

Specified by:

pExpireAt in interface ReactiveKeyCommands

Parameters:

commands - must not be null.

Returns:

Flux of ReactiveRedisConnection.BooleanResponse holding the key removed along with the expiration result.

See Also:

Redis Documentation: PEXPIREAT

persist

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

Description copied from interface: ReactiveKeyCommands

Remove one-by-one the expiration from given key.

Specified by:

persist in interface ReactiveKeyCommands

Parameters:

commands - must not be null.

Returns:

Flux of ReactiveRedisConnection.BooleanResponse holding the key persisted along with the persist result.

See Also:

Redis Documentation: PERSIST

ttl

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

Description copied from interface: ReactiveKeyCommands

Get one-by-one the time to live for keys.

Specified by:

ttl in interface ReactiveKeyCommands

Parameters:

commands - must not be null.

Returns:

Flux of ReactiveRedisConnection.NumericResponse holding the key along with the time to live result.

See Also:

Redis Documentation: TTL

pTtl

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

Description copied from interface: ReactiveKeyCommands

Get one-by-one the time to live for keys.

Specified by:

pTtl in interface ReactiveKeyCommands

Parameters:

commands - must not be null.

Returns:

Flux of ReactiveRedisConnection.NumericResponse holding the key along with the time to live result.

See Also:

Redis Documentation: PTTL

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

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