Module io.inverno.mod.redis

Package io.inverno.mod.redis.operations

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

Redis Streams reactive commands.

Since:

1.4

Author:

Jeremy Kuhn

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	RedisStreamReactiveOperations.StreamClaimedMessages<A,B>
static interface	RedisStreamReactiveOperations.StreamEntries<A,B>
static interface	RedisStreamReactiveOperations.StreamMessage<A,B>
static interface	RedisStreamReactiveOperations.StreamMessageIds
static interface	RedisStreamReactiveOperations.StreamPendingMessage
static interface	RedisStreamReactiveOperations.StreamPendingMessages
static interface	RedisStreamReactiveOperations.StreamStreams<A>
static interface	RedisStreamReactiveOperations.StreamXaddBuilder<A,B>	XADD key [NOMKSTREAM] [MAXLEN|MINID [=|~] threshold [LIMIT count]] *|id field value [field value ...]
static interface	RedisStreamReactiveOperations.StreamXautoclaimBuilder<A,B>	XAUTOCLAIM key group consumer min-idle-time start [COUNT count] [JUSTID]
static interface	RedisStreamReactiveOperations.StreamXclaimBuilder<A,B>	XCLAIM key group consumer min-idle-time id [id ...]
static interface	RedisStreamReactiveOperations.StreamXgroupCreateBuilder<A>	XGROUP CREATE key groupname id|$ [MKSTREAM]
static interface	RedisStreamReactiveOperations.StreamXpendingExtendedBuilder<A>	XPENDING key group [IDLE min-idle-time] start end count [consumer]
static interface	RedisStreamReactiveOperations.StreamXreadBuilder<A,B>	XREAD [COUNT count] [BLOCK milliseconds] STREAMS key [key ...] id [id ...]
static interface	RedisStreamReactiveOperations.StreamXreadgroupBuilder<A,B>	XREADGROUP GROUP group consumer [COUNT count] [BLOCK milliseconds] [NOACK] STREAMS key [key ...] id [id ...]
static interface	RedisStreamReactiveOperations.StreamXtrimBuilder<A>	XTRIM key MAXLEN|MINID [=|~] threshold [LIMIT count]

Method Summary

Modifier and Type	Method	Description
Mono<Long>	xack(A key, A group, String messageId)	XACK key group id
Mono<Long>	xack(A key, A group, Consumer<RedisStreamReactiveOperations.StreamMessageIds> messageIds)	XACK key group id [id ...]
RedisStreamReactiveOperations.StreamXaddBuilder<A,B>	xadd()	XADD key [NOMKSTREAM] [MAXLEN|MINID [=|~] threshold [LIMIT count]] *|id field value [field value ...]
Mono<String>	xadd(A key, A field, B value)	XADD key * field value
Mono<String>	xadd(A key, Consumer<RedisStreamReactiveOperations.StreamEntries<A,B>> entries)	XADD key * field value [field value ...]
RedisStreamReactiveOperations.StreamXautoclaimBuilder<A,B>	xautoclaim()	XAUTOCLAIM key group consumer min-idle-time start [COUNT count] [JUSTID]
Mono<RedisStreamReactiveOperations.StreamClaimedMessages<A,B>>	xautoclaim(A key, A group, A consumer, long minIdleTime, String start)	XAUTOCLAIM key group consumer min-idle-time start
RedisStreamReactiveOperations.StreamXclaimBuilder<A,B>	xclaim()	XCLAIM key group consumer min-idle-time id [id ...]
Flux<RedisStreamReactiveOperations.StreamMessage<A,B>>	xclaim(A key, A group, A consumer, long minIdleTime, String messageId)	XCLAIM key group consumer min-idle-time id
Flux<RedisStreamReactiveOperations.StreamMessage<A,B>>	xclaim(A key, A group, A consumer, long minIdleTime, Consumer<RedisStreamReactiveOperations.StreamMessageIds> messageIds)	XCLAIM key group consumer min-idle-time id [id ...]
Mono<Long>	xdel(A key, String messageId)	XDEL key id
Mono<Long>	xdel(A key, Consumer<RedisStreamReactiveOperations.StreamMessageIds> messageIds)	XDEL key id [id ...]
RedisStreamReactiveOperations.StreamXgroupCreateBuilder<A>	xgroupCreate()	XGROUP CREATE key groupname id|$ [MKSTREAM]
Mono<String>	xgroupCreate(A key, A group, String id)	XGROUP CREATE key groupname id|$
Mono<Boolean>	xgroupCreateconsumer(A key, A group, A consumer)	XGROUP CREATECONSUMER key groupname consumername
Mono<Long>	xgroupDelconsumer(A key, A group, A consumer)	XGROUP DELCONSUMER key groupname consumername
Mono<Boolean>	xgroupDestroy(A key, A group)	XGROUP DESTROY key groupname
Mono<String>	xgroupSetid(A key, A group, String id)	XGROUP SETID key groupname id|$
Flux<Object>	xinfoConsumers(A key, A group)	XINFO CONSUMERS key groupname
Flux<Object>	xinfoGroups(A key)	XINFO GROUPS key
Flux<Object>	xinfoStream(A key)	XINFO STREAM key
Flux<Object>	xinfoStreamFull(A key)	XINFO STREAM key FULL
Flux<Object>	xinfoStreamFull(A key, long count)	XINFO STREAM key FULL COUNT count
Mono<Long>	xlen(A key)	XLEN key
Mono<RedisStreamReactiveOperations.StreamPendingMessages>	xpending(A key, A group)	XPENDING key group [[IDLE min-idle-time] start end count [consumer]]
RedisStreamReactiveOperations.StreamXpendingExtendedBuilder<A>	xpendingExtended()	XPENDING key group [[IDLE min-idle-time] start end count [consumer]]
Flux<RedisStreamReactiveOperations.StreamPendingMessage>	xpendingExtended(A key, A group, String start, String end, long count)	XPENDING key group [[IDLE min-idle-time] start end count [consumer]]
Flux<RedisStreamReactiveOperations.StreamMessage<A,B>>	xrange(A key, String start, String end)	XRANGE key start end
Flux<RedisStreamReactiveOperations.StreamMessage<A,B>>	xrange(A key, String start, String end, long count)	XRANGE key start end [COUNT count]
RedisStreamReactiveOperations.StreamXreadBuilder<A,B>	xread()	XREAD [COUNT count] [BLOCK milliseconds] STREAMS key [key ...] id [id ...]
Flux<RedisStreamReactiveOperations.StreamMessage<A,B>>	xread(A key, String messageId)	XREAD STREAMS key id
Flux<RedisStreamReactiveOperations.StreamMessage<A,B>>	xread(Consumer<RedisStreamReactiveOperations.StreamStreams<A>> streams)	XREAD STREAMS key [key ...] id [id ...]
RedisStreamReactiveOperations.StreamXreadgroupBuilder<A,B>	xreadgroup()	XREADGROUP GROUP group consumer [COUNT count] [BLOCK milliseconds] [NOACK] STREAMS key [key ...] id [id ...]
Flux<RedisStreamReactiveOperations.StreamMessage<A,B>>	xreadgroup(A group, A consumer, A key, String messageId)	XREADGROUP GROUP group consumer STREAMS key id
Flux<RedisStreamReactiveOperations.StreamMessage<A,B>>	xreadgroup(A group, A consumer, Consumer<RedisStreamReactiveOperations.StreamStreams<A>> streams)	XREADGROUP GROUP group consumer STREAMS key [key ...] id [id ...]
Flux<RedisStreamReactiveOperations.StreamMessage<A,B>>	xrevrange(A key, String start, String end)	XREVRANGE key end start
Flux<RedisStreamReactiveOperations.StreamMessage<A,B>>	xrevrange(A key, String start, String end, long count)	XREVRANGE key end start COUNT count
RedisStreamReactiveOperations.StreamXtrimBuilder<A>	xtrim()	XTRIM key MAXLEN|MINID [=|~] threshold [LIMIT count]
Mono<Long>	xtrimMaxLen(A key, long threshold)	XTRIM key MAXLEN threshold
Mono<Long>	xtrimMaxLen(A key, long threshold, long count)	XTRIM key MAXLEN threshold LIMIT count
Mono<Long>	xtrimMinId(A key, String streamId)	XTRIM key MINID streamId
Mono<Long>	xtrimMinId(A key, String streamId, long count)	XTRIM key MINID threshold LIMIT count

Method Details

xack

Mono<Long> xack(A key,
 A group,
 String messageId)

XACK key group id

Parameters:

key -

group -

messageId -

Returns:

xack

Mono<Long> xack(A key,
 A group,
 Consumer<RedisStreamReactiveOperations.StreamMessageIds> messageIds)

XACK key group id [id ...]

Parameters:

key -

group -

messageIds -

Returns:

xadd

Mono<String> xadd(A key,
 A field,
 B value)

XADD key * field value

Parameters:

key -

field -

value -

Returns:

xadd

Mono<String> xadd(A key,
 Consumer<RedisStreamReactiveOperations.StreamEntries<A,B>> entries)

XADD key * field value [field value ...]

Parameters:

key -

entries -

Returns:

xadd

RedisStreamReactiveOperations.StreamXaddBuilder<A,B> xadd()

XADD key [NOMKSTREAM] [MAXLEN|MINID [=|~] threshold [LIMIT count]] *|id field value [field value ...]

Returns:

xautoclaim

Mono<RedisStreamReactiveOperations.StreamClaimedMessages<A,B>> xautoclaim(A key,
 A group,
 A consumer,
 long minIdleTime,
 String start)

XAUTOCLAIM key group consumer min-idle-time start

Parameters:

key -

group -

consumer -

minIdleTime -

start -

Returns:

xautoclaim

RedisStreamReactiveOperations.StreamXautoclaimBuilder<A,B> xautoclaim()

XAUTOCLAIM key group consumer min-idle-time start [COUNT count] [JUSTID]

Returns:

xclaim

Flux<RedisStreamReactiveOperations.StreamMessage<A,B>> xclaim(A key,
 A group,
 A consumer,
 long minIdleTime,
 String messageId)

XCLAIM key group consumer min-idle-time id

Parameters:

key -

group -

consumer -

minIdleTime -

messageId -

Returns:

xclaim

Flux<RedisStreamReactiveOperations.StreamMessage<A,B>> xclaim(A key,
 A group,
 A consumer,
 long minIdleTime,
 Consumer<RedisStreamReactiveOperations.StreamMessageIds> messageIds)

XCLAIM key group consumer min-idle-time id [id ...]

Parameters:

key -

group -

consumer -

minIdleTime -

messageIds -

Returns:

xclaim

RedisStreamReactiveOperations.StreamXclaimBuilder<A,B> xclaim()

XCLAIM key group consumer min-idle-time id [id ...] [IDLE ms] [TIME ms-unix-time] [RETRYCOUNT count] [FORCE] [JUSTID]

Returns:

xdel

Mono<Long> xdel(A key,
 String messageId)

XDEL key id

Parameters:

key -

messageId -

Returns:

xdel

Mono<Long> xdel(A key,
 Consumer<RedisStreamReactiveOperations.StreamMessageIds> messageIds)

XDEL key id [id ...]

Parameters:

key -

messageIds -

Returns:

xgroupCreate

Mono<String> xgroupCreate(A key,
 A group,
 String id)

XGROUP CREATE key groupname id|$

Parameters:

key -

group -

id -

Returns:

xgroupCreate

RedisStreamReactiveOperations.StreamXgroupCreateBuilder<A> xgroupCreate()

XGROUP CREATE key groupname id|$ [MKSTREAM]

Returns:

xgroupCreateconsumer

Mono<Boolean> xgroupCreateconsumer(A key,
 A group,
 A consumer)

XGROUP CREATECONSUMER key groupname consumername

Parameters:

key -

group -

consumer -

Returns:

xgroupDelconsumer

Mono<Long> xgroupDelconsumer(A key,
 A group,
 A consumer)

XGROUP DELCONSUMER key groupname consumername

Parameters:

key -

group -

consumer -

Returns:

xgroupDestroy

Mono<Boolean> xgroupDestroy(A key,
 A group)

XGROUP DESTROY key groupname

Parameters:

key -

group -

Returns:

xgroupSetid

Mono<String> xgroupSetid(A key,
 A group,
 String id)

XGROUP SETID key groupname id|$

Parameters:

key -

group -

id -

Returns:

xinfoConsumers

Flux<Object> xinfoConsumers(A key,
 A group)

XINFO CONSUMERS key groupname

Parameters:

key -

group -

Returns:

xinfoGroups

Flux<Object> xinfoGroups(A key)

XINFO GROUPS key

Parameters:

key -

Returns:

xinfoStream

Flux<Object> xinfoStream(A key)

XINFO STREAM key

Parameters:

key -

Returns:

xinfoStreamFull

Flux<Object> xinfoStreamFull(A key)

XINFO STREAM key FULL

Parameters:

key -

Returns:

xinfoStreamFull

Flux<Object> xinfoStreamFull(A key,
 long count)

XINFO STREAM key FULL COUNT count

Parameters:

key -

count -

Returns:

xlen

Mono<Long> xlen(A key)

XLEN key

Parameters:

key -

Returns:

xpending

Mono<RedisStreamReactiveOperations.StreamPendingMessages> xpending(A key,
 A group)

XPENDING key group [[IDLE min-idle-time] start end count [consumer]]

Parameters:

key -

group -

Returns:

xpendingExtended

Flux<RedisStreamReactiveOperations.StreamPendingMessage> xpendingExtended(A key,
 A group,
 String start,
 String end,
 long count)

XPENDING key group [[IDLE min-idle-time] start end count [consumer]]

Parameters:

key -

group -

start -

end -

count -

Returns:

xpendingExtended

RedisStreamReactiveOperations.StreamXpendingExtendedBuilder<A> xpendingExtended()

XPENDING key group [[IDLE min-idle-time] start end count [consumer]]

Returns:

xrange

Flux<RedisStreamReactiveOperations.StreamMessage<A,B>> xrange(A key,
 String start,
 String end)

XRANGE key start end

Parameters:

key -

start -

end -

Returns:

xrange

Flux<RedisStreamReactiveOperations.StreamMessage<A,B>> xrange(A key,
 String start,
 String end,
 long count)

XRANGE key start end [COUNT count]

Parameters:

key -

start -

end -

count -

Returns:

xread

Flux<RedisStreamReactiveOperations.StreamMessage<A,B>> xread(A key,
 String messageId)

XREAD STREAMS key id

Parameters:

key -

messageId -

Returns:

xread

Flux<RedisStreamReactiveOperations.StreamMessage<A,B>> xread(Consumer<RedisStreamReactiveOperations.StreamStreams<A>> streams)

XREAD STREAMS key [key ...] id [id ...]

Parameters:

streams -

Returns:

xread

RedisStreamReactiveOperations.StreamXreadBuilder<A,B> xread()

XREAD [COUNT count] [BLOCK milliseconds] STREAMS key [key ...] id [id ...]

Returns:

xreadgroup

Flux<RedisStreamReactiveOperations.StreamMessage<A,B>> xreadgroup(A group,
 A consumer,
 A key,
 String messageId)

XREADGROUP GROUP group consumer STREAMS key id

Parameters:

group -

consumer -

key -

messageId -

Returns:

xreadgroup

Flux<RedisStreamReactiveOperations.StreamMessage<A,B>> xreadgroup(A group,
 A consumer,
 Consumer<RedisStreamReactiveOperations.StreamStreams<A>> streams)

XREADGROUP GROUP group consumer STREAMS key [key ...] id [id ...]

Parameters:

group -

consumer -

streams -

Returns:

xreadgroup

RedisStreamReactiveOperations.StreamXreadgroupBuilder<A,B> xreadgroup()

XREADGROUP GROUP group consumer [COUNT count] [BLOCK milliseconds] [NOACK] STREAMS key [key ...] id [id ...]

Returns:

xrevrange

Flux<RedisStreamReactiveOperations.StreamMessage<A,B>> xrevrange(A key,
 String start,
 String end)

XREVRANGE key end start

Parameters:

key -

start -

end -

Returns:

xrevrange

Flux<RedisStreamReactiveOperations.StreamMessage<A,B>> xrevrange(A key,
 String start,
 String end,
 long count)

XREVRANGE key end start COUNT count

Parameters:

key -

start -

end -

count -

Returns:

xtrimMaxLen

Mono<Long> xtrimMaxLen(A key,
 long threshold)

XTRIM key MAXLEN threshold

Parameters:

key -

threshold -

Returns:

xtrimMaxLen

Mono<Long> xtrimMaxLen(A key,
 long threshold,
 long count)

XTRIM key MAXLEN threshold LIMIT count

Parameters:

key -

threshold -

count -

Returns:

xtrimMinId

Mono<Long> xtrimMinId(A key,
 String streamId)

XTRIM key MINID streamId

Parameters:

key -

streamId -

Returns:

xtrimMinId

Mono<Long> xtrimMinId(A key,
 String streamId,
 long count)

XTRIM key MINID threshold LIMIT count

Parameters:

key -

streamId -

count -

Returns:

xtrim

RedisStreamReactiveOperations.StreamXtrimBuilder<A> xtrim()

XTRIM key MAXLEN|MINID [=|~] threshold [LIMIT count]

Returns: