Module io.inverno.mod.redis

Package io.inverno.mod.redis.operations

Interface RedisStreamReactiveOperations.StreamXaddBuilder<A,B>

Type Parameters:

A - key type

B - value type

Enclosing interface:

RedisStreamReactiveOperations<A,B>

public static interface RedisStreamReactiveOperations.StreamXaddBuilder<A,B>

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

Since:

1.4

Author:

Jeremy Kuhn

Method Summary

Modifier and Type	Method	Description
RedisStreamReactiveOperations.StreamXaddBuilder<A,B>	approximate()
Mono<String>	build(A key, A field, B value)
Mono<String>	build(A key, Consumer<RedisStreamReactiveOperations.StreamEntries<A,B>> entries)
RedisStreamReactiveOperations.StreamXaddBuilder<A,B>	exact()
RedisStreamReactiveOperations.StreamXaddBuilder<A,B>	id(String id)
RedisStreamReactiveOperations.StreamXaddBuilder<A,B>	limit(long limit)
RedisStreamReactiveOperations.StreamXaddBuilder<A,B>	maxlen(long threshold)
RedisStreamReactiveOperations.StreamXaddBuilder<A,B>	minid(String minid)
RedisStreamReactiveOperations.StreamXaddBuilder<A,B>	nomkstream()

Method Details

nomkstream

RedisStreamReactiveOperations.StreamXaddBuilder<A,B> nomkstream()

Returns:

maxlen

RedisStreamReactiveOperations.StreamXaddBuilder<A,B> maxlen(long threshold)

Parameters:

threshold -

Returns:

minid

RedisStreamReactiveOperations.StreamXaddBuilder<A,B> minid(String minid)

Parameters:

minid -

Returns:

exact

RedisStreamReactiveOperations.StreamXaddBuilder<A,B> exact()

Returns:

approximate

RedisStreamReactiveOperations.StreamXaddBuilder<A,B> approximate()

Returns:

limit

RedisStreamReactiveOperations.StreamXaddBuilder<A,B> limit(long limit)

Parameters:

limit -

Returns:

id

RedisStreamReactiveOperations.StreamXaddBuilder<A,B> id(String id)

Parameters:

id -

Returns:

build

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

Parameters:

key -

field -

value -

Returns:

build

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

Parameters:

key -

entries -

Returns: