public class PreferConsistencyStrategy extends Object implements AvailabilityStrategy
Constructor and Description |
---|
PreferConsistencyStrategy(EventLogManager eventLogManager) |
Modifier and Type | Method and Description |
---|---|
protected AvailabilityMode |
computeAvailabilityAfterMerge(AvailabilityStrategyContext context,
CacheTopology maxStableTopology,
List<Address> newMembers,
AvailabilityMode initialMode) |
protected boolean |
isMinorityPartition(List<Address> stableMembers,
List<Address> lostMembers) |
void |
onClusterViewChange(AvailabilityStrategyContext context,
List<Address> clusterMembers)
Called when the cluster view changed (e.g.
|
void |
onGracefulLeave(AvailabilityStrategyContext context,
Address leaver)
Called when a node leaves gracefully.
|
void |
onJoin(AvailabilityStrategyContext context,
Address joiner)
Called when a node joins.
|
void |
onManualAvailabilityChange(AvailabilityStrategyContext context,
AvailabilityMode newAvailabilityMode)
Called when the administrator manually changes the availability status.
|
void |
onPartitionMerge(AvailabilityStrategyContext context,
Collection<CacheStatusResponse> statusResponses)
Called when two or more partitions merge, to compute the stable and current cache topologies for the merged
cluster.
|
void |
onRebalanceEnd(AvailabilityStrategyContext context)
Called when a rebalance ends.
|
public PreferConsistencyStrategy(EventLogManager eventLogManager)
public void onJoin(AvailabilityStrategyContext context, Address joiner)
AvailabilityStrategy
onJoin
in interface AvailabilityStrategy
public void onGracefulLeave(AvailabilityStrategyContext context, Address leaver)
AvailabilityStrategy
onGracefulLeave
in interface AvailabilityStrategy
public void onClusterViewChange(AvailabilityStrategyContext context, List<Address> clusterMembers)
AvailabilityStrategy
onClusterViewChange
in interface AvailabilityStrategy
protected boolean isMinorityPartition(List<Address> stableMembers, List<Address> lostMembers)
public void onPartitionMerge(AvailabilityStrategyContext context, Collection<CacheStatusResponse> statusResponses)
AvailabilityStrategy
onPartitionMerge
in interface AvailabilityStrategy
protected AvailabilityMode computeAvailabilityAfterMerge(AvailabilityStrategyContext context, CacheTopology maxStableTopology, List<Address> newMembers, AvailabilityMode initialMode)
public void onRebalanceEnd(AvailabilityStrategyContext context)
AvailabilityStrategy
onRebalanceEnd
in interface AvailabilityStrategy
public void onManualAvailabilityChange(AvailabilityStrategyContext context, AvailabilityMode newAvailabilityMode)
AvailabilityStrategy
onManualAvailabilityChange
in interface AvailabilityStrategy
Copyright © 2023 JBoss, a division of Red Hat. All rights reserved.