Package 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	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	Description
AdaptiveRefreshTriggeredEvent(Supplier<Partitions> partitionsSupplier, Runnable topologyRefreshScheduler, ClusterTopologyRefreshOptions.RefreshTrigger refreshTrigger)

Method Summary

Modifier and Type	Method	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.