public interface ReactiveStreamCommands
Modifier and Type | Interface and Description |
---|---|
static class |
ReactiveStreamCommands.AcknowledgeCommand
XACK command parameters. |
static class |
ReactiveStreamCommands.AddStreamRecord
XADD command parameters. |
static class |
ReactiveStreamCommands.DeleteCommand
XDEL command parameters. |
static class |
ReactiveStreamCommands.GroupCommand |
static class |
ReactiveStreamCommands.RangeCommand
XRANGE /XREVRANGE command parameters. |
static class |
ReactiveStreamCommands.ReadCommand
XRANGE /XREVRANGE command parameters. |
static class |
ReactiveStreamCommands.TrimCommand
XTRIM command parameters. |
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.ReadCommand,reactor.core.publisher.Flux<ByteBufferRecord>>> |
read(org.reactivestreams.Publisher<ReactiveStreamCommands.ReadCommand> commands)
Read records from one or more
StreamOffset s. |
default reactor.core.publisher.Mono<Long> |
xAck(ByteBuffer key,
String group,
RecordId... recordIds)
Acknowledge one or more records as processed.
|
default reactor.core.publisher.Mono<Long> |
xAck(ByteBuffer key,
String group,
String... recordIds)
Acknowledge one or more records as processed.
|
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveStreamCommands.AcknowledgeCommand,Long>> |
xAck(org.reactivestreams.Publisher<ReactiveStreamCommands.AcknowledgeCommand> commands)
Acknowledge one or more records as processed.
|
default reactor.core.publisher.Mono<RecordId> |
xAdd(ByteBuffer key,
Map<ByteBuffer,ByteBuffer> body)
Add stream record with given body to key.
|
default reactor.core.publisher.Mono<RecordId> |
xAdd(ByteBufferRecord record)
Add stream record with given body to key.
|
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.AddStreamRecord,RecordId>> |
xAdd(org.reactivestreams.Publisher<ReactiveStreamCommands.AddStreamRecord> commands)
Add stream record with given body to key.
|
default reactor.core.publisher.Mono<Long> |
xDel(ByteBuffer key,
RecordId... recordIds)
Removes the specified entries from the stream.
|
default reactor.core.publisher.Mono<Long> |
xDel(ByteBuffer key,
String... recordIds)
Removes the specified entries from the stream.
|
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.DeleteCommand,Long>> |
xDel(org.reactivestreams.Publisher<ReactiveStreamCommands.DeleteCommand> commands)
Removes the specified entries from the stream.
|
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.GroupCommand,String>> |
xGroup(org.reactivestreams.Publisher<ReactiveStreamCommands.GroupCommand> commands)
Execute the given
ReactiveStreamCommands.GroupCommand to create, destroy,... groups. |
default reactor.core.publisher.Mono<String> |
xGroup(ReactiveStreamCommands.GroupCommand command)
Execute the given
ReactiveStreamCommands.GroupCommand to create, destroy,... groups. |
default reactor.core.publisher.Mono<String> |
xGroupCreate(ByteBuffer key,
String groupName,
ReadOffset readOffset)
Create a consumer group.
|
default reactor.core.publisher.Mono<String> |
xGroupDelConsumer(ByteBuffer key,
Consumer consumer)
Delete a consumer from a consumer group.
|
default reactor.core.publisher.Mono<String> |
xGroupDelConsumer(ByteBuffer key,
String groupName,
String consumerName)
Delete a consumer from a consumer group.
|
default reactor.core.publisher.Mono<String> |
xGroupDestroy(ByteBuffer key,
String groupName)
Destroy a consumer group.
|
default reactor.core.publisher.Mono<Long> |
xLen(ByteBuffer key)
Get the size of the stream stored at key.
|
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>> |
xLen(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands)
Get the size of the stream stored at
ReactiveRedisConnection.KeyCommand.getKey() |
default reactor.core.publisher.Flux<ByteBufferRecord> |
xRange(ByteBuffer key,
Range<String> range)
Read records from a stream within a specific
Range . |
default reactor.core.publisher.Flux<ByteBufferRecord> |
xRange(ByteBuffer key,
Range<String> range,
RedisZSetCommands.Limit limit)
Read records from a stream within a specific
Range applying a RedisZSetCommands.Limit . |
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.RangeCommand,reactor.core.publisher.Flux<ByteBufferRecord>>> |
xRange(org.reactivestreams.Publisher<ReactiveStreamCommands.RangeCommand> commands)
Read records from a stream within a specific
Range applying a RedisZSetCommands.Limit . |
default reactor.core.publisher.Flux<ByteBufferRecord> |
xRead(StreamOffset<ByteBuffer>... streams)
Read records from one or more
StreamOffset s. |
default reactor.core.publisher.Flux<ByteBufferRecord> |
xRead(StreamReadOptions readOptions,
StreamOffset<ByteBuffer>... streams)
Read records from one or more
StreamOffset s. |
default reactor.core.publisher.Flux<ByteBufferRecord> |
xReadGroup(Consumer consumer,
StreamOffset<ByteBuffer>... streams)
Read records from one or more
StreamOffset s using a consumer group. |
default reactor.core.publisher.Flux<ByteBufferRecord> |
xReadGroup(Consumer consumer,
StreamReadOptions readOptions,
StreamOffset<ByteBuffer>... streams)
Read records from one or more
StreamOffset s using a consumer group. |
default reactor.core.publisher.Flux<ByteBufferRecord> |
xRevRange(ByteBuffer key,
Range<String> range)
Read records from a stream within a specific
Range in reverse order. |
default reactor.core.publisher.Flux<ByteBufferRecord> |
xRevRange(ByteBuffer key,
Range<String> range,
RedisZSetCommands.Limit limit)
Read records from a stream within a specific
Range applying a RedisZSetCommands.Limit in reverse order. |
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.RangeCommand,reactor.core.publisher.Flux<ByteBufferRecord>>> |
xRevRange(org.reactivestreams.Publisher<ReactiveStreamCommands.RangeCommand> commands)
Read records from a stream within a specific
Range applying a RedisZSetCommands.Limit in reverse order. |
default reactor.core.publisher.Mono<Long> |
xTrim(ByteBuffer key,
long count)
Trims the stream to
count elements. |
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>> |
xTrim(org.reactivestreams.Publisher<ReactiveStreamCommands.TrimCommand> commands)
Trims the stream to
count elements. |
default reactor.core.publisher.Mono<Long> xAck(ByteBuffer key, String group, String... recordIds)
key
- the stream key.group
- name of the consumer group.recordIds
- record Id's to acknowledge.Mono
emitting the nr of acknowledged messages.default reactor.core.publisher.Mono<Long> xAck(ByteBuffer key, String group, RecordId... recordIds)
key
- the stream key.group
- name of the consumer group.recordIds
- record Id's to acknowledge.Mono
emitting the nr of acknowledged messages.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveStreamCommands.AcknowledgeCommand,Long>> xAck(org.reactivestreams.Publisher<ReactiveStreamCommands.AcknowledgeCommand> commands)
commands
- must not be null.Flux
emitting the nr of acknowledged messages per ReactiveStreamCommands.AcknowledgeCommand
.default reactor.core.publisher.Mono<RecordId> xAdd(ByteBuffer key, Map<ByteBuffer,ByteBuffer> body)
key
- must not be null.body
- must not be null.Mono
emitting the server generated id
.default reactor.core.publisher.Mono<RecordId> xAdd(ByteBufferRecord record)
record
- must not be null.Mono
the id
.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.AddStreamRecord,RecordId>> xAdd(org.reactivestreams.Publisher<ReactiveStreamCommands.AddStreamRecord> commands)
commands
- must not be null.Flux
emitting the RecordId
on by for for the given ReactiveStreamCommands.AddStreamRecord
commands.default reactor.core.publisher.Mono<Long> xDel(ByteBuffer key, String... recordIds)
key
- the stream key.recordIds
- stream record Id's.Mono
emitting the number of removed entries.default reactor.core.publisher.Mono<Long> xDel(ByteBuffer key, RecordId... recordIds)
key
- the stream key.recordIds
- stream record Id's.Mono
emitting the number of removed entries.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.DeleteCommand,Long>> xDel(org.reactivestreams.Publisher<ReactiveStreamCommands.DeleteCommand> commands)
commands
- must not be null.Mono
emitting the number of removed entries.default reactor.core.publisher.Mono<Long> xLen(ByteBuffer key)
key
- must not be null.Mono
emitting the length of the stream.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>> xLen(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands)
ReactiveRedisConnection.KeyCommand.getKey()
commands
- must not be null.Flux
emitting the length of the stream per ReactiveRedisConnection.KeyCommand
.default reactor.core.publisher.Flux<ByteBufferRecord> xRange(ByteBuffer key, Range<String> range)
Range
.key
- the stream key.range
- must not be null.Flux
emitting with members of the stream.default reactor.core.publisher.Flux<ByteBufferRecord> xRange(ByteBuffer key, Range<String> range, RedisZSetCommands.Limit limit)
Range
applying a RedisZSetCommands.Limit
.key
- the stream key.range
- must not be null.limit
- must not be null.Flux
emitting with members of the stream.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.RangeCommand,reactor.core.publisher.Flux<ByteBufferRecord>>> xRange(org.reactivestreams.Publisher<ReactiveStreamCommands.RangeCommand> commands)
Range
applying a RedisZSetCommands.Limit
.commands
- must not be null.Flux
emitting with members of the stream per ReactiveStreamCommands.RangeCommand
.default reactor.core.publisher.Flux<ByteBufferRecord> xRead(StreamOffset<ByteBuffer>... streams)
StreamOffset
s.streams
- the streams to read from.Flux
emitting with members of the stream.default reactor.core.publisher.Flux<ByteBufferRecord> xRead(StreamReadOptions readOptions, StreamOffset<ByteBuffer>... streams)
StreamOffset
s.readOptions
- read arguments.streams
- the streams to read from.Flux
emitting with members of the stream.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.ReadCommand,reactor.core.publisher.Flux<ByteBufferRecord>>> read(org.reactivestreams.Publisher<ReactiveStreamCommands.ReadCommand> commands)
StreamOffset
s.commands
- must not be null.Flux
emitting the members of the stream per ReactiveStreamCommands.ReadCommand
.default reactor.core.publisher.Mono<String> xGroupCreate(ByteBuffer key, String groupName, ReadOffset readOffset)
key
- key the key the stream is stored at.groupName
- name of the consumer group to create.readOffset
- the offset to start at.Mono
emitting ok if successful.@Nullable default reactor.core.publisher.Mono<String> xGroupDelConsumer(ByteBuffer key, String groupName, String consumerName)
key
- the key the stream is stored at.groupName
- the name of the group to remove the consumer from.consumerName
- the name of the consumer to remove from the group.Mono
emitting ok if successful.default reactor.core.publisher.Mono<String> xGroupDelConsumer(ByteBuffer key, Consumer consumer)
key
- the key the stream is stored at.consumer
- the Consumer
.Mono
emitting ok if successful.@Nullable default reactor.core.publisher.Mono<String> xGroupDestroy(ByteBuffer key, String groupName)
key
- the key the stream is stored at.groupName
- name of the consumer group.Mono
emitting ok if successful.default reactor.core.publisher.Mono<String> xGroup(ReactiveStreamCommands.GroupCommand command)
ReactiveStreamCommands.GroupCommand
to create, destroy,... groups.command
- the ReactiveStreamCommands.GroupCommand
to run.Mono
emitting the command result.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.GroupCommand,String>> xGroup(org.reactivestreams.Publisher<ReactiveStreamCommands.GroupCommand> commands)
ReactiveStreamCommands.GroupCommand
to create, destroy,... groups.commands
- Flux
emitting the results of the ReactiveStreamCommands.GroupCommand
one by one.default reactor.core.publisher.Flux<ByteBufferRecord> xReadGroup(Consumer consumer, StreamOffset<ByteBuffer>... streams)
StreamOffset
s using a consumer group.consumer
- consumer/group.streams
- the streams to read from.Flux
emitting the members of the streamdefault reactor.core.publisher.Flux<ByteBufferRecord> xReadGroup(Consumer consumer, StreamReadOptions readOptions, StreamOffset<ByteBuffer>... streams)
StreamOffset
s using a consumer group.consumer
- consumer/group.readOptions
- read arguments.streams
- the streams to read from.Flux
emitting the members of the stream.default reactor.core.publisher.Flux<ByteBufferRecord> xRevRange(ByteBuffer key, Range<String> range)
Range
in reverse order.key
- the stream key.range
- must not be null.Flux
emitting the members of the stream in reverse.default reactor.core.publisher.Flux<ByteBufferRecord> xRevRange(ByteBuffer key, Range<String> range, RedisZSetCommands.Limit limit)
Range
applying a RedisZSetCommands.Limit
in reverse order.key
- the stream key.range
- must not be null.limit
- must not be null.Flux
emitting the members of the stream in reverse.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.RangeCommand,reactor.core.publisher.Flux<ByteBufferRecord>>> xRevRange(org.reactivestreams.Publisher<ReactiveStreamCommands.RangeCommand> commands)
Range
applying a RedisZSetCommands.Limit
in reverse order.commands
- must not be null.Flux
emitting the members of the stream in reverse.default reactor.core.publisher.Mono<Long> xTrim(ByteBuffer key, long count)
count
elements.key
- the stream key.count
- length of the stream.Mono
emitting the number of removed entries.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>> xTrim(org.reactivestreams.Publisher<ReactiveStreamCommands.TrimCommand> commands)
count
elements.commands
- must not be null.Flux
emitting the number of removed entries per ReactiveStreamCommands.TrimCommand
.Copyright © 2011–2020 Pivotal Software, Inc.. All rights reserved.