org.infinispan.partitionhandling.impl

Class PreferAvailabilityStrategy

java.lang.Object

org.infinispan.partitionhandling.impl.PreferAvailabilityStrategy

All Implemented Interfaces:

AvailabilityStrategy

public class PreferAvailabilityStrategy
extends Object
implements AvailabilityStrategy

Constructor Summary

Constructors

Constructor and Description
PreferAvailabilityStrategy(EventLogManager eventLogManager, PersistentUUIDManager persistentUUIDManager, LostDataCheck lostDataCheck)

Method Summary

Modifier and Type	Method and Description
CacheTopology	computePreferredTopology(Map<Address,CacheStatusResponse> statusResponseMap) Ignore the AvailabilityStrategyContext and only compute the preferred topology for testing.
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

Methods inherited from interface org.infinispan.partitionhandling.impl.AvailabilityStrategy

ownersConsistentHash

Constructor Detail

PreferAvailabilityStrategy

public PreferAvailabilityStrategy(EventLogManager eventLogManager,
                                  PersistentUUIDManager persistentUUIDManager,
                                  LostDataCheck lostDataCheck)

Method Detail

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

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

computePreferredTopology

public CacheTopology computePreferredTopology(Map<Address,CacheStatusResponse> statusResponseMap)

Ignore the AvailabilityStrategyContext and only compute the preferred topology for testing.

Returns:

The preferred topology, or null if there is no preferred topology.

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