Package org.springframework.data.redis.connection

Interface ReactiveKeyCommands

All Known Subinterfaces:

ReactiveClusterKeyCommands

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	Description
static class	ReactiveKeyCommands.CopyCommand	MOVE command parameters.
static class	ReactiveKeyCommands.ExpireAtCommand	EXPIREAT/PEXPIREAT command parameters.
static class	ReactiveKeyCommands.ExpireCommand	EXPIRE/PEXPIRE command parameters.
static class	ReactiveKeyCommands.MoveCommand	MOVE command parameters.
static class	ReactiveKeyCommands.RenameCommand	RENAME command parameters.

Method Summary

Modifier and Type	Method	Description
default reactor.core.publisher.Mono<Boolean>	copy(ByteBuffer sourceKey, ByteBuffer targetKey, boolean replace)	Copy given key to a target key.
reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveKeyCommands.CopyCommand>>	copy(org.reactivestreams.Publisher<ReactiveKeyCommands.CopyCommand> commands)	Copy keys one-by-one.
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.
reactor.core.publisher.Mono<ValueEncoding>	encodingOf(ByteBuffer key)	Get the type of internal representation used for storing the value at the given key.
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<Boolean>	expire(ByteBuffer key, Duration timeout)	Set time to live for given key in seconds.
reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveKeyCommands.ExpireCommand>>	expire(org.reactivestreams.Publisher<ReactiveKeyCommands.ExpireCommand> commands)	Expire keys one by one.
default reactor.core.publisher.Mono<Boolean>	expireAt(ByteBuffer key, Instant expireAt)	Set the expiration for given key as a UNIX timestamp.
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.Mono<Duration>	idletime(ByteBuffer key)	Get the Duration since the object stored at the given key is idle.
default reactor.core.publisher.Mono<List<ByteBuffer>>	keys(ByteBuffer pattern)	Retrieve all keys matching the given pattern via KEYS command.
reactor.core.publisher.Flux<ReactiveRedisConnection.MultiValueResponse<ByteBuffer,ByteBuffer>>	keys(org.reactivestreams.Publisher<ByteBuffer> patterns)	Find all keys matching the given pattern. It is recommended to use scan(ScanOptions) to iterate over the keyspace as keys(Publisher) is a non-interruptible and expensive Redis operation.
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.
default reactor.core.publisher.Mono<Boolean>	move(ByteBuffer key, int database)	Move given key to database with index.
reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveKeyCommands.MoveCommand>>	move(org.reactivestreams.Publisher<ReactiveKeyCommands.MoveCommand> commands)	Move keys one-by-one between databases.
default reactor.core.publisher.Mono<Long>	mUnlink(List<ByteBuffer> keys)	Unlink the keys from the keyspace.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<List<ByteBuffer>,Long>>	mUnlink(org.reactivestreams.Publisher<List<ByteBuffer>> keys)	Unlink the keys from the keyspace.
default reactor.core.publisher.Mono<Boolean>	persist(ByteBuffer key)	Remove the expiration from given key.
reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveRedisConnection.KeyCommand>>	persist(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands)	Remove one-by-one the expiration from given key.
default reactor.core.publisher.Mono<Boolean>	pExpire(ByteBuffer key, Duration timeout)	Set time to live for given key in milliseconds.
reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveKeyCommands.ExpireCommand>>	pExpire(org.reactivestreams.Publisher<ReactiveKeyCommands.ExpireCommand> commands)	Expire keys one by one.
default reactor.core.publisher.Mono<Boolean>	pExpireAt(ByteBuffer key, Instant expireAt)	Set the expiration for given key as a UNIX timestamp.
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.
default reactor.core.publisher.Mono<Long>	pTtl(ByteBuffer key)	Get the time to live for key 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.Mono<Long>	refcount(ByteBuffer key)	Get the number of references of the value associated with the specified key.
default reactor.core.publisher.Mono<Boolean>	rename(ByteBuffer oldKey, ByteBuffer newKey)	Rename key oldKey to newKey.
reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveKeyCommands.RenameCommand>>	rename(org.reactivestreams.Publisher<ReactiveKeyCommands.RenameCommand> command)	Rename key oldKey to newKey.
default reactor.core.publisher.Mono<Boolean>	renameNX(ByteBuffer key, ByteBuffer newKey)	Rename key oldKey to newKey only if newKey does not exist.
reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveKeyCommands.RenameCommand>>	renameNX(org.reactivestreams.Publisher<ReactiveKeyCommands.RenameCommand> command)	Rename key oldKey to newKey only if newKey does not exist.
default reactor.core.publisher.Flux<ByteBuffer>	scan()	Use a Flux to iterate over keys.
default reactor.core.publisher.Flux<ByteBuffer>	scan(KeyScanOptions options)	Use a Flux to iterate over keys.
reactor.core.publisher.Flux<ByteBuffer>	scan(ScanOptions options)	Use a Flux to iterate over keys.
default reactor.core.publisher.Mono<Long>	touch(Collection<ByteBuffer> keys)	Alter the last access time of given key(s).
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<Collection<ByteBuffer>,Long>>	touch(org.reactivestreams.Publisher<Collection<ByteBuffer>> keys)	Alter the last access time of given key(s).
default reactor.core.publisher.Mono<Long>	ttl(ByteBuffer key)	Get the time to live for key in seconds.
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.
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.
default reactor.core.publisher.Mono<Long>	unlink(ByteBuffer key)	Unlink the key from the keyspace.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>>	unlink(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> keys)	Unlink the key from the keyspace.

Method Details

copy

default reactor.core.publisher.Mono<Boolean> copy(ByteBuffer sourceKey,
 ByteBuffer targetKey,
 boolean replace)

Copy given key to a target key.

Parameters:

sourceKey - must not be null.

targetKey - must not be null.

replace - whether to replace existing keys.

Returns:

Since:

2.6

See Also:

• Redis Documentation: COPY

copy

reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveKeyCommands.CopyCommand>> copy(org.reactivestreams.Publisher<ReactiveKeyCommands.CopyCommand> commands)

Copy keys one-by-one.

Parameters:

commands - must not be null.

Returns:

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

Since:

2.6

See Also:

• Redis Documentation: COPY

exists

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

Determine if given key exists.

Parameters:

key - must not be null.

Returns:

See Also:

• Redis Documentation: EXISTS

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:

See Also:

• Redis Documentation: EXISTS

type

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

Determine the type stored at key.

Parameters:

key - must not be null.

Returns:

See Also:

• Redis Documentation: TYPE

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:

See Also:

• Redis Documentation: TYPE

touch

default reactor.core.publisher.Mono<Long> touch(Collection<ByteBuffer> keys)

Alter the last access time of given key(s).

Parameters:

keys - must not be null.

Returns:

Mono emitting the number of keys touched.

Since:

2.1

See Also:

• Redis Documentation: TOUCH

touch

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

Alter the last access time of given key(s).

Parameters:

keys - must not be null.

Returns:

Since:

2.1

See Also:

• Redis Documentation: TOUCH

keys

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

Retrieve all keys matching the given pattern via KEYS command.

IMPORTANT: This command is non-interruptible and scans the entire keyspace which may cause performance issues. Consider scan(ScanOptions) for large datasets.

Parameters:

pattern - must not be null.

Returns:

See Also:

• Redis Documentation: KEYS

keys

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

Find all keys matching the given pattern.
It is recommended to use scan(ScanOptions) to iterate over the keyspace as keys(Publisher) is a non-interruptible and expensive Redis operation.

Parameters:

patterns - must not be null.

Returns:

See Also:

• Redis Documentation: KEYS

scan

default reactor.core.publisher.Flux<ByteBuffer> scan()

Use a Flux to iterate over keys. The resulting Flux acts as a cursor and issues SCAN commands itself as long as the subscriber signals demand.

Returns:

never null.

Since:

2.1

See Also:

• Redis Documentation: SCAN

scan

default reactor.core.publisher.Flux<ByteBuffer> scan(KeyScanOptions options)

Use a Flux to iterate over keys. The resulting Flux acts as a cursor and issues SCAN commands itself as long as the subscriber signals demand.

Parameters:

options - must not be null.

Returns:

the Flux emitting keys one by one.

Throws:

IllegalArgumentException - when options is null.

Since:

2.6

See Also:

• Redis Documentation: SCAN

scan

reactor.core.publisher.Flux<ByteBuffer> scan(ScanOptions options)

Use a Flux to iterate over keys. The resulting Flux acts as a cursor and issues SCAN commands itself as long as the subscriber signals demand.

Parameters:

options - must not be null.

Returns:

the Flux emitting keys one by one.

Throws:

IllegalArgumentException - when options is null.

Since:

2.1

See Also:

• Redis Documentation: SCAN

randomKey

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

Return a random key from the keyspace.

Returns:

See Also:

• Redis Documentation: RANDOMKEY

rename

default reactor.core.publisher.Mono<Boolean> rename(ByteBuffer oldKey,
 ByteBuffer newKey)

Rename key oldKey to newKey.

Parameters:

oldKey - must not be null.

newKey - must not be null.

Returns:

See Also:

• Redis Documentation: RENAME

rename

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

Rename key oldKey to newKey.

Parameters:

command - must not be null.

Returns:

See Also:

• Redis Documentation: RENAME

renameNX

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

Rename key oldKey to newKey only if newKey does not exist.

Parameters:

key - must not be null.

newKey - must not be null.

Returns:

See Also:

• Redis Documentation: RENAMENX

renameNX

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

Rename key oldKey to newKey only if newKey does not exist.

Parameters:

command - must not be null.

Returns:

See Also:

• Redis Documentation: RENAMENX

del

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

Delete key.

Parameters:

key - must not be null.

Returns:

See Also:

• Redis Documentation: DEL

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.

See Also:

• Redis Documentation: DEL

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:

See Also:

• Redis Documentation: DEL

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.

See Also:

• Redis Documentation: DEL

unlink

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

Unlink the key from the keyspace. Unlike with del(ByteBuffer) the actual memory reclaiming here happens asynchronously.

Parameters:

key - must not be null.

Returns:

Since:

2.1

See Also:

• Redis Documentation: UNLINK

unlink

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

Unlink the key from the keyspace. Unlike with del(ByteBuffer) the actual memory reclaiming here happens asynchronously.

Parameters:

keys - must not be null.

Returns:

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

Since:

2.1

See Also:

• Redis Documentation: UNLINK

mUnlink

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

Unlink the keys from the keyspace. Unlike with mDel(List) the actual memory reclaiming here happens asynchronously.

Parameters:

keys - must not be null.

Returns:

Since:

2.1

See Also:

• Redis Documentation: UNLINK

mUnlink

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

Unlink the keys from the keyspace. Unlike with mDel(Publisher) the actual memory reclaiming here happens asynchronously.

Parameters:

keys - must not be null.

Returns:

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

Since:

2.1

See Also:

• Redis Documentation: UNLINK

expire

default reactor.core.publisher.Mono<Boolean> expire(ByteBuffer key,
 Duration timeout)

Set time to live for given key in seconds.

Parameters:

key - must not be null.

timeout - must not be null.

Returns:

See Also:

• Redis Documentation: EXPIRE

expire

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

Expire keys one by one.

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

default reactor.core.publisher.Mono<Boolean> pExpire(ByteBuffer key,
 Duration timeout)

Set time to live for given key in milliseconds.

Parameters:

key - must not be null.

timeout - must not be null.

Returns:

See Also:

• Redis Documentation: PEXPIRE

pExpire

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

Expire keys one by one.

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

default reactor.core.publisher.Mono<Boolean> expireAt(ByteBuffer key,
 Instant expireAt)

Set the expiration for given key as a UNIX timestamp.

Parameters:

key - must not be null.

expireAt - must not be null.

Returns:

See Also:

• Redis Documentation: EXPIREAT

expireAt

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.

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

default reactor.core.publisher.Mono<Boolean> pExpireAt(ByteBuffer key,
 Instant expireAt)

Set the expiration for given key as a UNIX timestamp.

Parameters:

key - must not be null.

expireAt - must not be null.

Returns:

See Also:

• Redis Documentation: PEXPIREAT

pExpireAt

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.

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

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

Remove the expiration from given key.

Parameters:

key - must not be null.

Returns:

See Also:

• Redis Documentation: PERSIST

persist

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

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

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

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

Get the time to live for key in seconds.

Parameters:

key - must not be null.

Returns:

See Also:

• Redis Documentation: TTL

ttl

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.

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

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

Get the time to live for key in milliseconds.

Parameters:

key - must not be null.

Returns:

See Also:

• Redis Documentation: TTL

pTtl

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.

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

default reactor.core.publisher.Mono<Boolean> move(ByteBuffer key,
 int database)

Move given key to database with index.

Parameters:

key - must not be null.

Returns:

See Also:

• Redis Documentation: MOVE

move

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

Move keys one-by-one between databases.

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

encodingOf

reactor.core.publisher.Mono<ValueEncoding> encodingOf(ByteBuffer key)

Get the type of internal representation used for storing the value at the given key.

Parameters:

key - must not be null.

Returns:

the Mono emitting ValueEncoding.

Throws:

IllegalArgumentException - if key is null.

Since:

2.1

See Also:

• Redis Documentation: OBJECT ENCODING

idletime

reactor.core.publisher.Mono<Duration> idletime(ByteBuffer key)

Get the Duration since the object stored at the given key is idle.

Parameters:

key - must not be null.

Returns:

the Mono emitting the idletime of the key of Mono.empty() if the key does not exist.

Throws:

IllegalArgumentException - if key is null.

Since:

2.1

See Also:

• Redis Documentation: OBJECT IDLETIME

refcount

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

Get the number of references of the value associated with the specified key.

Parameters:

key - must not be null.

Returns:

Mono.empty() if key does not exist.

Throws:

IllegalArgumentException - if key is null.

Since:

2.1

See Also:

• Redis Documentation: OBJECT REFCOUNT