io.lettuce.core.event.cluster

Class AdaptiveRefreshTriggeredEvent

java.lang.Object

io.lettuce.core.event.cluster.AdaptiveRefreshTriggeredEvent

All Implemented Interfaces:

Event

Direct Known Subclasses:

AdaptiveRefreshTriggeredEvent.PersistentReconnectsAdaptiveRefreshTriggeredEvent, AdaptiveRefreshTriggeredEvent.UncoveredSlotAdaptiveRefreshTriggeredEvent

public class AdaptiveRefreshTriggeredEvent
extends Object
implements Event

Event when a topology refresh is about to start by an adaptive refresh trigger.

Since:

5.2

Author:

Mark Paluch

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AdaptiveRefreshTriggeredEvent.PersistentReconnectsAdaptiveRefreshTriggeredEvent Extension to AdaptiveRefreshTriggeredEvent providing the reconnect-attempt counter value.
static class	AdaptiveRefreshTriggeredEvent.UncoveredSlotAdaptiveRefreshTriggeredEvent Extension to AdaptiveRefreshTriggeredEvent providing the uncovered slot value.

Constructor Summary

Constructors

Constructor and Description
AdaptiveRefreshTriggeredEvent(Supplier<Partitions> partitionsSupplier, Runnable topologyRefreshScheduler, ClusterTopologyRefreshOptions.RefreshTrigger refreshTrigger)

Method Summary

Modifier and Type	Method and Description
Partitions	getPartitions() Retrieve the currently known partitions.
ClusterTopologyRefreshOptions.RefreshTrigger	getRefreshTrigger() Retrieve the ClusterTopologyRefreshOptions.RefreshTrigger that caused this event.
void	scheduleRefresh() Schedules a new topology refresh.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AdaptiveRefreshTriggeredEvent

public AdaptiveRefreshTriggeredEvent(Supplier<Partitions> partitionsSupplier,
                                     Runnable topologyRefreshScheduler,
                                     ClusterTopologyRefreshOptions.RefreshTrigger refreshTrigger)

Method Detail

scheduleRefresh

public void scheduleRefresh()

Schedules a new topology refresh. Refresh happens asynchronously.

getPartitions

public Partitions getPartitions()

Retrieve the currently known partitions.

Returns:

the currently known topology view. The view is mutable and changes over time.

getRefreshTrigger

public ClusterTopologyRefreshOptions.RefreshTrigger getRefreshTrigger()

Retrieve the ClusterTopologyRefreshOptions.RefreshTrigger that caused this event.

Returns:

the ClusterTopologyRefreshOptions.RefreshTrigger that caused this event.