| Package | Description |
|---|---|
| org.infinispan.conflict.impl |
This package contains implementations of the conflict resolution API.
|
| org.infinispan.distribution |
Classes relating to the distributed cache mode.
|
| org.infinispan.distribution.impl | |
| org.infinispan.distribution.util | |
| org.infinispan.interceptors.distribution |
Interceptors dealing with command replication in distributed/replicated mode.
|
| org.infinispan.interceptors.impl |
Basic interceptors
|
| org.infinispan.interceptors.locking |
Interceptors dealing with locking.
|
| org.infinispan.partitionhandling.impl | |
| org.infinispan.scattered.impl | |
| 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.
|
| Modifier and Type | Method and Description |
|---|---|
CompletableFuture<List<Map<Address,CacheEntry<K,V>>>> |
StateReceiver.getAllReplicasForSegment(int segmentId,
LocalizedCacheTopology topology,
long timeout)
Return all replicas of a cache entry for a given segment.
|
CompletableFuture<List<Map<Address,CacheEntry<K,V>>>> |
StateReceiverImpl.getAllReplicasForSegment(int segmentId,
LocalizedCacheTopology topology,
long timeout) |
| Modifier and Type | Method and Description |
|---|---|
LocalizedCacheTopology |
DistributionManager.createLocalizedCacheTopology(CacheTopology cacheTopology) |
LocalizedCacheTopology |
DistributionManager.getCacheTopology() |
static LocalizedCacheTopology |
LocalizedCacheTopology.makeSegmentedSingletonTopology(KeyPartitioner keyPartitioner,
int numSegments,
Address localAddress)
Creates a new local topology that has a single address but multiple segments.
|
static LocalizedCacheTopology |
LocalizedCacheTopology.makeSingletonTopology(CacheMode cacheMode,
Address localAddress) |
| Modifier and Type | Method and Description |
|---|---|
LocalizedCacheTopology |
DistributionManagerImpl.createLocalizedCacheTopology(CacheTopology cacheTopology) |
LocalizedCacheTopology |
DistributionManagerImpl.getCacheTopology() |
static LocalizedCacheTopology |
DistributionManagerImpl.makeSingletonTopology(CacheMode cacheMode,
KeyPartitioner keyPartitioner,
int numSegments,
Address localAddress) |
| Modifier and Type | Field and Description |
|---|---|
protected LocalizedCacheTopology |
ReadOnlySegmentAwareCollection.topology |
protected LocalizedCacheTopology |
ReadOnlySegmentAwareIterator.topology |
protected LocalizedCacheTopology |
ReadOnlySegmentAwareMap.topology |
| Constructor and Description |
|---|
ReadOnlySegmentAwareCollection(Collection<E> set,
LocalizedCacheTopology topology,
IntSet allowedSegments) |
ReadOnlySegmentAwareEntryCollection(Set<Map.Entry<K,V>> set,
LocalizedCacheTopology topology,
IntSet allowedSegments) |
ReadOnlySegmentAwareEntryIterator(Iterator<Map.Entry<K,V>> iter,
LocalizedCacheTopology topology,
IntSet allowedSegments) |
ReadOnlySegmentAwareIterator(Iterator<E> iter,
LocalizedCacheTopology topology,
IntSet allowedSegments) |
ReadOnlySegmentAwareMap(Map<K,V> map,
LocalizedCacheTopology topology,
IntSet allowedSegments) |
| Modifier and Type | Method and Description |
|---|---|
protected LocalizedCacheTopology |
BaseDistributionInterceptor.checkTopologyId(TopologyAffectedCommand command) |
| Modifier and Type | Method and Description |
|---|---|
CompletionStage<Void> |
BaseDistributionInterceptor.ReadManyCommandHelper.fetchRequiredKeys(LocalizedCacheTopology cacheTopology,
Map<Address,List<Object>> requestedKeys,
List<Object> availableKeys,
InvocationContext ctx,
C command) |
CompletionStage<Void> |
BaseDistributionInterceptor.ReadOnlyManyHelper.fetchRequiredKeys(LocalizedCacheTopology cacheTopology,
Map<Address,List<Object>> requestedKeys,
List<Object> availableKeys,
InvocationContext ctx,
ReadOnlyManyCommand command) |
protected DistributionInfo |
BaseDistributionInterceptor.retrieveDistributionInfo(LocalizedCacheTopology topology,
ReplicableCommand command,
Object key) |
| Modifier and Type | Method and Description |
|---|---|
protected LocalizedCacheTopology |
AbstractIracLocalSiteInterceptor.getCacheTopology() |
| Modifier and Type | Method and Description |
|---|---|
LocalizedCacheTopology |
ClusteringDependentLogic.getCacheTopology() |
LocalizedCacheTopology |
ClusteringDependentLogic.AbstractClusteringDependentLogic.getCacheTopology() |
LocalizedCacheTopology |
ClusteringDependentLogic.LocalLogic.getCacheTopology() |
LocalizedCacheTopology |
OrderedClusteringDependentLogic.getCacheTopology() |
| Modifier and Type | Method and Description |
|---|---|
protected boolean |
PartitionHandlingManagerImpl.isKeyOperationAllowed(boolean isWrite,
long flagBitSet,
LocalizedCacheTopology cacheTopology,
Object key)
Check if a read/write operation is allowed with the actual members
|
| Modifier and Type | Method and Description |
|---|---|
protected boolean |
ScatteredPartitionHandlingManagerImpl.isKeyOperationAllowed(boolean isWrite,
long flagBitSet,
LocalizedCacheTopology cacheTopology,
Object key) |
| Modifier and Type | Method and Description |
|---|---|
static Map<Integer,Collection<Object>> |
TriangleFunctionsUtil.filterBySegment(LocalizedCacheTopology cacheTopology,
Collection<Object> keys) |
Copyright © 2021 JBoss by Red Hat. All rights reserved.