Uses of Class
org.springframework.data.redis.connection.ReactiveStreamCommands.GroupCommand
Packages that use ReactiveStreamCommands.GroupCommand
Package
Description
Connection package providing low-level abstractions for interacting with the various Redis 'drivers'/libraries.
-
Uses of ReactiveStreamCommands.GroupCommand in org.springframework.data.redis.connection
Methods in org.springframework.data.redis.connection that return ReactiveStreamCommands.GroupCommandModifier and TypeMethodDescriptionReactiveStreamCommands.GroupCommand.at
(ReadOffset offset) ReactiveStreamCommands.GroupCommand.createGroup
(String group) ReactiveStreamCommands.GroupCommand.deleteConsumer
(String consumerName) ReactiveStreamCommands.GroupCommand.deleteConsumer
(Consumer consumer) ReactiveStreamCommands.GroupCommand.destroyGroup
(String group) ReactiveStreamCommands.GroupCommand.forStream
(ByteBuffer key) ReactiveStreamCommands.GroupCommand.makeStream
(boolean mkStream) Methods in org.springframework.data.redis.connection that return types with arguments of type ReactiveStreamCommands.GroupCommandModifier and TypeMethodDescriptionreactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.GroupCommand,
String>> ReactiveStreamCommands.xGroup
(org.reactivestreams.Publisher<ReactiveStreamCommands.GroupCommand> commands) Execute the givenReactiveStreamCommands.GroupCommand
to create, destroy,... groups.Methods in org.springframework.data.redis.connection with parameters of type ReactiveStreamCommands.GroupCommandModifier and TypeMethodDescriptiondefault reactor.core.publisher.Mono<String>
ReactiveStreamCommands.xGroup
(ReactiveStreamCommands.GroupCommand command) Execute the givenReactiveStreamCommands.GroupCommand
to create, destroy,... groups.Method parameters in org.springframework.data.redis.connection with type arguments of type ReactiveStreamCommands.GroupCommandModifier and TypeMethodDescriptionreactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.GroupCommand,
String>> ReactiveStreamCommands.xGroup
(org.reactivestreams.Publisher<ReactiveStreamCommands.GroupCommand> commands) Execute the givenReactiveStreamCommands.GroupCommand
to create, destroy,... groups.