Uses of Class
org.infinispan.topology.CacheTopology

Packages that use CacheTopology

Package	Description
org.infinispan.container.versioning.irac
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.topology
org.infinispan.transaction.impl
org.infinispan.xsite.irac
org.infinispan.xsite.statetransfer

Uses of CacheTopology in org.infinispan.container.versioning.irac

Methods in org.infinispan.container.versioning.irac with parameters of type CacheTopology

Modifier and Type	Method	Description
void	DefaultIracVersionGenerator.onTopologyChange(CacheTopology newTopology)
void	IracVersionGenerator.onTopologyChange(CacheTopology newTopology)	Invoked when a topology change occurs in the cluster.
void	NoOpIracVersionGenerator.onTopologyChange(CacheTopology newTopology)

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, for removal: This API element is subject to removal in a future version. Internal only.

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

Modifier	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
CompletionStage<Void>	CacheNotifier.notifyTopologyChanged(CacheTopology oldTopology, CacheTopology newTopology, int newTopologyId, boolean pre)
CompletionStage<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
CompletionStage<CompletionStage<Void>>	ScatteredStateConsumerImpl.onTopologyUpdate(CacheTopology cacheTopology, boolean isRebalance)
CompletableFuture<Void>	ScatteredStateProviderImpl.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()
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()
CompletionStage<CacheTopology>	LocalTopologyManager.join(String cacheName, CacheJoinInfo joinInfo, CacheTopologyHandler stm, PartitionHandlingManager phm)	Forwards the join request to the coordinator.
CompletionStage<CacheTopology>	LocalTopologyManagerImpl.join(String cacheName, CacheJoinInfo joinInfo, CacheTopologyHandler stm, PartitionHandlingManager phm)

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

Modifier and Type	Method	Description
void	CacheTopology.Externalizer.doWriteObject(ObjectOutput output, CacheTopology cacheTopology)
CompletionStage<Void>	LocalTopologyManager.handleRebalance(String cacheName, CacheTopology cacheTopology, int viewId, Address sender)	Performs the state transfer.
CompletionStage<Void>	LocalTopologyManagerImpl.handleRebalance(String cacheName, CacheTopology cacheTopology, int viewId, Address sender)
CompletionStage<Void>	LocalTopologyManager.handleStableTopologyUpdate(String cacheName, CacheTopology cacheTopology, Address sender, int viewId)	Update the stable cache topology.
CompletionStage<Void>	LocalTopologyManagerImpl.handleStableTopologyUpdate(String cacheName, CacheTopology newStableTopology, Address sender, int viewId)
CompletionStage<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.
CompletionStage<Void>	LocalTopologyManagerImpl.handleTopologyUpdate(String cacheName, CacheTopology cacheTopology, AvailabilityMode availabilityMode, int viewId, Address sender)
void	ClusterCacheStatus.queueConflictResolution(CacheTopology conflictTopology, Set<Address> preferredNodes)
CompletionStage<Void>	CacheTopologyHandler.rebalance(CacheTopology cacheTopology)	Invoked when state transfer has to be started.
CompletionStage<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

Modifier	Constructor	Description
	CacheStatusResponse(CacheJoinInfo cacheJoinInfo, CacheTopology cacheTopology, CacheTopology stableTopology, AvailabilityMode availabilityMode, List<Address> current)

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.xsite.irac

Methods in org.infinispan.xsite.irac with parameters of type CacheTopology

Modifier and Type	Method	Description
void	DefaultIracManager.onTopologyUpdate(CacheTopology oldCacheTopology, CacheTopology newCacheTopology)
void	IracManager.onTopologyUpdate(CacheTopology oldCacheTopology, CacheTopology newCacheTopology)	Notifies a topology changed.
void	NoOpIracManager.onTopologyUpdate(CacheTopology oldCacheTopology, CacheTopology newCacheTopology)

Uses of CacheTopology in org.infinispan.xsite.statetransfer

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

Modifier and Type	Method	Description
void	NoOpXSiteStateTransferManager.onTopologyUpdated(CacheTopology cacheTopology, boolean stateTransferInProgress)
void	XSiteStateTransferManager.onTopologyUpdated(CacheTopology cacheTopology, boolean stateTransferInProgress)	Notifies XSiteStateTransferManager that a new CacheTopology is installed and if the local cluster state transfer is in progress (or about to start)
void	XSiteStateTransferManagerImpl.onTopologyUpdated(CacheTopology cacheTopology, boolean stateTransferInProgress)