Package | Description |
---|---|
io.lettuce.core.event |
Event publishing and subscription.
|
io.lettuce.core.event.metrics |
Metric events and publishing.
|
io.lettuce.core.protocol |
Redis protocol layer abstraction.
|
io.lettuce.core.resource |
Client resource infrastructure providers.
|
Modifier and Type | Class and Description |
---|---|
class |
DefaultEventBus
Default implementation for an
EventBus . |
Constructor and Description |
---|
DefaultCommandLatencyEventPublisher(EventExecutorGroup eventExecutorGroup,
EventPublisherOptions options,
EventBus eventBus,
CommandLatencyCollector commandLatencyCollector) |
Constructor and Description |
---|
ConnectionWatchdog(Delay reconnectDelay,
ClientOptions clientOptions,
Bootstrap bootstrap,
Timer timer,
EventExecutorGroup reconnectWorkers,
Mono<SocketAddress> socketAddressSupplier,
ReconnectionListener reconnectionListener,
ConnectionFacade connectionFacade,
EventBus eventBus)
Create a new watchdog that adds to new connections to the supplied
ChannelGroup and establishes a new
Channel when disconnected, while reconnect is true. |
Modifier and Type | Method and Description |
---|---|
EventBus |
ClientResources.eventBus()
Returns the event bus used to publish events.
|
EventBus |
DefaultClientResources.eventBus() |
Modifier and Type | Method and Description |
---|---|
ClientResources.Builder |
ClientResources.Builder.eventBus(EventBus eventBus)
Sets the
EventBus that can that can be used across different instances of the RedisClient. |
DefaultClientResources.Builder |
DefaultClientResources.Builder.eventBus(EventBus eventBus)
Sets the
EventBus that can that can be used across different instances of the RedisClient. |
Copyright © 2019 lettuce.io. All rights reserved.