| Package | Description |
|---|---|
| org.infinispan.partitionhandling.impl | |
| org.infinispan.topology |
| Modifier and Type | Method and Description |
|---|---|
CacheTopology |
PreferAvailabilityStrategy.computePreferredTopology(Map<Address,CacheStatusResponse> statusResponseMap)
Ignore the AvailabilityStrategyContext and only compute the preferred topology for testing.
|
void |
AvailabilityStrategy.onPartitionMerge(AvailabilityStrategyContext context,
Map<Address,CacheStatusResponse> statusResponseMap)
Called when two or more partitions merge, to compute the stable and current cache topologies for the merged
cluster.
|
void |
PreferAvailabilityStrategy.onPartitionMerge(AvailabilityStrategyContext context,
Map<Address,CacheStatusResponse> statusResponseMap) |
void |
PreferConsistencyStrategy.onPartitionMerge(AvailabilityStrategyContext context,
Map<Address,CacheStatusResponse> statusResponseMap) |
| Modifier and Type | Method and Description |
|---|---|
CacheStatusResponse |
ClusterCacheStatus.doJoin(Address joiner,
CacheJoinInfo joinInfo) |
CacheStatusResponse |
CacheStatusResponse.Externalizer.readObject(ObjectInput unmarshaller) |
| Modifier and Type | Method and Description |
|---|---|
Map<String,CacheStatusResponse> |
ManagerStatusResponse.getCaches() |
Set<Class<? extends CacheStatusResponse>> |
CacheStatusResponse.Externalizer.getTypeClasses() |
CompletionStage<CacheStatusResponse> |
ClusterTopologyManager.handleJoin(String cacheName,
Address joiner,
CacheJoinInfo joinInfo,
int viewId)
Signals that a new member is joining the cache.
|
CompletionStage<CacheStatusResponse> |
ClusterTopologyManagerImpl.handleJoin(String cacheName,
Address joiner,
CacheJoinInfo joinInfo,
int joinerViewId) |
CompletionStage<CacheStatusResponse> |
LocalTopologyManagerImpl.sendJoinRequest(String cacheName,
CacheJoinInfo joinInfo,
long timeout,
long endTime) |
| Modifier and Type | Method and Description |
|---|---|
CompletionStage<CacheTopology> |
LocalTopologyManagerImpl.handleJoinResponse(String cacheName,
org.infinispan.topology.LocalCacheStatus cacheStatus,
CacheStatusResponse initialStatus) |
void |
CacheStatusResponse.Externalizer.writeObject(ObjectOutput output,
CacheStatusResponse cacheStatusResponse) |
| Modifier and Type | Method and Description |
|---|---|
void |
ClusterCacheStatus.doMergePartitions(Map<Address,CacheStatusResponse> statusResponses) |
| Constructor and Description |
|---|
ManagerStatusResponse(Map<String,CacheStatusResponse> caches,
boolean rebalancingEnabled) |
Copyright © 2022 JBoss by Red Hat. All rights reserved.