Module io.inverno.mod.redis

Package io.inverno.mod.redis.operations

Interface RedisListReactiveOperations<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 RedisListReactiveOperations<A,B>

Redis Lists reactive commands.

Since:

1.4

Author:

Jeremy Kuhn

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	RedisListReactiveOperations.AbstractListLmoveBuilder<A,B,C extends RedisListReactiveOperations.AbstractListLmoveBuilder<A,B,C>>	BLMOVE source destination LEFT|RIGHT LEFT|RIGHT timeout LMOVE source destination LEFT|RIGHT LEFT|RIGHT
static interface	RedisListReactiveOperations.AbstractListLmpopBuilder<A,B,C extends RedisListReactiveOperations.AbstractListLmpopBuilder<A,B,C>>	BLMPOP timeout numkeys key [key ...]
static interface	RedisListReactiveOperations.ListBlmoveBuilder<A,B>	BLMOVE source destination LEFT|RIGHT LEFT|RIGHT timeout
static interface	RedisListReactiveOperations.ListBlmpopBuilder<A,B>	BLMPOP timeout numkeys key [key ...]
static interface	RedisListReactiveOperations.ListLmoveBuilder<A,B>	LMOVE source destination LEFT|RIGHT LEFT|RIGHT
static interface	RedisListReactiveOperations.ListLmpopBuilder<A,B>	LMPOP numkeys key [key ...]
static interface	RedisListReactiveOperations.ListLposBuilder<A,B>	LPOS key element [RANK rank] [COUNT num-matches] [MAXLEN len]

Method Summary

Modifier and Type	Method	Description
RedisListReactiveOperations.ListBlmoveBuilder<A,B>	blmove()	BLMOVE source destination LEFT|RIGHT LEFT|RIGHT timeout
RedisListReactiveOperations.ListBlmpopBuilder<A,B>	blmpop()	BLMPOP timeout numkeys key [key ...]
Mono<EntryOptional<A,B>>	blpop(A key, double timeout)	BLPOP key timeout
Mono<EntryOptional<A,B>>	blpop(Consumer<Keys<A>> keys, double timeout)	BLPOP key [key ...] timeout
Mono<EntryOptional<A,B>>	brpop(A key, double timeout)	BRPOP key timeout
Mono<EntryOptional<A,B>>	brpop(Consumer<Keys<A>> keys, double timeout)	BRPOP key [key ...] timeout
Mono<B>	brpoplpush(A source, A destination, double timeout)	BRPOPLPUSH source destination timeout
Mono<B>	lindex(A key, long index)	LINDEX key index
Mono<Long>	linsert(A key, boolean before, B pivot, B element)	LINSERT key BEFORE|AFTER pivot element
Mono<Long>	llen(A key)	LLEN key
RedisListReactiveOperations.ListLmoveBuilder<A,B>	lmove()	LMOVE source destination LEFT|RIGHT LEFT|RIGHT
RedisListReactiveOperations.ListLmpopBuilder<A,B>	lmpop()	LMPOP numkeys key [key ...]
Mono<B>	lpop(A key)	LPOP key
Flux<B>	lpop(A key, long count)	LPOP key [count]
RedisListReactiveOperations.ListLposBuilder<A,B>	lpos()	LPOS key element [RANK rank] [COUNT num-matches] [MAXLEN len]
Mono<Long>	lpos(A key, B element)	LPOS key element
Flux<Long>	lpos(A key, B element, long count)	LPOS key element [COUNT num-matches]
Mono<Long>	lpush(A key, B element)	LPUSH key element
Mono<Long>	lpush(A key, Consumer<Values<B>> elements)	LPUSH key element [element ...]
Mono<Long>	lpushx(A key, B element)	LPUSHX key element
Mono<Long>	lpushx(A key, Consumer<Values<B>> elements)	LPUSHX key element [element ...]
Flux<B>	lrange(A key, long start, long stop)	LRANGE key start stop
Mono<Long>	lrem(A key, long count, B element)	LREM key count element
Mono<String>	lset(A key, long index, B element)	LSET key index element
Mono<String>	ltrim(A key, long start, long stop)	LTRIM key start stop
Mono<B>	rpop(A key)	RPOP key
Flux<B>	rpop(A key, long count)	RPOP key [count]
Mono<B>	rpoplpush(A source, A destination)	RPOPLPUSH source destination
Mono<Long>	rpush(A key, B element)	RPUSH key element [element ...]
Mono<Long>	rpush(A key, Consumer<Values<B>> elements)	RPUSH key element [element ...]
Mono<Long>	rpushx(A key, B element)	RPUSHX key element [element ...]
Mono<Long>	rpushx(A key, Consumer<Values<B>> elements)	RPUSHX key element [element ...]

Method Details

blmove

RedisListReactiveOperations.ListBlmoveBuilder<A,B> blmove()

BLMOVE source destination LEFT|RIGHT LEFT|RIGHT timeout

Returns:

blmpop

RedisListReactiveOperations.ListBlmpopBuilder<A,B> blmpop()

BLMPOP timeout numkeys key [key ...] LEFT|RIGHT [COUNT count]

Returns:

blpop

Mono<EntryOptional<A,B>> blpop(A key,
 double timeout)

BLPOP key timeout

Parameters:

key -

timeout -

Returns:

blpop

Mono<EntryOptional<A,B>> blpop(Consumer<Keys<A>> keys,
 double timeout)

BLPOP key [key ...] timeout

Parameters:

keys -

timeout -

Returns:

brpop

Mono<EntryOptional<A,B>> brpop(A key,
 double timeout)

BRPOP key timeout

Parameters:

key -

timeout -

Returns:

brpop

Mono<EntryOptional<A,B>> brpop(Consumer<Keys<A>> keys,
 double timeout)

BRPOP key [key ...] timeout

Parameters:

keys -

timeout -

Returns:

brpoplpush

Mono<B> brpoplpush(A source,
 A destination,
 double timeout)

BRPOPLPUSH source destination timeout

Parameters:

source -

destination -

timeout -

Returns:

lindex

Mono<B> lindex(A key,
 long index)

LINDEX key index

Parameters:

key -

index -

Returns:

linsert

Mono<Long> linsert(A key,
 boolean before,
 B pivot,
 B element)

LINSERT key BEFORE|AFTER pivot element

Parameters:

key -

before -

pivot -

element -

Returns:

llen

Mono<Long> llen(A key)

LLEN key

Parameters:

key -

Returns:

lmove

RedisListReactiveOperations.ListLmoveBuilder<A,B> lmove()

LMOVE source destination LEFT|RIGHT LEFT|RIGHT

Returns:

lmpop

RedisListReactiveOperations.ListLmpopBuilder<A,B> lmpop()

LMPOP numkeys key [key ...] LEFT|RIGHT [COUNT count]

Returns:

lpop

Mono<B> lpop(A key)

LPOP key

Parameters:

key -

Returns:

lpop

Flux<B> lpop(A key,
 long count)

LPOP key [count]

Parameters:

key -

count -

Returns:

lpos

Mono<Long> lpos(A key,
 B element)

LPOS key element

Parameters:

key -

element -

Returns:

lpos

Flux<Long> lpos(A key,
 B element,
 long count)

LPOS key element [COUNT num-matches]

Parameters:

key -

element -

count -

Returns:

lpos

RedisListReactiveOperations.ListLposBuilder<A,B> lpos()

LPOS key element [RANK rank] [COUNT num-matches] [MAXLEN len]

Returns:

lpush

Mono<Long> lpush(A key,
 B element)

LPUSH key element

Parameters:

key -

element -

Returns:

lpush

Mono<Long> lpush(A key,
 Consumer<Values<B>> elements)

LPUSH key element [element ...]

Parameters:

key -

elements -

Returns:

lpushx

Mono<Long> lpushx(A key,
 B element)

LPUSHX key element

Parameters:

key -

element -

Returns:

lpushx

Mono<Long> lpushx(A key,
 Consumer<Values<B>> elements)

LPUSHX key element [element ...]

Parameters:

key -

elements -

Returns:

lrange

Flux<B> lrange(A key,
 long start,
 long stop)

LRANGE key start stop

Parameters:

key -

start -

stop -

Returns:

lrem

Mono<Long> lrem(A key,
 long count,
 B element)

LREM key count element

Parameters:

key -

count -

element -

Returns:

lset

Mono<String> lset(A key,
 long index,
 B element)

LSET key index element

Parameters:

key -

index -

element -

Returns:

ltrim

Mono<String> ltrim(A key,
 long start,
 long stop)

LTRIM key start stop

Parameters:

key -

start -

stop -

Returns:

rpop

Mono<B> rpop(A key)

RPOP key

Parameters:

key -

Returns:

rpop

Flux<B> rpop(A key,
 long count)

RPOP key [count]

Parameters:

key -

count -

Returns:

rpoplpush

Mono<B> rpoplpush(A source,
 A destination)

RPOPLPUSH source destination

Parameters:

source -

destination -

Returns:

rpush

Mono<Long> rpush(A key,
 B element)

RPUSH key element [element ...]

Parameters:

key -

element -

Returns:

rpush

Mono<Long> rpush(A key,
 Consumer<Values<B>> elements)

RPUSH key element [element ...]

Parameters:

key -

elements -

Returns:

rpushx

Mono<Long> rpushx(A key,
 B element)

RPUSHX key element [element ...]

Parameters:

key -

element -

Returns:

rpushx

Mono<Long> rpushx(A key,
 Consumer<Values<B>> elements)

RPUSHX key element [element ...]

Parameters:

key -

elements -

Returns: