Package org.infinispan.topology

Class CacheTopology

java.lang.Object

org.infinispan.topology.CacheTopology

Direct Known Subclasses:

LocalizedCacheTopology

public class CacheTopology
extends Object

The status of a cache from a distribution/state transfer point of view.

The pending CH can be null if we don't have a state transfer in progress.

The topologyId is incremented every time the topology changes (e.g. a member leaves, state transfer starts or ends). The rebalanceId is not modified when the consistent hashes are updated without requiring state transfer (e.g. when a member leaves).

Since:

5.2

Author:

Dan Berindei

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	CacheTopology.Externalizer
static enum	CacheTopology.Phase	Phase of the rebalance process.

Constructor Summary

Constructors

Constructor	Description
CacheTopology(int topologyId, int rebalanceId, boolean restoredTopology, ConsistentHash currentCH, ConsistentHash pendingCH, ConsistentHash unionCH, CacheTopology.Phase phase, List<Address> actualMembers, List<PersistentUUID> persistentUUIDs)
CacheTopology(int topologyId, int rebalanceId, boolean restoredTopology, ConsistentHash currentCH, ConsistentHash pendingCH, CacheTopology.Phase phase, List<Address> actualMembers, List<PersistentUUID> persistentUUIDs)
CacheTopology(int topologyId, int rebalanceId, ConsistentHash currentCH, ConsistentHash pendingCH, ConsistentHash unionCH, CacheTopology.Phase phase, List<Address> actualMembers, List<PersistentUUID> persistentUUIDs)
CacheTopology(int topologyId, int rebalanceId, ConsistentHash currentCH, ConsistentHash pendingCH, CacheTopology.Phase phase, List<Address> actualMembers, List<PersistentUUID> persistentUUIDs)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
List<Address>	getActualMembers()
ConsistentHash	getCurrentCH()	The current consistent hash.
List<Address>	getMembers()
List<PersistentUUID>	getMembersPersistentUUIDs()
ConsistentHash	getPendingCH()	The future consistent hash.
CacheTopology.Phase	getPhase()
ConsistentHash	getReadConsistentHash()	Read operations should always go to the "current" owners.
int	getRebalanceId()	The id of the latest started rebalance.
int	getTopologyId()
ConsistentHash	getUnionCH()	The union of the current and future consistent hashes.
ConsistentHash	getWriteConsistentHash()	When there is a rebalance in progress, write operations should go to the union of the "current" and "future" owners.
int	hashCode()
final void	logRoutingTableInformation(String cacheName)
String	toString()
boolean	wasTopologyRestoredFromState()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Details

CacheTopology

public CacheTopology(int topologyId,
 int rebalanceId,
 ConsistentHash currentCH,
 ConsistentHash pendingCH,
 CacheTopology.Phase phase,
 List<Address> actualMembers,
 List<PersistentUUID> persistentUUIDs)

CacheTopology

public CacheTopology(int topologyId,
 int rebalanceId,
 boolean restoredTopology,
 ConsistentHash currentCH,
 ConsistentHash pendingCH,
 CacheTopology.Phase phase,
 List<Address> actualMembers,
 List<PersistentUUID> persistentUUIDs)

CacheTopology

public CacheTopology(int topologyId,
 int rebalanceId,
 ConsistentHash currentCH,
 ConsistentHash pendingCH,
 ConsistentHash unionCH,
 CacheTopology.Phase phase,
 List<Address> actualMembers,
 List<PersistentUUID> persistentUUIDs)

CacheTopology

public CacheTopology(int topologyId,
 int rebalanceId,
 boolean restoredTopology,
 ConsistentHash currentCH,
 ConsistentHash pendingCH,
 ConsistentHash unionCH,
 CacheTopology.Phase phase,
 List<Address> actualMembers,
 List<PersistentUUID> persistentUUIDs)

Method Details

getTopologyId

public int getTopologyId()

getCurrentCH

public ConsistentHash getCurrentCH()

The current consistent hash.

getPendingCH

public ConsistentHash getPendingCH()

The future consistent hash. Should be null if there is no rebalance in progress.

getUnionCH

public ConsistentHash getUnionCH()

The union of the current and future consistent hashes. Should be null if there is no rebalance in progress.

getRebalanceId

public int getRebalanceId()

The id of the latest started rebalance.

getMembers

public List<Address> getMembers()

Returns:

The nodes that are members in both consistent hashes (if pendingCH != null, otherwise the members of the current CH).

See Also:

• getActualMembers()

getActualMembers

public List<Address> getActualMembers()

Returns:

The nodes that are active members of the cache. It should be equal to getMembers() when the cache is available, and a strict subset if the cache is in degraded mode.

See Also:

• AvailabilityMode

getMembersPersistentUUIDs

public List<PersistentUUID> getMembersPersistentUUIDs()

wasTopologyRestoredFromState

public boolean wasTopologyRestoredFromState()

getReadConsistentHash

public ConsistentHash getReadConsistentHash()

Read operations should always go to the "current" owners.

getWriteConsistentHash

public ConsistentHash getWriteConsistentHash()

When there is a rebalance in progress, write operations should go to the union of the "current" and "future" owners.

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object

logRoutingTableInformation

public final void logRoutingTableInformation(String cacheName)

getPhase

public CacheTopology.Phase getPhase()