Uses of Class
org.infinispan.topology.CacheTopology
-
Packages that use CacheTopology Package Description org.infinispan.distribution Classes relating to the distributed cache mode.org.infinispan.notifications.cachelistener Cache
-specific notifications and eventing.org.infinispan.statetransfer Transfer of state to new caches in a cluster.org.infinispan.topology 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. -
-
Uses of CacheTopology in org.infinispan.distribution
Subclasses of CacheTopology in org.infinispan.distribution Modifier and Type Class Description class
LocalizedCacheTopology
ExtendsCacheTopology
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.notifications.cachelistener
Methods in org.infinispan.notifications.cachelistener with parameters of type CacheTopology Modifier and Type Method Description java.util.concurrent.CompletionStage<java.lang.Void>
CacheNotifier. notifyTopologyChanged(CacheTopology oldTopology, CacheTopology newTopology, int newTopologyId, boolean pre)
java.util.concurrent.CompletionStage<java.lang.Void>
CacheNotifierImpl. notifyTopologyChanged(CacheTopology oldTopology, CacheTopology newTopology, int newTopologyId, boolean pre)
-
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 with parameters of type CacheTopology Modifier and Type Method Description java.util.concurrent.CompletableFuture<java.lang.Void>
StateConsumer. onTopologyUpdate(CacheTopology cacheTopology, boolean isRebalance)
Receive notification of topology changes.java.util.concurrent.CompletableFuture<java.lang.Void>
StateConsumerImpl. onTopologyUpdate(CacheTopology cacheTopology, boolean isRebalance)
java.util.concurrent.CompletableFuture<java.lang.Void>
StateProvider. onTopologyUpdate(CacheTopology cacheTopology, boolean isRebalance)
Receive notification of topology changes.java.util.concurrent.CompletableFuture<java.lang.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(java.io.ObjectInput unmarshaller)
CacheTopology
CacheStatusResponse. getCacheTopology()
CacheTopology
LocalTopologyManager. getCacheTopology(java.lang.String cacheName)
CacheTopology
LocalTopologyManagerImpl. getCacheTopology(java.lang.String cacheName)
CacheTopology
ClusterCacheStatus. getCurrentTopology()
CacheTopology
LocalTopologyManager. getStableCacheTopology(java.lang.String cacheName)
CacheTopology
LocalTopologyManagerImpl. getStableCacheTopology(java.lang.String cacheName)
CacheTopology
CacheStatusResponse. getStableTopology()
CacheTopology
ClusterCacheStatus. getStableTopology()
CacheTopology
LocalTopologyManager. join(java.lang.String cacheName, CacheJoinInfo joinInfo, CacheTopologyHandler stm, org.infinispan.partitionhandling.impl.PartitionHandlingManager phm)
Forwards the join request to the coordinator.CacheTopology
LocalTopologyManagerImpl. join(java.lang.String cacheName, CacheJoinInfo joinInfo, CacheTopologyHandler stm, org.infinispan.partitionhandling.impl.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 java.util.Set<java.lang.Class<? extends CacheTopology>>
CacheTopology.Externalizer. getTypeClasses()
Methods in org.infinispan.topology with parameters of type CacheTopology Modifier and Type Method Description void
ClusterTopologyManager. broadcastRebalanceStart(java.lang.String cacheName, CacheTopology cacheTopology, boolean totalOrder, boolean distributed)
void
ClusterTopologyManagerImpl. broadcastRebalanceStart(java.lang.String cacheName, CacheTopology cacheTopology, boolean totalOrder, boolean distributed)
void
ClusterTopologyManager. broadcastShutdownCache(java.lang.String cacheName, CacheTopology currentTopology, boolean totalOrder, boolean distributed)
void
ClusterTopologyManagerImpl. broadcastShutdownCache(java.lang.String cacheName, CacheTopology cacheTopology, boolean totalOrder, boolean distributed)
void
ClusterTopologyManager. broadcastStableTopologyUpdate(java.lang.String cacheName, CacheTopology cacheTopology, boolean totalOrder, boolean distributed)
void
ClusterTopologyManagerImpl. broadcastStableTopologyUpdate(java.lang.String cacheName, CacheTopology cacheTopology, boolean totalOrder, boolean distributed)
void
ClusterTopologyManager. broadcastTopologyUpdate(java.lang.String cacheName, CacheTopology cacheTopology, AvailabilityMode availabilityMode, boolean totalOrder, boolean distributed)
void
ClusterTopologyManagerImpl. broadcastTopologyUpdate(java.lang.String cacheName, CacheTopology cacheTopology, AvailabilityMode availabilityMode, boolean totalOrder, boolean distributed)
void
CacheTopology.Externalizer. doWriteObject(java.io.ObjectOutput output, CacheTopology cacheTopology)
void
LocalTopologyManager. handleRebalance(java.lang.String cacheName, CacheTopology cacheTopology, int viewId, Address sender)
Performs the state transfer.void
LocalTopologyManagerImpl. handleRebalance(java.lang.String cacheName, CacheTopology cacheTopology, int viewId, Address sender)
void
LocalTopologyManager. handleStableTopologyUpdate(java.lang.String cacheName, CacheTopology cacheTopology, Address sender, int viewId)
Update the stable cache topology.void
LocalTopologyManagerImpl. handleStableTopologyUpdate(java.lang.String cacheName, CacheTopology newStableTopology, Address sender, int viewId)
void
LocalTopologyManager. handleTopologyUpdate(java.lang.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(java.lang.String cacheName, CacheTopology cacheTopology, AvailabilityMode availabilityMode, int viewId, Address sender)
void
ClusterCacheStatus. queueConflictResolution(CacheTopology conflictTopology, java.util.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(java.lang.String cacheName, CacheTopologyControlCommand.Type type, Address sender, CacheTopology cacheTopology, AvailabilityMode availabilityMode, int viewId)
-
Uses of CacheTopology in org.infinispan.util
Methods in org.infinispan.util that return CacheTopology Modifier and Type Method Description CacheTopology
AbstractControlledLocalTopologyManager. getCacheTopology(java.lang.String cacheName)
CacheTopology
AbstractControlledLocalTopologyManager. getStableCacheTopology(java.lang.String cacheName)
CacheTopology
AbstractControlledLocalTopologyManager. join(java.lang.String cacheName, CacheJoinInfo joinInfo, CacheTopologyHandler stm, org.infinispan.partitionhandling.impl.PartitionHandlingManager phm)
Methods in org.infinispan.util with parameters of type CacheTopology Modifier and Type Method Description protected void
AbstractControlledLocalTopologyManager. beforeHandleRebalance(java.lang.String cacheName, CacheTopology cacheTopology, int viewId)
protected void
AbstractControlledLocalTopologyManager. beforeHandleTopologyUpdate(java.lang.String cacheName, CacheTopology cacheTopology, int viewId)
void
AbstractControlledLocalTopologyManager. handleRebalance(java.lang.String cacheName, CacheTopology cacheTopology, int viewId, Address sender)
void
AbstractControlledLocalTopologyManager. handleStableTopologyUpdate(java.lang.String cacheName, CacheTopology cacheTopology, Address sender, int viewId)
void
AbstractControlledLocalTopologyManager. handleTopologyUpdate(java.lang.String cacheName, CacheTopology cacheTopology, AvailabilityMode availabilityMode, int viewId, Address sender)
-