Package org.infinispan.partitionhandling.impl

Class PreferConsistencyStrategy

java.lang.Object

org.infinispan.partitionhandling.impl.PreferConsistencyStrategy

All Implemented Interfaces:

AvailabilityStrategy

public class PreferConsistencyStrategy
extends Object
implements AvailabilityStrategy

Constructor Summary

Constructors

Constructor	Description
PreferConsistencyStrategy(org.infinispan.util.logging.events.EventLogManager eventLogManager, PersistentUUIDManager persistentUUIDManager, LostDataCheck lostDataCheck)

Method Summary

Modifier and Type	Method	Description
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, Map<Address,CacheStatusResponse> statusResponseMap)	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.

Methods inherited from class java.lang.Object

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

Constructor Details

PreferConsistencyStrategy

public PreferConsistencyStrategy(org.infinispan.util.logging.events.EventLogManager eventLogManager,
 PersistentUUIDManager persistentUUIDManager,
 LostDataCheck lostDataCheck)

Method Details

onJoin

public void onJoin(AvailabilityStrategyContext context,
 Address joiner)

Description copied from interface: AvailabilityStrategy

Called when a node joins.

Specified by:

onJoin in interface AvailabilityStrategy

onGracefulLeave

public void onGracefulLeave(AvailabilityStrategyContext context,
 Address leaver)

Description copied from interface: AvailabilityStrategy

Called when a node leaves gracefully.

Specified by:

onGracefulLeave in interface AvailabilityStrategy

onClusterViewChange

public void onClusterViewChange(AvailabilityStrategyContext context,
 List<Address> clusterMembers)

Description copied from interface: AvailabilityStrategy

Called when the cluster view changed (e.g. because one or more nodes left abruptly).

Specified by:

onClusterViewChange in interface AvailabilityStrategy

isMinorityPartition

protected boolean isMinorityPartition(List<Address> stableMembers,
 List<Address> lostMembers)

onPartitionMerge

public void onPartitionMerge(AvailabilityStrategyContext context,
 Map<Address,CacheStatusResponse> statusResponseMap)

Description copied from interface: AvailabilityStrategy

Called when two or more partitions merge, to compute the stable and current cache topologies for the merged cluster.

Specified by:

onPartitionMerge in interface AvailabilityStrategy

onRebalanceEnd

public void onRebalanceEnd(AvailabilityStrategyContext context)

Description copied from interface: AvailabilityStrategy

Called when a rebalance ends. Can be used to re-assess the state of the cache and apply pending changes.

Specified by:

onRebalanceEnd in interface AvailabilityStrategy

onManualAvailabilityChange

public void onManualAvailabilityChange(AvailabilityStrategyContext context,
 AvailabilityMode newAvailabilityMode)

Description copied from interface: AvailabilityStrategy

Called when the administrator manually changes the availability status.

Specified by:

onManualAvailabilityChange in interface AvailabilityStrategy