Package | Description |
---|---|
org.infinispan.statetransfer |
Transfer of state to new caches in a cluster.
|
org.infinispan.topology | |
org.infinispan.transaction |
JTA transaction support.
|
org.infinispan.transaction.xa.recovery |
Modifier and Type | Method and Description |
---|---|
CacheTopology |
StateConsumerImpl.getCacheTopology() |
CacheTopology |
StateTransferManagerImpl.getCacheTopology() |
CacheTopology |
StateConsumer.getCacheTopology() |
CacheTopology |
StateTransferManager.getCacheTopology() |
Modifier and Type | Method and Description |
---|---|
void |
StateConsumerImpl.onTopologyUpdate(CacheTopology cacheTopology,
boolean isRebalance) |
void |
StateProviderImpl.onTopologyUpdate(CacheTopology cacheTopology,
boolean isRebalance) |
void |
StateConsumer.onTopologyUpdate(CacheTopology cacheTopology,
boolean isRebalance)
Receive notification of topology changes.
|
void |
StateProvider.onTopologyUpdate(CacheTopology cacheTopology,
boolean isRebalance)
Receive notification of topology changes.
|
Modifier and Type | Method and Description |
---|---|
CacheTopology |
ClusterCacheStatus.getCacheTopology() |
CacheTopology |
LocalTopologyManagerImpl.getCacheTopology(String cacheName) |
CacheTopology |
LocalTopologyManager.getCacheTopology(String cacheName) |
CacheTopology |
ClusterTopologyManagerImpl.handleJoin(String cacheName,
Address joiner,
CacheJoinInfo joinInfo,
int viewId) |
CacheTopology |
ClusterTopologyManager.handleJoin(String cacheName,
Address joiner,
CacheJoinInfo joinInfo,
int viewId)
Updates the members list and notifies the
RebalancePolicy . |
CacheTopology |
LocalTopologyManagerImpl.join(String cacheName,
CacheJoinInfo joinInfo,
CacheTopologyHandler stm) |
CacheTopology |
LocalTopologyManager.join(String cacheName,
CacheJoinInfo joinInfo,
CacheTopologyHandler stm)
Forwards the join request to the coordinator.
|
CacheTopology |
CacheTopology.Externalizer.readObject(ObjectInput unmarshaller) |
Modifier and Type | Method and Description |
---|---|
Set<Class<? extends CacheTopology>> |
CacheTopology.Externalizer.getTypeClasses() |
Modifier and Type | Method and Description |
---|---|
void |
LocalTopologyManagerImpl.handleConsistentHashUpdate(String cacheName,
CacheTopology cacheTopology,
int viewId) |
void |
LocalTopologyManager.handleConsistentHashUpdate(String cacheName,
CacheTopology cacheTopology,
int viewId)
Updates the current and/or pending consistent hash, without transferring any state.
|
void |
LocalTopologyManagerImpl.handleRebalance(String cacheName,
CacheTopology cacheTopology,
int viewId) |
void |
LocalTopologyManager.handleRebalance(String cacheName,
CacheTopology cacheTopology,
int viewId)
Performs the state transfer.
|
void |
CacheTopologyHandler.rebalance(CacheTopology cacheTopology)
Invoked when state transfer has to be started.
|
boolean |
ClusterCacheStatus.startRebalance(CacheTopology newTopology) |
void |
ClusterCacheStatus.updateCacheTopology(CacheTopology newTopology) |
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 |
CacheTopology.Externalizer.writeObject(ObjectOutput output,
CacheTopology cacheTopology) |
Modifier and Type | Method and Description |
---|---|
void |
ClusterTopologyManagerImpl.updateCacheStatusAfterMerge(String cacheName,
List<Address> clusterMembers,
List<CacheTopology> partitionTopologies) |
Constructor and Description |
---|
CacheTopologyControlCommand(String cacheName,
CacheTopologyControlCommand.Type type,
Address sender,
CacheTopology cacheTopology,
int viewId) |
Modifier and Type | Method and Description |
---|---|
void |
TransactionTable.cleanupStaleTransactions(CacheTopology cacheTopology) |
Modifier and Type | Method and Description |
---|---|
void |
RecoveryAwareTransactionTable.cleanupStaleTransactions(CacheTopology cacheTopology)
First moves the prepared transactions originated on the leavers into the recovery cache and then cleans up the
transactions that are not yet prepared.
|
Copyright © 2017 JBoss, a division of Red Hat. All Rights Reserved.