Package | Description |
---|---|
org.springframework.data.redis.connection |
Connection package providing low-level abstractions for interacting with the various Redis 'drivers'/libraries.
|
org.springframework.data.redis.connection.stream |
Data structures and interfaces to interact with Redis Streams.
|
org.springframework.data.redis.core |
Core package for integrating Redis with Spring concepts.
|
Modifier and Type | Method and Description |
---|---|
default reactor.core.publisher.Flux<StreamInfo.XInfoConsumer> |
ReactiveStreamCommands.xInfoConsumers(ByteBuffer key,
String groupName)
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.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.
|
Modifier and Type | Method and Description |
---|---|
StreamInfo.XInfoConsumer |
StreamInfo.XInfoConsumers.get(int index)
Returns the
StreamInfo.XInfoConsumer element at the given index. |
Modifier and Type | Method and Description |
---|---|
Iterator<StreamInfo.XInfoConsumer> |
StreamInfo.XInfoConsumers.iterator()
Returns an iterator over the
StreamInfo.XInfoConsumer elements. |
Stream<StreamInfo.XInfoConsumer> |
StreamInfo.XInfoConsumers.stream()
Returns a sequential
Stream of StreamInfo.XInfoConsumer . |
Modifier and Type | Method and Description |
---|---|
void |
StreamInfo.XInfoConsumers.forEach(Consumer<? super StreamInfo.XInfoConsumer> action)
Performs the given action on every available
StreamInfo.XInfoConsumer of this StreamInfo.XInfoConsumers . |
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Flux<StreamInfo.XInfoConsumer> |
ReactiveStreamOperations.consumers(K key,
String group)
Obtain information about every consumer in a specific consumer group for the stream stored at the
specified key.
|
Copyright © 2011–2022 Pivotal Software, Inc.. All rights reserved.