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.XInfoCommand |
ReactiveStreamCommands.XInfoCommand.consumersIn(String groupName) |
static ReactiveStreamCommands.XInfoCommand |
ReactiveStreamCommands.XInfoCommand.of(ByteBuffer key) |
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XInfoCommand,StreamInfo.XInfoStream>> |
ReactiveStreamCommands.xInfo(org.reactivestreams.Publisher<ReactiveStreamCommands.XInfoCommand> commands)
Obtain general information about the stream stored at the specified key.
|
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XInfoCommand,reactor.core.publisher.Flux<StreamInfo.XInfoConsumer>>> |
ReactiveStreamCommands.xInfoConsumers(org.reactivestreams.Publisher<ReactiveStreamCommands.XInfoCommand> commands)
Obtain information about every consumer in a specific consumer group for the stream stored at the
specified key.
|
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XInfoCommand,reactor.core.publisher.Flux<StreamInfo.XInfoGroup>>> |
ReactiveStreamCommands.xInfoGroups(org.reactivestreams.Publisher<ReactiveStreamCommands.XInfoCommand> commands)
Obtain general information about the stream stored at the specified key.
|
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XInfoCommand,StreamInfo.XInfoStream>> |
ReactiveStreamCommands.xInfo(org.reactivestreams.Publisher<ReactiveStreamCommands.XInfoCommand> commands)
Obtain general information about the stream stored at the specified key.
|
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XInfoCommand,reactor.core.publisher.Flux<StreamInfo.XInfoConsumer>>> |
ReactiveStreamCommands.xInfoConsumers(org.reactivestreams.Publisher<ReactiveStreamCommands.XInfoCommand> commands)
Obtain information about every consumer in a specific consumer group for the stream stored at the
specified key.
|
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XInfoCommand,reactor.core.publisher.Flux<StreamInfo.XInfoGroup>>> |
ReactiveStreamCommands.xInfoGroups(org.reactivestreams.Publisher<ReactiveStreamCommands.XInfoCommand> commands)
Obtain general information about the stream stored at the specified key.
|
Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.