Module io.inverno.mod.redis

Package io.inverno.mod.redis.operations

Interface RedisKeyReactiveOperations<A,B>

Type Parameters:

A - key type

B - value type

All Known Subinterfaces:

RedisClient<A,B>, RedisOperations<A,B>, RedisTransactionalClient<A,B>, RedisTransactionalOperations<A,B>

All Known Implementing Classes:

io.inverno.mod.redis.lettuce.internal.AbstractRedisClient, PoolRedisClient, PoolRedisClusterClient

public interface RedisKeyReactiveOperations<A,B>

Redis Keys reactive commands.

Since:

1.4

Author:

Jeremy Kuhn

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	RedisKeyReactiveOperations.AbstractKeySortBuilder<A,C extends RedisKeyReactiveOperations.AbstractKeySortBuilder<A,C>>	SORT key [BY pattern] [LIMIT offset count] [GET pattern [GET pattern ...]]
static interface	RedisKeyReactiveOperations.KeyCopyBuilder<A>	COPY source destination [DB destination-db] [REPLACE]
static interface	RedisKeyReactiveOperations.KeyExpireatBuilder<A>	EXPIREAT key timestamp [NX|XX|GT|LT]
static interface	RedisKeyReactiveOperations.KeyExpireBuilder<A>	EXPIRE key seconds [NX|XX|GT|LT]
static interface	RedisKeyReactiveOperations.KeyMigrateBuilder<A>	MIGRATE host port key|"" destination-db timeout [COPY] [REPLACE] [AUTH password] [AUTH2 username password] [KEYS key [key ...]]
static interface	RedisKeyReactiveOperations.KeyPexpireatBuilder<A>	PEXPIREAT key milliseconds-timestamp [NX|XX|GT|LT]
static interface	RedisKeyReactiveOperations.KeyPexpireBuilder<A>	PEXPIRE key milliseconds [NX|XX|GT|LT]
static interface	RedisKeyReactiveOperations.KeyRestoreBuilder<A>	RESTORE key ttl serialized-value [REPLACE] [ABSTTL] [IDLETIME seconds] [FREQ frequency]
static interface	RedisKeyReactiveOperations.KeyScanBuilder<A>	SCAN cursor [MATCH pattern] [COUNT count] [TYPE type]
static interface	RedisKeyReactiveOperations.KeyScanResult<A>
static interface	RedisKeyReactiveOperations.KeySortBuilder<A,B>	SORT key [BY pattern] [LIMIT offset count] [GET pattern [GET pattern ...]]
static interface	RedisKeyReactiveOperations.KeySortStoreBuilder<A>	SORT key [BY pattern] [LIMIT offset count] [GET pattern [GET pattern ...]]

Method Summary

Modifier and Type	Method	Description
RedisKeyReactiveOperations.KeyCopyBuilder<A>	copy()	COPY source destination [DB destination-db] [REPLACE]
Mono<Boolean>	copy(A source, A destination)	COPY source destination
Mono<Long>	del(A key)	DEL key
Mono<Long>	del(Consumer<Keys<A>> keys)	DEL key [key ...]
Mono<byte[]>	dump(A key)	DUMP key
Mono<Long>	exists(A key)	EXISTS key
Mono<Long>	exists(Consumer<Keys<A>> keys)	EXISTS key [key ...]
RedisKeyReactiveOperations.KeyExpireBuilder<A>	expire()	EXPIRE key seconds [NX|XX|GT|LT]
Mono<Boolean>	expire(A key, long seconds)	EXPIRE key seconds
Mono<Boolean>	expire(A key, Duration duration)	EXPIRE key seconds
RedisKeyReactiveOperations.KeyExpireatBuilder<A>	expireat()	EXPIREAT key timestamp [NX|XX|GT|LT]
Mono<Boolean>	expireat(A key, long epochSeconds)	EXPIREAT key timestamp
Mono<Boolean>	expireat(A key, Instant instant)	EXPIREAT key timestamp
Mono<Boolean>	expireat(A key, ZonedDateTime datetime)	EXPIREAT key timestamp
Mono<Long>	expiretime(A key)	EXPIRETIME key
Flux<A>	keys(A pattern)	KEYS pattern
RedisKeyReactiveOperations.KeyMigrateBuilder<A>	migrate()	MIGRATE host port key|"" destination-db timeout [COPY] [REPLACE] [AUTH password] [AUTH2 username password] [KEYS key [key ...]]
Mono<String>	migrate(String host, int port, A key, int db, long timeout)	MIGRATE host port key|"" destination-db timeout
Mono<Boolean>	move(A key, int db)	https://redis.io/commands/move key db
Mono<String>	objectEncoding(A key)	OBJECT ENCODING key
Mono<Long>	objectFreq(A key)	OBJECT FREQ key
Mono<Long>	objectIdletime(A key)	OBJECT IDLETIME key
Mono<Long>	objectRefcount(A key)	OBJECT REFCOUNT key
Mono<Boolean>	persist(A key)	PERSIST key
RedisKeyReactiveOperations.KeyPexpireBuilder<A>	pexpire()	PEXPIRE key milliseconds [NX|XX|GT|LT]
Mono<Boolean>	pexpire(A key, long milliseconds)	PEXPIRE key milliseconds [NX|XX|GT|LT]
Mono<Boolean>	pexpire(A key, Duration duration)	PEXPIRE key milliseconds [NX|XX|GT|LT]
RedisKeyReactiveOperations.KeyPexpireatBuilder<A>	pexpireat()	PEXPIREAT key milliseconds-timestamp [NX|XX|GT|LT]
Mono<Boolean>	pexpireat(A key, long epochMilliseconds)	PEXPIREAT key milliseconds-timestamp [NX|XX|GT|LT]
Mono<Boolean>	pexpireat(A key, Instant instant)	PEXPIREAT key milliseconds-timestamp [NX|XX|GT|LT]
Mono<Boolean>	pexpireat(A key, ZonedDateTime datetime)	PEXPIREAT key milliseconds-timestamp [NX|XX|GT|LT]
Mono<Long>	pexpiretime(A key)	PEXPIRETIME key
Mono<Long>	pttl(A key)	PTTL key
Mono<A>	randomkey()	RANDOMKEY
Mono<String>	rename(A key, A newkey)	RENAME key newkey
Mono<Boolean>	renamenx(A key, A newkey)	RENAMENX key newkey
RedisKeyReactiveOperations.KeyRestoreBuilder<A>	restore()	RESTORE key ttl serialized-value [REPLACE] [ABSTTL] [IDLETIME seconds] [FREQ frequency]
Mono<String>	restore(A key, long ttl, byte[] serializedValue)	RESTORE key ttl serialized-value [REPLACE] [ABSTTL] [IDLETIME seconds] [FREQ frequency]
RedisKeyReactiveOperations.KeyScanBuilder<A>	scan()	SCAN cursor [MATCH pattern] [COUNT count] [TYPE type]
Mono<RedisKeyReactiveOperations.KeyScanResult<A>>	scan(String cursor)	SCAN cursor [MATCH pattern] [COUNT count] [TYPE type]
RedisKeyReactiveOperations.KeySortBuilder<A,B>	sort()	SORT key [BY pattern] [LIMIT offset count] [GET pattern [GET pattern ...]]
Flux<B>	sort(A key)	SORT key [BY pattern] [LIMIT offset count] [GET pattern [GET pattern ...]]
RedisKeyReactiveOperations.KeySortStoreBuilder<A>	sortStore()	SORT key [BY pattern] [LIMIT offset count] [GET pattern [GET pattern ...]]
Mono<Long>	sortStore(A key, A destination)	SORT key [BY pattern] [LIMIT offset count] [GET pattern [GET pattern ...]]
Mono<Long>	touch(A key)	TOUCH key [key ...]
Mono<Long>	touch(Consumer<Keys<A>> keys)	TOUCH key [key ...]
Mono<Long>	ttl(A key)	TTL key
Mono<String>	type(A key)	TYPE key
Mono<Long>	unlink(A key)	UNLINK key [key ...]
Mono<Long>	unlink(Consumer<Keys<A>> keys)	UNLINK key [key ...]
Mono<Long>	waitForReplication(int replicas, long timeout)	WAIT numreplicas timeout

Method Details

copy

Mono<Boolean> copy(A source,
 A destination)

COPY source destination

Parameters:

source -

destination -

Returns:

copy

RedisKeyReactiveOperations.KeyCopyBuilder<A> copy()

COPY source destination [DB destination-db] [REPLACE]

Returns:

del

Mono<Long> del(A key)

DEL key

Parameters:

key -

Returns:

del

Mono<Long> del(Consumer<Keys<A>> keys)

DEL key [key ...]

Parameters:

keys -

Returns:

dump

Mono<byte[]> dump(A key)

DUMP key

Parameters:

key -

Returns:

exists

Mono<Long> exists(A key)

EXISTS key

Parameters:

key -

Returns:

exists

Mono<Long> exists(Consumer<Keys<A>> keys)

EXISTS key [key ...]

Parameters:

keys -

Returns:

expire

Mono<Boolean> expire(A key,
 long seconds)

EXPIRE key seconds

Parameters:

key -

seconds -

Returns:

expire

Mono<Boolean> expire(A key,
 Duration duration)

EXPIRE key seconds

Parameters:

key -

duration -

Returns:

expire

RedisKeyReactiveOperations.KeyExpireBuilder<A> expire()

EXPIRE key seconds [NX|XX|GT|LT]

Returns:

expireat

Mono<Boolean> expireat(A key,
 long epochSeconds)

EXPIREAT key timestamp

Parameters:

key -

epochSeconds -

Returns:

expireat

Mono<Boolean> expireat(A key,
 ZonedDateTime datetime)

EXPIREAT key timestamp

Parameters:

key -

datetime -

Returns:

expireat

Mono<Boolean> expireat(A key,
 Instant instant)

EXPIREAT key timestamp

Parameters:

key -

instant -

Returns:

expireat

RedisKeyReactiveOperations.KeyExpireatBuilder<A> expireat()

EXPIREAT key timestamp [NX|XX|GT|LT]

Returns:

expiretime

Mono<Long> expiretime(A key)

EXPIRETIME key

Parameters:

key -

Returns:

keys

Flux<A> keys(A pattern)

KEYS pattern

Parameters:

pattern -

Returns:

migrate

Mono<String> migrate(String host,
 int port,
 A key,
 int db,
 long timeout)

MIGRATE host port key|"" destination-db timeout

Parameters:

host -

port -

key -

db -

timeout -

Returns:

migrate

RedisKeyReactiveOperations.KeyMigrateBuilder<A> migrate()

MIGRATE host port key|"" destination-db timeout [COPY] [REPLACE] [AUTH password] [AUTH2 username password] [KEYS key [key ...]]

Returns:

move

Mono<Boolean> move(A key,
 int db)

https://redis.io/commands/move key db

Parameters:

key -

db -

Returns:

objectEncoding

Mono<String> objectEncoding(A key)

OBJECT ENCODING key

Parameters:

key -

Returns:

objectFreq

Mono<Long> objectFreq(A key)

OBJECT FREQ key

Parameters:

key -

Returns:

objectIdletime

Mono<Long> objectIdletime(A key)

OBJECT IDLETIME key

Parameters:

key -

Returns:

objectRefcount

Mono<Long> objectRefcount(A key)

OBJECT REFCOUNT key

Parameters:

key -

Returns:

persist

Mono<Boolean> persist(A key)

PERSIST key

Parameters:

key -

Returns:

pexpire

Mono<Boolean> pexpire(A key,
 long milliseconds)

PEXPIRE key milliseconds [NX|XX|GT|LT]

Parameters:

key -

milliseconds -

Returns:

pexpire

Mono<Boolean> pexpire(A key,
 Duration duration)

PEXPIRE key milliseconds [NX|XX|GT|LT]

Parameters:

key -

duration -

Returns:

pexpire

RedisKeyReactiveOperations.KeyPexpireBuilder<A> pexpire()

PEXPIRE key milliseconds [NX|XX|GT|LT]

Returns:

pexpireat

Mono<Boolean> pexpireat(A key,
 long epochMilliseconds)

PEXPIREAT key milliseconds-timestamp [NX|XX|GT|LT]

Parameters:

key -

epochMilliseconds -

Returns:

pexpireat

Mono<Boolean> pexpireat(A key,
 ZonedDateTime datetime)

PEXPIREAT key milliseconds-timestamp [NX|XX|GT|LT]

Parameters:

key -

datetime -

Returns:

pexpireat

Mono<Boolean> pexpireat(A key,
 Instant instant)

PEXPIREAT key milliseconds-timestamp [NX|XX|GT|LT]

Parameters:

key -

instant -

Returns:

pexpireat

RedisKeyReactiveOperations.KeyPexpireatBuilder<A> pexpireat()

PEXPIREAT key milliseconds-timestamp [NX|XX|GT|LT]

Returns:

pexpiretime

Mono<Long> pexpiretime(A key)

PEXPIRETIME key

Parameters:

key -

Returns:

pttl

Mono<Long> pttl(A key)

PTTL key

Parameters:

key -

Returns:

randomkey

Mono<A> randomkey()

RANDOMKEY

Returns:

rename

Mono<String> rename(A key,
 A newkey)

RENAME key newkey

Parameters:

key -

newkey -

Returns:

renamenx

Mono<Boolean> renamenx(A key,
 A newkey)

RENAMENX key newkey

Parameters:

key -

newkey -

Returns:

restore

Mono<String> restore(A key,
 long ttl,
 byte[] serializedValue)

RESTORE key ttl serialized-value [REPLACE] [ABSTTL] [IDLETIME seconds] [FREQ frequency]

Parameters:

key -

ttl -

serializedValue -

Returns:

restore

RedisKeyReactiveOperations.KeyRestoreBuilder<A> restore()

RESTORE key ttl serialized-value [REPLACE] [ABSTTL] [IDLETIME seconds] [FREQ frequency]

Returns:

scan

Mono<RedisKeyReactiveOperations.KeyScanResult<A>> scan(String cursor)

SCAN cursor [MATCH pattern] [COUNT count] [TYPE type]

Parameters:

cursor -

Returns:

scan

RedisKeyReactiveOperations.KeyScanBuilder<A> scan()

SCAN cursor [MATCH pattern] [COUNT count] [TYPE type]

Returns:

sort

Flux<B> sort(A key)

SORT key [BY pattern] [LIMIT offset count] [GET pattern [GET pattern ...]] [ASC|DESC] [ALPHA] [STORE destination]

Parameters:

key -

Returns:

sort

RedisKeyReactiveOperations.KeySortBuilder<A,B> sort()

SORT key [BY pattern] [LIMIT offset count] [GET pattern [GET pattern ...]] [ASC|DESC] [ALPHA] [STORE destination]

Returns:

sortStore

Mono<Long> sortStore(A key,
 A destination)

SORT key [BY pattern] [LIMIT offset count] [GET pattern [GET pattern ...]] [ASC|DESC] [ALPHA] [STORE destination]

Parameters:

key -

destination -

Returns:

sortStore

RedisKeyReactiveOperations.KeySortStoreBuilder<A> sortStore()

SORT key [BY pattern] [LIMIT offset count] [GET pattern [GET pattern ...]] [ASC|DESC] [ALPHA] [STORE destination]

Returns:

touch

Mono<Long> touch(A key)

TOUCH key [key ...]

Parameters:

key -

Returns:

touch

Mono<Long> touch(Consumer<Keys<A>> keys)

TOUCH key [key ...]

Parameters:

keys -

Returns:

ttl

Mono<Long> ttl(A key)

TTL key

Parameters:

key -

Returns:

type

Mono<String> type(A key)

TYPE key

Parameters:

key -

Returns:

unlink

Mono<Long> unlink(A key)

UNLINK key [key ...]

Parameters:

key -

Returns:

unlink

Mono<Long> unlink(Consumer<Keys<A>> keys)

UNLINK key [key ...]

Parameters:

keys -

Returns:

waitForReplication

Mono<Long> waitForReplication(int replicas,
 long timeout)

WAIT numreplicas timeout

Parameters:

replicas -

timeout -

Returns: