Package | Description |
---|---|
org.infinispan.commands.topology | |
org.infinispan.configuration.cache |
Cache configuration |
org.infinispan.distribution |
Classes relating to the distributed cache mode.
|
org.infinispan.distribution.ch |
Consistent Hash interfaces
|
org.infinispan.distribution.ch.impl | |
org.infinispan.distribution.impl | |
org.infinispan.notifications.cachelistener |
Cache -specific notifications and eventing. |
org.infinispan.notifications.cachelistener.event |
Cache -specific listener events |
org.infinispan.notifications.cachelistener.event.impl | |
org.infinispan.partitionhandling.impl | |
org.infinispan.scattered.impl | |
org.infinispan.statetransfer |
Transfer of state to new caches in a cluster.
|
org.infinispan.stream.impl | |
org.infinispan.topology |
Modifier and Type | Method and Description |
---|---|
ConsistentHash |
RebalanceStartCommand.getCurrentCH() |
ConsistentHash |
TopologyUpdateCommand.getCurrentCH() |
ConsistentHash |
TopologyUpdateStableCommand.getCurrentCH() |
ConsistentHash |
RebalanceStartCommand.getPendingCH() |
ConsistentHash |
TopologyUpdateCommand.getPendingCH() |
ConsistentHash |
TopologyUpdateStableCommand.getPendingCH() |
Modifier and Type | Method and Description |
---|---|
HashConfigurationBuilder |
HashConfigurationBuilder.consistentHashFactory(ConsistentHashFactory<? extends ConsistentHash> consistentHashFactory)
Deprecated.
Since 11.0. Will be removed in 14.0, the segment allocation will no longer be customizable.
|
Modifier and Type | Method and Description |
---|---|
ConsistentHash |
DistributionManager.getReadConsistentHash()
Deprecated.
Since 11.0, to be removed in 14.0. Please use
DistributionManager.getCacheTopology() instead. |
ConsistentHash |
DistributionManager.getWriteConsistentHash()
Deprecated.
Since 11.0, to be removed in 14.0. Please use
DistributionManager.getCacheTopology() instead. |
Modifier and Type | Interface and Description |
---|---|
interface |
ConsistentHashFactory<CH extends ConsistentHash>
Deprecated.
Since 11.0. Will be removed in 14.0, the segment allocation will no longer be customizable.
|
Modifier and Type | Method and Description |
---|---|
default ConsistentHash |
ConsistentHash.remapAddresses(UnaryOperator<Address> remapper)
Returns a new ConsistentHash with the addresses remapped according to the provided
UnaryOperator . |
Modifier and Type | Class and Description |
---|---|
class |
AbstractConsistentHashFactory<CH extends ConsistentHash> |
Modifier and Type | Class and Description |
---|---|
class |
AbstractConsistentHash |
class |
DefaultConsistentHash
Default
ConsistentHash implementation. |
class |
ReplicatedConsistentHash
Special implementation of
ConsistentHash for replicated caches. |
class |
ScatteredConsistentHash
CH used by scattered caches.
|
Modifier and Type | Method and Description |
---|---|
ConsistentHash |
DefaultConsistentHash.remapAddresses(UnaryOperator<Address> remapper) |
ConsistentHash |
ReplicatedConsistentHash.remapAddresses(UnaryOperator<Address> remapper) |
ConsistentHash |
ScatteredConsistentHash.remapAddresses(UnaryOperator<Address> remapper) |
Constructor and Description |
---|
OwnershipStatistics(ConsistentHash ch) |
OwnershipStatistics(ConsistentHash ch,
List<Address> activeNodes) |
Modifier and Type | Method and Description |
---|---|
ConsistentHash |
DistributionManagerImpl.getReadConsistentHash() |
ConsistentHash |
DistributionManagerImpl.getWriteConsistentHash() |
Modifier and Type | Method and Description |
---|---|
CompletionStage<Void> |
CacheNotifier.notifyDataRehashed(ConsistentHash oldCH,
ConsistentHash newCH,
ConsistentHash unionCH,
int newTopologyId,
boolean pre) |
CompletionStage<Void> |
CacheNotifierImpl.notifyDataRehashed(ConsistentHash oldCH,
ConsistentHash newCH,
ConsistentHash unionCH,
int newTopologyId,
boolean pre) |
Modifier and Type | Method and Description |
---|---|
ConsistentHash |
DataRehashedEvent.getConsistentHashAtEnd() |
default ConsistentHash |
TopologyChangedEvent.getConsistentHashAtEnd()
Deprecated.
|
ConsistentHash |
DataRehashedEvent.getConsistentHashAtStart() |
default ConsistentHash |
TopologyChangedEvent.getConsistentHashAtStart()
Deprecated.
|
ConsistentHash |
TopologyChangedEvent.getReadConsistentHashAtEnd() |
ConsistentHash |
TopologyChangedEvent.getReadConsistentHashAtStart() |
ConsistentHash |
DataRehashedEvent.getUnionConsistentHash()
Deprecated.
Since 9.0
|
ConsistentHash |
TopologyChangedEvent.getWriteConsistentHashAtEnd() |
ConsistentHash |
TopologyChangedEvent.getWriteConsistentHashAtStart() |
Modifier and Type | Method and Description |
---|---|
ConsistentHash |
EventImpl.getConsistentHashAtEnd() |
ConsistentHash |
EventImpl.getConsistentHashAtStart() |
ConsistentHash |
EventImpl.getReadConsistentHashAtEnd() |
ConsistentHash |
EventImpl.getReadConsistentHashAtStart() |
ConsistentHash |
EventImpl.getUnionConsistentHash() |
ConsistentHash |
EventImpl.getWriteConsistentHashAtEnd() |
ConsistentHash |
EventImpl.getWriteConsistentHashAtStart() |
Modifier and Type | Method and Description |
---|---|
void |
EventImpl.setReadConsistentHashAtEnd(ConsistentHash readConsistentHashAtEnd) |
void |
EventImpl.setReadConsistentHashAtStart(ConsistentHash readConsistentHashAtStart) |
void |
EventImpl.setUnionConsistentHash(ConsistentHash unionConsistentHash) |
void |
EventImpl.setWriteConsistentHashAtEnd(ConsistentHash writeConsistentHashAtEnd) |
void |
EventImpl.setWriteConsistentHashAtStart(ConsistentHash writeConsistentHashAtStart) |
Modifier and Type | Method and Description |
---|---|
ConsistentHash |
AvailabilityStrategyContext.calculateConflictHash(ConsistentHash preferredHash,
Set<ConsistentHash> distinctHashes,
List<Address> actualMembers) |
static ConsistentHash |
AvailabilityStrategy.ownersConsistentHash(CacheTopology topology,
ConsistentHashFactory chFactory)
Compute the read consistent hash for a topology with a
null union consistent hash. |
Modifier and Type | Method and Description |
---|---|
ConsistentHash |
AvailabilityStrategyContext.calculateConflictHash(ConsistentHash preferredHash,
Set<ConsistentHash> distinctHashes,
List<Address> actualMembers) |
Modifier and Type | Method and Description |
---|---|
ConsistentHash |
AvailabilityStrategyContext.calculateConflictHash(ConsistentHash preferredHash,
Set<ConsistentHash> distinctHashes,
List<Address> actualMembers) |
Modifier and Type | Method and Description |
---|---|
protected void |
ScatteredStateConsumerImpl.beforeTopologyInstalled(int topologyId,
boolean startRebalance,
ConsistentHash previousWriteCh,
ConsistentHash newWriteCh) |
Modifier and Type | Method and Description |
---|---|
protected void |
StateConsumerImpl.beforeTopologyInstalled(int topologyId,
boolean startRebalance,
ConsistentHash previousWriteCh,
ConsistentHash newWriteCh) |
protected IntSet |
StateConsumerImpl.getOwnedSegments(ConsistentHash consistentHash) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
AbstractCacheStream.isPrimaryOwner(ConsistentHash ch,
Object key) |
Modifier and Type | Method and Description |
---|---|
ConsistentHash |
ClusterCacheStatus.calculateConflictHash(ConsistentHash preferredHash,
Set<ConsistentHash> distinctHashes,
List<Address> actualMembers) |
ConsistentHash |
CacheTopology.getCurrentCH()
The current consistent hash.
|
ConsistentHash |
CacheTopology.getPendingCH()
The future consistent hash.
|
ConsistentHash |
CacheTopology.getReadConsistentHash()
Read operations should always go to the "current" owners.
|
ConsistentHash |
CacheTopology.getUnionCH()
The union of the current and future consistent hashes.
|
ConsistentHash |
CacheTopology.getWriteConsistentHash()
When there is a rebalance in progress, write operations should go to the union of the "current" and "future" owners.
|
Modifier and Type | Method and Description |
---|---|
ConsistentHash |
ClusterCacheStatus.calculateConflictHash(ConsistentHash preferredHash,
Set<ConsistentHash> distinctHashes,
List<Address> actualMembers) |
static boolean |
ClusterTopologyManagerImpl.distLostDataCheck(ConsistentHash stableCH,
List<Address> newMembers) |
static boolean |
ClusterTopologyManagerImpl.scatteredLostDataCheck(ConsistentHash stableCH,
List<Address> newMembers) |
Modifier and Type | Method and Description |
---|---|
ConsistentHash |
ClusterCacheStatus.calculateConflictHash(ConsistentHash preferredHash,
Set<ConsistentHash> distinctHashes,
List<Address> actualMembers) |
Constructor and Description |
---|
CacheTopology(int topologyId,
int rebalanceId,
ConsistentHash currentCH,
ConsistentHash pendingCH,
CacheTopology.Phase phase,
List<Address> actualMembers,
List<PersistentUUID> persistentUUIDs) |
CacheTopology(int topologyId,
int rebalanceId,
ConsistentHash currentCH,
ConsistentHash pendingCH,
ConsistentHash unionCH,
CacheTopology.Phase phase,
List<Address> actualMembers,
List<PersistentUUID> persistentUUIDs) |
Copyright © 2021 JBoss by Red Hat. All rights reserved.