Uses of Class
org.infinispan.topology.CacheTopology

Packages that use CacheTopology

Package	Description
org.infinispan.conflict.impl	This package contains implementations of the conflict resolution API.
org.infinispan.distribution	Classes relating to the distributed cache mode.
org.infinispan.distribution.impl
org.infinispan.notifications.cachelistener	Cache-specific notifications and eventing.
org.infinispan.partitionhandling.impl
org.infinispan.scattered.impl
org.infinispan.statetransfer	Transfer of state to new caches in a cluster.
org.infinispan.topology
org.infinispan.transaction.impl
org.infinispan.util	General utilities that are not specific to Infinispan, including string parsing helpers, reflection tools and collections and containers designed to supplement the JDK-provided containers.
org.infinispan.util.logging	Infinispan's logging abstractions that delegate to either JDK or Log4J logging engines.

Uses of CacheTopology in org.infinispan.conflict.impl

Methods in org.infinispan.conflict.impl with parameters of type CacheTopology

Modifier and Type	Method	Description
CompletableFuture<Void>	DefaultConflictManager.resolveConflicts(CacheTopology topology, Set<Address> preferredNodes)
CompletableFuture<Void>	InternalConflictManager.resolveConflicts(CacheTopology cacheTopology, Set<Address> preferredNodes)

Uses of CacheTopology in org.infinispan.distribution

Subclasses of CacheTopology in org.infinispan.distribution

Modifier and Type	Class	Description
class	LocalizedCacheTopology	Extends CacheTopology with information about keys owned by the local node.

Methods in org.infinispan.distribution with parameters of type CacheTopology

Modifier and Type	Method	Description
LocalizedCacheTopology	DistributionManager.createLocalizedCacheTopology(CacheTopology cacheTopology)
void	DistributionManager.setCacheTopology(CacheTopology cacheTopology)	Deprecated. Internal only.

Constructors in org.infinispan.distribution with parameters of type CacheTopology

Constructor	Description
LocalizedCacheTopology(CacheMode cacheMode, CacheTopology cacheTopology, KeyPartitioner keyPartitioner, Address localAddress, boolean connected)

Uses of CacheTopology in org.infinispan.distribution.impl

Methods in org.infinispan.distribution.impl with parameters of type CacheTopology

Modifier and Type	Method	Description
LocalizedCacheTopology	DistributionManagerImpl.createLocalizedCacheTopology(CacheTopology cacheTopology)
void	DistributionManagerImpl.setCacheTopology(CacheTopology cacheTopology)

Uses of CacheTopology in org.infinispan.notifications.cachelistener

Methods in org.infinispan.notifications.cachelistener with parameters of type CacheTopology

Modifier and Type	Method	Description
void	CacheNotifier.notifyTopologyChanged(CacheTopology oldTopology, CacheTopology newTopology, int newTopologyId, boolean pre)
void	CacheNotifierImpl.notifyTopologyChanged(CacheTopology oldTopology, CacheTopology newTopology, int newTopologyId, boolean pre)

Uses of CacheTopology in org.infinispan.partitionhandling.impl

Methods in org.infinispan.partitionhandling.impl that return CacheTopology

Modifier and Type	Method	Description
CacheTopology	PreferAvailabilityStrategy.computePreferredTopology(Map<Address,CacheStatusResponse> statusResponseMap)	Ignore the AvailabilityStrategyContext and only compute the preferred topology for testing.
CacheTopology	AvailabilityStrategyContext.getCurrentTopology()
CacheTopology	AvailablePartitionHandlingManager.getLastStableTopology()
CacheTopology	PartitionHandlingManager.getLastStableTopology()	Deprecated.
CacheTopology	PartitionHandlingManagerImpl.getLastStableTopology()
CacheTopology	AvailabilityStrategyContext.getStableTopology()	Whenever a new cache topology without a pendingCH and with at least numOwners owners for each segment is installed, and the cache is AvailabilityMode.AVAILABLE, the current cache topology is marked as the stable topology.

Methods in org.infinispan.partitionhandling.impl with parameters of type CacheTopology

Modifier and Type	Method	Description
void	AvailablePartitionHandlingManager.onTopologyUpdate(CacheTopology cacheTopology)
void	PartitionHandlingManager.onTopologyUpdate(CacheTopology cacheTopology)	Notifies the PartitionHandlingManager that the cache topology was update.
void	PartitionHandlingManagerImpl.onTopologyUpdate(CacheTopology cacheTopology)
static ConsistentHash	AvailabilityStrategy.ownersConsistentHash(CacheTopology topology, ConsistentHashFactory chFactory)	Compute the read consistent hash for a topology with a null union consistent hash.
void	AvailabilityStrategyContext.queueConflictResolution(CacheTopology conflictTopology, Set<Address> preferredNodes)	Initiates conflict resolution using the conflictTopology, which should have already been broadcast via {@link this#updateTopologiesAfterMerge(CacheTopology, CacheTopology, AvailabilityMode)}
void	AvailabilityStrategyContext.updateTopologiesAfterMerge(CacheTopology currentTopology, CacheTopology stableTopology, AvailabilityMode availabilityMode)	Updates both the stable and the current topologies.

Uses of CacheTopology in org.infinispan.scattered.impl

Methods in org.infinispan.scattered.impl with parameters of type CacheTopology

Modifier and Type	Method	Description
CompletableFuture<Void>	ScatteredStateConsumerImpl.onTopologyUpdate(CacheTopology cacheTopology, boolean isRebalance)
CompletableFuture<Void>	ScatteredStateProviderImpl.onTopologyUpdate(CacheTopology cacheTopology, boolean isRebalance)

Uses of CacheTopology in org.infinispan.statetransfer

Fields in org.infinispan.statetransfer declared as CacheTopology

Modifier and Type	Field	Description
protected CacheTopology	StateConsumerImpl.cacheTopology

Methods in org.infinispan.statetransfer that return CacheTopology

Modifier and Type	Method	Description
CacheTopology	StateConsumer.getCacheTopology()	Deprecated. Since 9.3, please use DistributionManager.getCacheTopology() instead.
CacheTopology	StateConsumerImpl.getCacheTopology()
CacheTopology	StateTransferManager.getCacheTopology()	Deprecated. Since 9.3, please use DistributionManager.getCacheTopology() instead.
CacheTopology	StateTransferManagerImpl.getCacheTopology()

Methods in org.infinispan.statetransfer with parameters of type CacheTopology

Modifier and Type	Method	Description
CompletableFuture<Void>	StateConsumer.onTopologyUpdate(CacheTopology cacheTopology, boolean isRebalance)	Receive notification of topology changes.
CompletableFuture<Void>	StateConsumerImpl.onTopologyUpdate(CacheTopology cacheTopology, boolean isRebalance)
CompletableFuture<Void>	StateProvider.onTopologyUpdate(CacheTopology cacheTopology, boolean isRebalance)	Receive notification of topology changes.
CompletableFuture<Void>	StateProviderImpl.onTopologyUpdate(CacheTopology cacheTopology, boolean isRebalance)

Uses of CacheTopology in org.infinispan.topology

Methods in org.infinispan.topology that return CacheTopology

Modifier and Type	Method	Description
protected CacheTopology	ClusterCacheStatus.createInitialCacheTopology()
CacheTopology	CacheTopology.Externalizer.doReadObject(ObjectInput unmarshaller)
CacheTopology	CacheStatusResponse.getCacheTopology()
CacheTopology	LocalTopologyManager.getCacheTopology(String cacheName)
CacheTopology	LocalTopologyManagerImpl.getCacheTopology(String cacheName)
CacheTopology	ClusterCacheStatus.getCurrentTopology()
CacheTopology	LocalTopologyManager.getStableCacheTopology(String cacheName)
CacheTopology	LocalTopologyManagerImpl.getStableCacheTopology(String cacheName)
CacheTopology	CacheStatusResponse.getStableTopology()
CacheTopology	ClusterCacheStatus.getStableTopology()
CacheTopology	LocalTopologyManager.join(String cacheName, CacheJoinInfo joinInfo, CacheTopologyHandler stm, PartitionHandlingManager phm)	Forwards the join request to the coordinator.
CacheTopology	LocalTopologyManagerImpl.join(String cacheName, CacheJoinInfo joinInfo, CacheTopologyHandler stm, PartitionHandlingManager phm)
protected CacheTopology	ClusterCacheStatus.restoreCacheTopology(ScopedPersistentState state)

Methods in org.infinispan.topology that return types with arguments of type CacheTopology

Modifier and Type	Method	Description
Set<Class<? extends CacheTopology>>	CacheTopology.Externalizer.getTypeClasses()

Methods in org.infinispan.topology with parameters of type CacheTopology

Modifier and Type	Method	Description
void	ClusterTopologyManager.broadcastRebalanceStart(String cacheName, CacheTopology cacheTopology, boolean totalOrder, boolean distributed)
void	ClusterTopologyManagerImpl.broadcastRebalanceStart(String cacheName, CacheTopology cacheTopology, boolean totalOrder, boolean distributed)
void	ClusterTopologyManager.broadcastShutdownCache(String cacheName, CacheTopology currentTopology, boolean totalOrder, boolean distributed)
void	ClusterTopologyManagerImpl.broadcastShutdownCache(String cacheName, CacheTopology cacheTopology, boolean totalOrder, boolean distributed)
void	ClusterTopologyManager.broadcastStableTopologyUpdate(String cacheName, CacheTopology cacheTopology, boolean totalOrder, boolean distributed)
void	ClusterTopologyManagerImpl.broadcastStableTopologyUpdate(String cacheName, CacheTopology cacheTopology, boolean totalOrder, boolean distributed)
void	ClusterTopologyManager.broadcastTopologyUpdate(String cacheName, CacheTopology cacheTopology, AvailabilityMode availabilityMode, boolean totalOrder, boolean distributed)
void	ClusterTopologyManagerImpl.broadcastTopologyUpdate(String cacheName, CacheTopology cacheTopology, AvailabilityMode availabilityMode, boolean totalOrder, boolean distributed)
void	CacheTopology.Externalizer.doWriteObject(ObjectOutput output, CacheTopology cacheTopology)
void	LocalTopologyManager.handleRebalance(String cacheName, CacheTopology cacheTopology, int viewId, Address sender)	Performs the state transfer.
void	LocalTopologyManagerImpl.handleRebalance(String cacheName, CacheTopology cacheTopology, int viewId, Address sender)
void	LocalTopologyManager.handleStableTopologyUpdate(String cacheName, CacheTopology cacheTopology, Address sender, int viewId)	Update the stable cache topology.
void	LocalTopologyManagerImpl.handleStableTopologyUpdate(String cacheName, CacheTopology newStableTopology, Address sender, int viewId)
void	LocalTopologyManager.handleTopologyUpdate(String cacheName, CacheTopology cacheTopology, AvailabilityMode availabilityMode, int viewId, Address sender)	Updates the current and/or pending consistent hash, without transferring any state.
void	LocalTopologyManagerImpl.handleTopologyUpdate(String cacheName, CacheTopology cacheTopology, AvailabilityMode availabilityMode, int viewId, Address sender)
void	ClusterCacheStatus.queueConflictResolution(CacheTopology conflictTopology, Set<Address> preferredNodes)
void	CacheTopologyHandler.rebalance(CacheTopology cacheTopology)	Invoked when state transfer has to be started.
void	CacheTopologyHandler.updateConsistentHash(CacheTopology cacheTopology)	Invoked when the CH has to be immediately updated because of a leave or when the state transfer has completed and we have to install a permanent CH (pendingCH == null).
void	ClusterCacheStatus.updateTopologiesAfterMerge(CacheTopology currentTopology, CacheTopology stableTopology, AvailabilityMode availabilityMode)

Constructors in org.infinispan.topology with parameters of type CacheTopology

Constructor	Description
CacheStatusResponse(CacheJoinInfo cacheJoinInfo, CacheTopology cacheTopology, CacheTopology stableTopology, AvailabilityMode availabilityMode)
CacheTopologyControlCommand(String cacheName, CacheTopologyControlCommand.Type type, Address sender, CacheTopology cacheTopology, AvailabilityMode availabilityMode, int viewId)

Uses of CacheTopology in org.infinispan.transaction.impl

Methods in org.infinispan.transaction.impl with parameters of type CacheTopology

Modifier and Type	Method	Description
Collection<Address>	LocalTransaction.getCommitNodes(Collection<Address> recipients, CacheTopology cacheTopology)	Calculates the list of nodes to which a commit/rollback needs to be sent based on the nodes to which prepare was sent.

Uses of CacheTopology in org.infinispan.util

Methods in org.infinispan.util that return CacheTopology

Modifier and Type	Method	Description
CacheTopology	AbstractControlledLocalTopologyManager.getCacheTopology(String cacheName)
CacheTopology	AbstractControlledLocalTopologyManager.getStableCacheTopology(String cacheName)
CacheTopology	AbstractControlledLocalTopologyManager.join(String cacheName, CacheJoinInfo joinInfo, CacheTopologyHandler stm, PartitionHandlingManager phm)

Methods in org.infinispan.util with parameters of type CacheTopology

Modifier and Type	Method	Description
protected void	AbstractControlledLocalTopologyManager.beforeHandleRebalance(String cacheName, CacheTopology cacheTopology, int viewId)
protected void	AbstractControlledLocalTopologyManager.beforeHandleTopologyUpdate(String cacheName, CacheTopology cacheTopology, int viewId)
void	AbstractControlledLocalTopologyManager.handleRebalance(String cacheName, CacheTopology cacheTopology, int viewId, Address sender)
void	AbstractControlledLocalTopologyManager.handleStableTopologyUpdate(String cacheName, CacheTopology cacheTopology, Address sender, int viewId)
void	AbstractControlledLocalTopologyManager.handleTopologyUpdate(String cacheName, CacheTopology cacheTopology, AvailabilityMode availabilityMode, int viewId, Address sender)

Uses of CacheTopology in org.infinispan.util.logging

Methods in org.infinispan.util.logging with parameters of type CacheTopology

Modifier and Type	Method	Description
void	Log_$logger.cacheRecoveredAfterMerge(String cacheName, CacheTopology currentTopology, AvailabilityMode availabilityMode)
void	Log.cacheRecoveredAfterMerge(String cacheName, CacheTopology currentTopology, AvailabilityMode availabilityMode)
void	Log_$logger.cancelledConflictResolution(String cacheName, CacheTopology currentTopology)
void	Log.cancelledConflictResolution(String cacheName, CacheTopology currentTopology)
void	Log_$logger.failedConflictResolution(String cacheName, CacheTopology currentTopology, Throwable t)
void	Log.failedConflictResolution(String cacheName, CacheTopology currentTopology, Throwable t)
void	Log_$logger.finishedConflictResolution(String cacheName, CacheTopology currentTopology)
void	Log.finishedConflictResolution(String cacheName, CacheTopology currentTopology)
void	Log_$logger.finishedRebalance(String cacheName, CacheTopology topology)
void	Log.finishedRebalance(String cacheName, CacheTopology topology)
void	Log_$logger.ignoringCacheTopology(Collection<Address> sender, CacheTopology topology)
void	Log.ignoringCacheTopology(Collection<Address> sender, CacheTopology topology)
void	Log_$logger.startingConflictResolution(String cacheName, CacheTopology currentTopology)
void	Log.startingConflictResolution(String cacheName, CacheTopology currentTopology)
void	Log_$logger.startingRebalancePhase(String cacheName, CacheTopology cacheTopology)
void	Log.startingRebalancePhase(String cacheName, CacheTopology cacheTopology)
void	Log_$logger.updatingAvailabilityMode(String cacheName, AvailabilityMode oldMode, AvailabilityMode newMode, CacheTopology topology)
void	Log.updatingAvailabilityMode(String cacheName, AvailabilityMode oldMode, AvailabilityMode newMode, CacheTopology topology)
void	Log_$logger.updatingStableTopology(String cacheName, CacheTopology currentTopology)
void	Log.updatingStableTopology(String cacheName, CacheTopology currentTopology)
void	Log_$logger.updatingTopology(String cacheName, CacheTopology currentTopology, AvailabilityMode availabilityMode)
void	Log.updatingTopology(String cacheName, CacheTopology currentTopology, AvailabilityMode availabilityMode)