Package | Description |
---|---|
org.springframework.data.redis.connection |
Connection package providing low-level abstractions for interacting with the various Redis 'drivers'/libraries.
|
Modifier and Type | Method and Description |
---|---|
ReactiveStreamCommands.GroupCommand |
ReactiveStreamCommands.GroupCommand.at(ReadOffset offset) |
static ReactiveStreamCommands.GroupCommand |
ReactiveStreamCommands.GroupCommand.createGroup(String group) |
static ReactiveStreamCommands.GroupCommand |
ReactiveStreamCommands.GroupCommand.deleteConsumer(Consumer consumer) |
static ReactiveStreamCommands.GroupCommand |
ReactiveStreamCommands.GroupCommand.deleteConsumer(String consumerName) |
static ReactiveStreamCommands.GroupCommand |
ReactiveStreamCommands.GroupCommand.destroyGroup(String group) |
ReactiveStreamCommands.GroupCommand |
ReactiveStreamCommands.GroupCommand.forStream(ByteBuffer key) |
ReactiveStreamCommands.GroupCommand |
ReactiveStreamCommands.GroupCommand.fromGroup(String groupName) |
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.GroupCommand,String>> |
ReactiveStreamCommands.xGroup(org.reactivestreams.Publisher<ReactiveStreamCommands.GroupCommand> commands)
Execute the given
ReactiveStreamCommands.GroupCommand to create, destroy,... groups. |
Modifier and Type | Method and Description |
---|---|
default reactor.core.publisher.Mono<String> |
ReactiveStreamCommands.xGroup(ReactiveStreamCommands.GroupCommand command)
Execute the given
ReactiveStreamCommands.GroupCommand to create, destroy,... groups. |
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.GroupCommand,String>> |
ReactiveStreamCommands.xGroup(org.reactivestreams.Publisher<ReactiveStreamCommands.GroupCommand> commands)
Execute the given
ReactiveStreamCommands.GroupCommand to create, destroy,... groups. |
Copyright © 2011–2019 Pivotal Software, Inc.. All rights reserved.