Modifier and Type | Method and Description |
---|---|
K |
KeyAffinityService.getKeyForAddress(Address address)
Returns a key that will be distributed on the cluster node identified by address.
|
Modifier and Type | Method and Description |
---|---|
static <K,V> KeyAffinityService<K> |
KeyAffinityServiceFactory.newKeyAffinityService(Cache<K,V> cache,
Collection<Address> filter,
KeyGenerator<K> keyGenerator,
Executor ex,
int keyBufferSize)
|
static <K,V> KeyAffinityService<K> |
KeyAffinityServiceFactory.newKeyAffinityService(Cache<K,V> cache,
Collection<Address> filter,
KeyGenerator<K> keyGenerator,
Executor ex,
int keyBufferSize,
boolean start)
Creates a service that would only generate keys for addresses specified in filter.
|
Constructor and Description |
---|
KeyAffinityServiceImpl(Executor executor,
Cache<? extends K,?> cache,
KeyGenerator<? extends K> keyGenerator,
int bufferSize,
Collection<Address> filter,
boolean start)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
Map<Address,BlockingQueue<K>> |
KeyAffinityServiceImpl.getAddress2KeysMapping() |
Modifier and Type | Method and Description |
---|---|
K |
KeyAffinityServiceImpl.getKeyForAddress(Address address) |
Constructor and Description |
---|
KeyAffinityServiceImpl(Executor executor,
Cache<? extends K,?> cache,
KeyGenerator<? extends K> keyGenerator,
int bufferSize,
Collection<Address> filter,
boolean start) |
Modifier and Type | Method and Description |
---|---|
<T> DistributedExecuteCommand<T> |
CommandsFactory.buildDistributedExecuteCommand(Callable<T> callable,
Address sender,
Collection keys)
Builds a DistributedExecuteCommand used for migration and execution of distributed Callables and Runnables.
|
<T> DistributedExecuteCommand<T> |
CommandsFactoryImpl.buildDistributedExecuteCommand(Callable<T> callable,
Address sender,
Collection keys) |
InvalidateCommand |
CommandsFactory.buildInvalidateFromL1Command(Address origin,
Set<Flag> flags,
Collection<Object> keys) |
InvalidateCommand |
CommandsFactoryImpl.buildInvalidateFromL1Command(Address origin,
Set<Flag> flags,
Collection<Object> keys) |
StateRequestCommand |
CommandsFactory.buildStateRequestCommand(StateRequestCommand.Type subtype,
Address sender,
int viewId,
Set<Integer> segments)
Builds a StateRequestCommand used for requesting transactions and locks and for starting or canceling transfer of cache entries.
|
StateRequestCommand |
CommandsFactoryImpl.buildStateRequestCommand(StateRequestCommand.Type subtype,
Address sender,
int viewId,
Set<Integer> segments) |
StateResponseCommand |
CommandsFactory.buildStateResponseCommand(Address sender,
int viewId,
Collection<StateChunk> stateChunks)
Builds a StateResponseCommand used for pushing cache entries to another node in response to a StateRequestCommand.
|
StateResponseCommand |
CommandsFactoryImpl.buildStateResponseCommand(Address sender,
int topologyId,
Collection<StateChunk> stateChunks) |
static CommandInvocationId |
CommandInvocationId.generateId(Address address) |
Modifier and Type | Method and Description |
---|---|
Address |
BaseRpcCommand.getOrigin() |
Address |
CacheRpcCommand.getOrigin()
Get the origin of the command
|
Modifier and Type | Method and Description |
---|---|
void |
BaseRpcCommand.setOrigin(Address origin) |
void |
CacheRpcCommand.setOrigin(Address origin)
Set the origin of the command
|
Modifier and Type | Method and Description |
---|---|
Address |
AbstractTransactionBoundaryCommand.getOrigin() |
Modifier and Type | Method and Description |
---|---|
void |
AbstractTransactionBoundaryCommand.setOrigin(Address origin) |
Modifier and Type | Method and Description |
---|---|
boolean |
InvalidateL1Command.isCausedByALocalWrite(Address address)
Returns true if the write that caused the invalidation was performed on this node.
|
Constructor and Description |
---|
InvalidateL1Command(Address writeOrigin,
DataContainer dc,
DistributionManager dm,
CacheNotifier notifier,
Set<Flag> flags,
Collection<Object> keys,
CommandInvocationId commandInvocationId) |
Modifier and Type | Method and Description |
---|---|
Address |
SingleKeyNonTxInvocationContext.getOrigin() |
Address |
InvocationContext.getOrigin() |
Constructor and Description |
---|
SingleKeyNonTxInvocationContext(Address origin,
Equivalence<Object> keyEquivalence) |
Modifier and Type | Method and Description |
---|---|
Address |
ImmutableContext.getOrigin() |
Address |
AbstractInvocationContext.getOrigin() |
Modifier and Type | Method and Description |
---|---|
Collection<Address> |
LocalTxInvocationContext.getRemoteLocksAcquired() |
Modifier and Type | Method and Description |
---|---|
void |
LocalTxInvocationContext.remoteLocksAcquired(Collection<Address> nodes) |
Constructor and Description |
---|
AbstractInvocationContext(Address origin) |
AbstractTxInvocationContext(T cacheTransaction,
Address origin) |
ClearInvocationContext(Address origin) |
NonTxInvocationContext(Address origin,
Equivalence<Object> keyEq) |
NonTxInvocationContext(int numEntries,
Address origin,
Equivalence<Object> keyEq) |
Modifier and Type | Method and Description |
---|---|
Address |
FailoverContext.executionFailureLocation()
Returns an Address of the node where the task failed
|
Address |
DistributedTaskFailoverPolicy.failover(FailoverContext context)
As parts of distributively executed task can fail due to the task itself throwing an exception
or it can be an Infinispan system caused failure (e.g node failed or left cluster during task
execution etc).
|
protected <T> Address |
DefaultExecutorService.selectExecutionNode(DistributedTask<T> task) |
protected Address |
DefaultExecutorService.selectExecutionNode(List<Address> candidates) |
Modifier and Type | Method and Description |
---|---|
List<Address> |
FailoverContext.executionCandidates()
Returns a list of candidates for possible repeated execution governed by installed
DistributedTaskFailoverPolicy |
protected <T> List<Address> |
DefaultExecutorService.executionCandidates(DistributedTask<T> task) |
protected List<Address> |
DefaultExecutorService.getMembers() |
protected <K> Map<Address,List<K>> |
DefaultExecutorService.keysToExecutionNodes(DistributedTaskExecutionPolicy policy,
K... input) |
protected List<Address> |
DefaultExecutorService.randomClusterMembers(List<Address> members,
int numNeeded) |
Modifier and Type | Method and Description |
---|---|
protected <T,K> org.infinispan.distexec.DefaultExecutorService.DistributedTaskPart<T> |
DefaultExecutorService.createDistributedTaskPart(DistributedTask<T> task,
DistributedExecuteCommand<T> c,
Address target,
int failoverCount) |
protected <T,K> org.infinispan.distexec.DefaultExecutorService.DistributedTaskPart<T> |
DefaultExecutorService.createDistributedTaskPart(DistributedTask<T> task,
DistributedExecuteCommand<T> c,
List<K> inputKeys,
Address target,
int failoverCount) |
<T> NotifyingFuture<T> |
DefaultExecutorService.submit(Address target,
Callable<T> task) |
<T> NotifyingFuture<T> |
DistributedExecutorService.submit(Address target,
Callable<T> task)
Submits the given Callable task for execution on the specified target Infinispan node.
|
<K> Future<V> |
DistributedExecutionCompletionService.submit(Address target,
Callable<V> task) |
<T> NotifyingFuture<T> |
DefaultExecutorService.submit(Address target,
DistributedTask<T> task) |
<T> NotifyingFuture<T> |
DistributedExecutorService.submit(Address target,
DistributedTask<T> task)
Submits the given DistributedTask for execution on the specified target Infinispan node.
|
Modifier and Type | Method and Description |
---|---|
protected List<Address> |
DefaultExecutorService.randomClusterMembers(List<Address> members,
int numNeeded) |
protected Address |
DefaultExecutorService.selectExecutionNode(List<Address> candidates) |
Modifier and Type | Method and Description |
---|---|
protected <T> Map<Address,? extends Collection<T>> |
MapReduceTask.mapKeysToNodes(Collection<T> keysToMap)
Deprecated.
|
protected <T> Map<Address,? extends Collection<T>> |
MapReduceTask.mapKeysToNodes(Collection<T> keysToMap,
boolean useIntermediateCompositeKey)
Deprecated.
|
protected <T> Map<Address,? extends Collection<T>> |
MapReduceTask.mapKeysToNodes(DistributionManager dm,
Collection<T> keysToMap,
boolean useIntermediateCompositeKey)
Deprecated.
|
<T> Map<Address,List<T>> |
MapReduceManagerImpl.mapKeysToNodes(DistributionManager dm,
String taskId,
Collection<T> keysToMap) |
<T> Map<Address,List<T>> |
MapReduceManager.mapKeysToNodes(DistributionManager dm,
String taskId,
Collection<T> keysToMap)
Maps Map/Reduce task intermediate or input keys to nodes on Infinispan cluster
|
Modifier and Type | Method and Description |
---|---|
protected <V> org.infinispan.distexec.mapreduce.MapReduceTask.ReduceTaskPart<V> |
MapReduceTask.createReducePart(ReduceCommand<KOut,VOut> cmd,
Address target,
String destCacheName)
Deprecated.
|
protected <V> org.infinispan.distexec.mapreduce.MapReduceTask.MapTaskPart<V> |
MapReduceTask.createTaskMapPart(MapCombineCommand<KIn,VIn,KOut,VOut> cmd,
Address target,
boolean distributedReduce)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
Address |
DistributionManager.getPrimaryLocation(Object key)
Returns the first Address containing the key.
|
Modifier and Type | Method and Description |
---|---|
List<Address> |
DistributionManager.locate(Object key)
Locates a key in a cluster.
|
Set<Address> |
DistributionManager.locateAll(Collection<Object> keys)
Locates a list of keys in a cluster.
|
Modifier and Type | Method and Description |
---|---|
void |
L1Manager.addRequestor(Object key,
Address requestor)
Records a request that will be cached in another nodes L1
|
Future<?> |
L1Manager.flushCache(Collection<Object> key,
Address origin,
boolean assumeOriginKeptEntryInL1) |
Modifier and Type | Method and Description |
---|---|
default Address |
ConsistentHash.locatePrimaryOwner(Object key)
Should be equivalent to return the first element of
ConsistentHash.locateOwners(java.lang.Object) . |
Address |
ConsistentHash.locatePrimaryOwnerForSegment(int segmentId) |
Modifier and Type | Method and Description |
---|---|
List<Address> |
ConsistentHash.getMembers()
Should return the addresses of the nodes used to create this consistent hash.
|
default Set<Address> |
ConsistentHash.locateAllOwners(Collection<Object> keys) |
default List<Address> |
ConsistentHash.locateOwners(Object key)
Finds all the owners of a key.
|
List<Address> |
ConsistentHash.locateOwnersForSegment(int segmentId) |
Modifier and Type | Method and Description |
---|---|
Set<Integer> |
ConsistentHash.getPrimarySegmentsForOwner(Address owner)
Returns the segments that this cache member is the primary owner for.
|
Set<Integer> |
ConsistentHash.getSegmentsForOwner(Address owner)
Returns the segments owned by a cache member.
|
default boolean |
ConsistentHash.isKeyLocalToNode(Address nodeAddress,
Object key)
Test to see whether a key is owned by a given node.
|
default boolean |
ConsistentHash.isSegmentLocalToNode(Address nodeAddress,
int segmentId)
Check if a segment is local to a given member.
|
Modifier and Type | Method and Description |
---|---|
CH |
ConsistentHashFactory.create(Hash hashFunction,
int numOwners,
int numSegments,
List<Address> members,
Map<Address,Float> capacityFactors)
Create a new consistent hash instance.
|
CH |
ConsistentHashFactory.create(Hash hashFunction,
int numOwners,
int numSegments,
List<Address> members,
Map<Address,Float> capacityFactors)
Create a new consistent hash instance.
|
CH |
ConsistentHashFactory.updateMembers(CH baseCH,
List<Address> newMembers,
Map<Address,Float> capacityFactors)
Create a new consistent hash instance, based on an existing instance, but with a new list of members.
|
CH |
ConsistentHashFactory.updateMembers(CH baseCH,
List<Address> newMembers,
Map<Address,Float> capacityFactors)
Create a new consistent hash instance, based on an existing instance, but with a new list of members.
|
Modifier and Type | Field and Description |
---|---|
protected Map<Address,Float> |
SyncConsistentHashFactory.Builder.capacityFactors |
protected List<Address> |
SyncConsistentHashFactory.Builder.sortedMembers |
Modifier and Type | Method and Description |
---|---|
protected Address |
DefaultConsistentHashFactory.findNewBackupOwner(DefaultConsistentHashFactory.Builder builder,
Collection<Address> excludes,
Address owner) |
protected Address |
DefaultConsistentHashFactory.findNewPrimaryOwner(DefaultConsistentHashFactory.Builder builder,
Collection<Address> candidates,
Address primaryOwner) |
Address |
DefaultConsistentHashFactory.Builder.getPrimaryOwner(int segment) |
Address |
DefaultConsistentHash.locatePrimaryOwner(Object key) |
Address |
ReplicatedConsistentHash.locatePrimaryOwner(Object key) |
Address |
DefaultConsistentHash.locatePrimaryOwnerForSegment(int segmentId) |
Address |
ReplicatedConsistentHash.locatePrimaryOwnerForSegment(int segmentId) |
Modifier and Type | Method and Description |
---|---|
List<Address> |
DefaultConsistentHashFactory.Builder.getBackupOwners(int segment) |
Map<Address,Float> |
DefaultConsistentHash.getCapacityFactors() |
Map<Address,Float> |
DefaultConsistentHashFactory.Builder.getCapacityFactors() |
List<Address> |
DefaultConsistentHash.getMembers() |
List<Address> |
DefaultConsistentHashFactory.Builder.getMembers() |
List<Address> |
ReplicatedConsistentHash.getMembers() |
List<Address> |
DefaultConsistentHashFactory.Builder.getOwners(int segment) |
Set<Address> |
DefaultConsistentHash.locateAllOwners(Collection<Object> keys) |
Set<Address> |
ReplicatedConsistentHash.locateAllOwners(Collection<Object> keys) |
List<Address> |
DefaultConsistentHash.locateOwners(Object key) |
List<Address> |
ReplicatedConsistentHash.locateOwners(Object key) |
List<Address> |
DefaultConsistentHash.locateOwnersForSegment(int segmentId) |
List<Address> |
ReplicatedConsistentHash.locateOwnersForSegment(int segmentId) |
protected List<Address> |
SyncConsistentHashFactory.Builder.sort(List<Address> members,
Map<Address,Float> capacityFactors) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
TopologyAwareSyncConsistentHashFactory.Builder.addBackupOwner(int segment,
Address candidate) |
protected boolean |
SyncConsistentHashFactory.Builder.addBackupOwner(int segment,
Address candidate) |
boolean |
DefaultConsistentHashFactory.Builder.addOwner(int segment,
Address owner) |
protected void |
SyncConsistentHashFactory.Builder.addOwnerNoCheck(int segment,
Address owner) |
void |
DefaultConsistentHashFactory.Builder.addPrimaryOwner(int segment,
Address newPrimaryOwner) |
protected boolean |
SyncConsistentHashFactory.Builder.addPrimaryOwner(int segment,
Address candidate) |
protected double |
TopologyAwareSyncConsistentHashFactory.Builder.computeExpectedSegmentsForNode(Address node,
int numCopies) |
protected double |
SyncConsistentHashFactory.Builder.computeExpectedSegmentsForNode(Address node,
int numCopies) |
void |
OwnershipStatistics.decOwned(Address a) |
void |
OwnershipStatistics.decPrimaryOwned(Address a) |
protected Address |
DefaultConsistentHashFactory.findNewBackupOwner(DefaultConsistentHashFactory.Builder builder,
Collection<Address> excludes,
Address owner) |
protected Address |
DefaultConsistentHashFactory.findNewPrimaryOwner(DefaultConsistentHashFactory.Builder builder,
Collection<Address> candidates,
Address primaryOwner) |
float |
DefaultConsistentHashFactory.Builder.getCapacityFactor(Address node) |
int |
OwnershipStatistics.getOwned(Address a) |
int |
DefaultConsistentHashFactory.Builder.getOwned(Address node) |
float |
DefaultConsistentHashFactory.Builder.getOwnedPerCapacity(Address node) |
int |
OwnershipStatistics.getPrimaryOwned(Address a) |
float |
DefaultConsistentHashFactory.Builder.getPrimaryOwnedPerCapacity(Address node) |
Set<Integer> |
DefaultConsistentHash.getPrimarySegmentsForOwner(Address owner) |
Set<Integer> |
ReplicatedConsistentHash.getPrimarySegmentsForOwner(Address owner) |
Set<Integer> |
DefaultConsistentHash.getSegmentsForOwner(Address owner) |
Set<Integer> |
ReplicatedConsistentHash.getSegmentsForOwner(Address owner) |
void |
OwnershipStatistics.incOwned(Address a) |
void |
OwnershipStatistics.incPrimaryOwned(Address a) |
boolean |
DefaultConsistentHash.isKeyLocalToNode(Address nodeAddress,
Object key) |
boolean |
ReplicatedConsistentHash.isKeyLocalToNode(Address nodeAddress,
Object key) |
boolean |
DefaultConsistentHash.isSegmentLocalToNode(Address nodeAddress,
int segmentId) |
boolean |
ReplicatedConsistentHash.isSegmentLocalToNode(Address nodeAddress,
int segmentId) |
boolean |
DefaultConsistentHashFactory.Builder.removeOwner(int segment,
Address owner) |
void |
DefaultConsistentHashFactory.Builder.replacePrimaryOwnerWithBackup(int segment,
Address newPrimaryOwner) |
Modifier and Type | Method and Description |
---|---|
boolean |
DefaultConsistentHashFactory.Builder.addOwners(int segment,
Collection<Address> newOwners) |
protected boolean |
TopologyAwareSyncConsistentHashFactory.Builder.canAddOwners(List<Address> owners) |
protected boolean |
SyncConsistentHashFactory.Builder.canAddOwners(List<Address> owners) |
protected void |
SyncConsistentHashFactory.checkCapacityFactors(List<Address> members,
Map<Address,Float> capacityFactors) |
protected void |
SyncConsistentHashFactory.checkCapacityFactors(List<Address> members,
Map<Address,Float> capacityFactors) |
int |
DefaultConsistentHashFactory.Builder.computeActualNumOwners(int numOwners,
List<Address> members,
Map<Address,Float> capacityFactors) |
int |
DefaultConsistentHashFactory.Builder.computeActualNumOwners(int numOwners,
List<Address> members,
Map<Address,Float> capacityFactors) |
ReplicatedConsistentHash |
ReplicatedConsistentHashFactory.create(Hash hashFunction,
int numOwners,
int numSegments,
List<Address> members,
Map<Address,Float> capacityFactors) |
ReplicatedConsistentHash |
ReplicatedConsistentHashFactory.create(Hash hashFunction,
int numOwners,
int numSegments,
List<Address> members,
Map<Address,Float> capacityFactors) |
DefaultConsistentHash |
DefaultConsistentHashFactory.create(Hash hashFunction,
int numOwners,
int numSegments,
List<Address> members,
Map<Address,Float> capacityFactors) |
DefaultConsistentHash |
DefaultConsistentHashFactory.create(Hash hashFunction,
int numOwners,
int numSegments,
List<Address> members,
Map<Address,Float> capacityFactors) |
ReplicatedConsistentHash |
SyncReplicatedConsistentHashFactory.create(Hash hashFunction,
int numOwners,
int numSegments,
List<Address> members,
Map<Address,Float> capacityFactors) |
ReplicatedConsistentHash |
SyncReplicatedConsistentHashFactory.create(Hash hashFunction,
int numOwners,
int numSegments,
List<Address> members,
Map<Address,Float> capacityFactors) |
DefaultConsistentHash |
SyncConsistentHashFactory.create(Hash hashFunction,
int numOwners,
int numSegments,
List<Address> members,
Map<Address,Float> capacityFactors) |
DefaultConsistentHash |
SyncConsistentHashFactory.create(Hash hashFunction,
int numOwners,
int numSegments,
List<Address> members,
Map<Address,Float> capacityFactors) |
protected TopologyAwareSyncConsistentHashFactory.Builder |
TopologyAwareSyncConsistentHashFactory.createBuilder(Hash hashFunction,
int numOwners,
int numSegments,
List<Address> members,
Map<Address,Float> capacityFactors) |
protected TopologyAwareSyncConsistentHashFactory.Builder |
TopologyAwareSyncConsistentHashFactory.createBuilder(Hash hashFunction,
int numOwners,
int numSegments,
List<Address> members,
Map<Address,Float> capacityFactors) |
protected SyncConsistentHashFactory.Builder |
SyncConsistentHashFactory.createBuilder(Hash hashFunction,
int numOwners,
int numSegments,
List<Address> members,
Map<Address,Float> capacityFactors) |
protected SyncConsistentHashFactory.Builder |
SyncConsistentHashFactory.createBuilder(Hash hashFunction,
int numOwners,
int numSegments,
List<Address> members,
Map<Address,Float> capacityFactors) |
protected Address |
DefaultConsistentHashFactory.findNewBackupOwner(DefaultConsistentHashFactory.Builder builder,
Collection<Address> excludes,
Address owner) |
protected Address |
DefaultConsistentHashFactory.findNewPrimaryOwner(DefaultConsistentHashFactory.Builder builder,
Collection<Address> candidates,
Address primaryOwner) |
protected List<Address> |
SyncConsistentHashFactory.Builder.sort(List<Address> members,
Map<Address,Float> capacityFactors) |
protected List<Address> |
SyncConsistentHashFactory.Builder.sort(List<Address> members,
Map<Address,Float> capacityFactors) |
DefaultConsistentHash |
DefaultConsistentHashFactory.updateMembers(DefaultConsistentHash baseCH,
List<Address> actualMembers,
Map<Address,Float> actualCapacityFactors)
Leavers are removed and segments without owners are assigned new owners.
|
DefaultConsistentHash |
DefaultConsistentHashFactory.updateMembers(DefaultConsistentHash baseCH,
List<Address> actualMembers,
Map<Address,Float> actualCapacityFactors)
Leavers are removed and segments without owners are assigned new owners.
|
DefaultConsistentHash |
SyncConsistentHashFactory.updateMembers(DefaultConsistentHash baseCH,
List<Address> newMembers,
Map<Address,Float> actualCapacityFactors) |
DefaultConsistentHash |
SyncConsistentHashFactory.updateMembers(DefaultConsistentHash baseCH,
List<Address> newMembers,
Map<Address,Float> actualCapacityFactors) |
ReplicatedConsistentHash |
ReplicatedConsistentHashFactory.updateMembers(ReplicatedConsistentHash baseCH,
List<Address> newMembers,
Map<Address,Float> actualCapacityFactors) |
ReplicatedConsistentHash |
ReplicatedConsistentHashFactory.updateMembers(ReplicatedConsistentHash baseCH,
List<Address> newMembers,
Map<Address,Float> actualCapacityFactors) |
ReplicatedConsistentHash |
SyncReplicatedConsistentHashFactory.updateMembers(ReplicatedConsistentHash baseCH,
List<Address> newMembers,
Map<Address,Float> actualCapacityFactors) |
ReplicatedConsistentHash |
SyncReplicatedConsistentHashFactory.updateMembers(ReplicatedConsistentHash baseCH,
List<Address> newMembers,
Map<Address,Float> actualCapacityFactors) |
Constructor and Description |
---|
Builder(DefaultConsistentHash baseCH,
List<Address> actualMembers,
Map<Address,Float> actualCapacityFactors) |
Builder(DefaultConsistentHash baseCH,
List<Address> actualMembers,
Map<Address,Float> actualCapacityFactors) |
Builder(Hash hashFunction,
int numOwners,
int numSegments,
List<Address> members,
Map<Address,Float> capacityFactors) |
Builder(Hash hashFunction,
int numOwners,
int numSegments,
List<Address> members,
Map<Address,Float> capacityFactors) |
Builder(Hash hashFunction,
int numOwners,
int numSegments,
List<Address> members,
Map<Address,Float> capacityFactors) |
Builder(Hash hashFunction,
int numOwners,
int numSegments,
List<Address> members,
Map<Address,Float> capacityFactors) |
Builder(Hash hashFunction,
int numOwners,
int numSegments,
List<Address> members,
Map<Address,Float> capacityFactors) |
Builder(Hash hashFunction,
int numOwners,
int numSegments,
List<Address> members,
Map<Address,Float> capacityFactors) |
DefaultConsistentHash(Hash hashFunction,
int numOwners,
int numSegments,
List<Address> members,
Map<Address,Float> capacityFactors,
List<Address>[] segmentOwners) |
DefaultConsistentHash(Hash hashFunction,
int numOwners,
int numSegments,
List<Address> members,
Map<Address,Float> capacityFactors,
List<Address>[] segmentOwners) |
OwnershipStatistics(ConsistentHash ch,
List<Address> activeNodes) |
OwnershipStatistics(List<Address> nodes) |
ReplicatedConsistentHash(Hash hashFunction,
List<Address> members,
int[] primaryOwners) |
Modifier and Type | Method and Description |
---|---|
Address |
GroupManager.getPrimaryOwner(String group)
It returns the primary owner of the group.
|
Address |
GroupManagerImpl.getPrimaryOwner(String group) |
Address |
PartitionerConsistentHash.locatePrimaryOwnerForSegment(int segmentId) |
Modifier and Type | Method and Description |
---|---|
List<Address> |
PartitionerConsistentHash.getMembers() |
List<Address> |
PartitionerConsistentHash.locateOwnersForSegment(int segmentId) |
Modifier and Type | Method and Description |
---|---|
Set<Integer> |
PartitionerConsistentHash.getPrimarySegmentsForOwner(Address owner) |
Set<Integer> |
PartitionerConsistentHash.getSegmentsForOwner(Address owner) |
boolean |
PartitionerConsistentHash.isKeyLocalToNode(Address nodeAddress,
Object key) |
boolean |
PartitionerConsistentHash.isSegmentLocalToNode(Address nodeAddress,
int segmentId) |
Modifier and Type | Method and Description |
---|---|
Address |
DistributionManagerImpl.getPrimaryLocation(Object key) |
Modifier and Type | Method and Description |
---|---|
List<Address> |
DistributionManagerImpl.locate(Object key) |
Set<Address> |
DistributionManagerImpl.locateAll(Collection<Object> keys) |
Modifier and Type | Method and Description |
---|---|
void |
L1ManagerImpl.addRequestor(Object key,
Address origin) |
Future<?> |
L1ManagerImpl.flushCache(Collection<Object> keys,
Address origin,
boolean assumeOriginKeptEntryInL1) |
Modifier and Type | Method and Description |
---|---|
Collection<Address> |
TopologyInfo.getMachineNodes(String site,
String rack,
String machine) |
Collection<Address> |
TopologyInfo.getRackNodes(String site,
String rack) |
Collection<Address> |
TopologyInfo.getSiteNodes(String site) |
Modifier and Type | Method and Description |
---|---|
int |
TopologyInfo.computeExpectedSegments(int numSegments,
int numOwners,
Address node) |
Modifier and Type | Method and Description |
---|---|
float |
TopologyInfo.computeTotalCapacity(Collection<Address> nodes,
Map<Address,Float> capacityFactors) |
float |
TopologyInfo.computeTotalCapacity(Collection<Address> nodes,
Map<Address,Float> capacityFactors) |
Constructor and Description |
---|
TopologyInfo(Collection<Address> members,
Map<Address,Float> capacityFactors) |
TopologyInfo(Collection<Address> members,
Map<Address,Float> capacityFactors) |
Modifier and Type | Method and Description |
---|---|
protected Map<Address,Response> |
BaseRpcInterceptor.totalOrderPrepare(Collection<Address> recipients,
PrepareCommand prepareCommand,
TimeoutValidationResponseFilter responseFilter)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected Map<Address,Response> |
BaseRpcInterceptor.totalOrderPrepare(Collection<Address> recipients,
PrepareCommand prepareCommand,
TimeoutValidationResponseFilter responseFilter)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected void |
TxDistributionInterceptor.checkTxCommandResponses(Map<Address,Response> responseMap,
TransactionBoundaryCommand command,
LocalTxInvocationContext context,
Collection<Address> recipients)
Deprecated.
|
protected void |
TxDistributionInterceptor.checkTxCommandResponses(Map<Address,Response> responseMap,
TransactionBoundaryCommand command,
LocalTxInvocationContext context,
Collection<Address> recipients)
Deprecated.
|
protected void |
VersionedDistributionInterceptor.prepareOnAffectedNodes(TxInvocationContext<?> ctx,
PrepareCommand command,
Collection<Address> recipients)
Deprecated.
|
protected void |
TxDistributionInterceptor.prepareOnAffectedNodes(TxInvocationContext<?> ctx,
PrepareCommand command,
Collection<Address> recipients)
Deprecated.
|
Modifier and Type | Field and Description |
---|---|
static Address |
ClusteringDependentLogic.LOCAL_MODE_ADDRESS |
Modifier and Type | Method and Description |
---|---|
Address |
ClusteringDependentLogic.getAddress() |
Address |
ClusteringDependentLogic.LocalLogic.getAddress() |
Address |
ClusteringDependentLogic.InvalidationLogic.getAddress() |
Address |
ClusteringDependentLogic.DistributionLogic.getAddress() |
Address |
ClusteringDependentLogic.getPrimaryOwner(Object key) |
Address |
ClusteringDependentLogic.LocalLogic.getPrimaryOwner(Object key) |
Address |
ClusteringDependentLogic.InvalidationLogic.getPrimaryOwner(Object key) |
Address |
ClusteringDependentLogic.DistributionLogic.getPrimaryOwner(Object key) |
Modifier and Type | Method and Description |
---|---|
List<Address> |
ClusteringDependentLogic.getOwners(Collection<Object> keys) |
List<Address> |
ClusteringDependentLogic.LocalLogic.getOwners(Collection<Object> keys) |
List<Address> |
ClusteringDependentLogic.InvalidationLogic.getOwners(Collection<Object> keys) |
List<Address> |
ClusteringDependentLogic.DistributionLogic.getOwners(Collection<Object> affectedKeys) |
List<Address> |
ClusteringDependentLogic.getOwners(Object key) |
List<Address> |
ClusteringDependentLogic.LocalLogic.getOwners(Object key) |
List<Address> |
ClusteringDependentLogic.InvalidationLogic.getOwners(Object key) |
List<Address> |
ClusteringDependentLogic.DistributionLogic.getOwners(Object key) |
Modifier and Type | Method and Description |
---|---|
protected void |
TotalOrderDistributionInterceptor.prepareOnAffectedNodes(TxInvocationContext<?> ctx,
PrepareCommand command,
Collection<Address> recipients)
Deprecated.
|
protected void |
TotalOrderVersionedDistributionInterceptor.prepareOnAffectedNodes(TxInvocationContext<?> ctx,
PrepareCommand command,
Collection<Address> recipients)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
<C> void |
LocalEntryRetriever.receiveResponse(UUID identifier,
Address origin,
Set<Integer> completedSegments,
Set<Integer> inDoubtSegments,
Collection<CacheEntry<K,C>> entries,
CacheException e) |
<C> void |
EntryRetriever.receiveResponse(UUID identifier,
Address origin,
Set<Integer> completedSegments,
Set<Integer> inDoubtSegments,
Collection<CacheEntry<K,C>> entries,
CacheException e)
Deprecated.
This method is invoked on the local node who started the iteration process for each batch of values.
|
<C> void |
DistributedEntryRetriever.receiveResponse(UUID identifier,
Address origin,
Set<Integer> completedSegments,
Set<Integer> inDoubtSegments,
Collection<CacheEntry<K,C>> entries,
CacheException e) |
<C> void |
LocalEntryRetriever.startRetrievingValues(UUID identifier,
Address origin,
Set<Integer> segments,
Set<K> keysToFilter,
KeyValueFilter<? super K,? super V> filter,
Converter<? super K,? super V,C> converter,
Set<Flag> flags) |
<C> void |
EntryRetriever.startRetrievingValues(UUID identifier,
Address origin,
Set<Integer> segments,
Set<K> keysToFilter,
KeyValueFilter<? super K,? super V> filter,
Converter<? super K,? super V,C> converter,
Set<Flag> flagss)
Deprecated.
This method is intended to be ran remotely on a node who has segments that the values have been requested.
|
<C> void |
DistributedEntryRetriever.startRetrievingValues(UUID identifier,
Address origin,
Set<Integer> segments,
Set<K> keysToFilter,
KeyValueFilter<? super K,? super V> filter,
Converter<? super K,? super V,C> converter,
Set<Flag> flags) |
Constructor and Description |
---|
EntryRequestCommand(String cacheName,
UUID identifier,
Address origin,
Set<Integer> segments,
Set<K> keysToFilter,
KeyValueFilter<? super K,? super V> filter,
Converter<? super K,? super V,C> converter,
Set<Flag> flags) |
EntryResponseCommand(Address origin,
String cacheName,
UUID identifier,
Set<Integer> completedSegments,
Set<Integer> inDoubtSegments,
Collection<CacheEntry<K,C>> values,
CacheException e) |
Modifier and Type | Method and Description |
---|---|
Address |
DefaultCacheManager.getAddress() |
Address |
EmbeddedCacheManager.getAddress() |
Address |
DefaultCacheManager.getCoordinator() |
Address |
EmbeddedCacheManager.getCoordinator() |
Modifier and Type | Method and Description |
---|---|
List<Address> |
DefaultCacheManager.getMembers() |
List<Address> |
EmbeddedCacheManager.getMembers() |
Modifier and Type | Method and Description |
---|---|
ClusterExecutor |
ClusterExecutor.filterTargets(Collection<Address> addresses)
Allows for filtering of address nodes by only allowing addresses in this collection from being contacted.
|
ClusterExecutor |
ClusterExecutor.filterTargets(Predicate<? super Address> predicate)
Allows for filtering of address nodes dynamically per invocation.
|
<V> CompletableFuture<Void> |
ClusterExecutor.submitConsumer(Function<? super EmbeddedCacheManager,? extends V> callable,
TriConsumer<? super Address,? super V,? super Throwable> triConsumer)
Submits the given command to the desired nodes and allows for handling of results as they return.
|
<V> CompletableFuture<Void> |
ClusterExecutor.submitConsumer(SerializableFunction<? super EmbeddedCacheManager,? extends V> callable,
TriConsumer<? super Address,? super V,? super Throwable> triConsumer)
The same as
ClusterExecutor.submitConsumer(Function, TriConsumer) , except the Callable must also implement
Serializable. |
Modifier and Type | Method and Description |
---|---|
Address |
AbstractDelegatingEmbeddedCacheManager.getAddress() |
Address |
AbstractDelegatingEmbeddedCacheManager.getCoordinator() |
Modifier and Type | Method and Description |
---|---|
List<Address> |
AbstractDelegatingEmbeddedCacheManager.getMembers() |
Modifier and Type | Method and Description |
---|---|
ClusterExecutor |
ClusterExecutorImpl.filterTargets(Collection<Address> addresses) |
ClusterExecutor |
ClusterExecutorImpl.filterTargets(Predicate<? super Address> predicate) |
<V> CompletableFuture<Void> |
ClusterExecutorImpl.submitConsumer(Function<? super EmbeddedCacheManager,? extends V> function,
TriConsumer<? super Address,? super V,? super Throwable> triConsumer) |
<V> CompletableFuture<Void> |
ClusterExecutorImpl.submitConsumer(SerializableFunction<? super EmbeddedCacheManager,? extends V> function,
TriConsumer<? super Address,? super V,? super Throwable> triConsumer) |
Constructor and Description |
---|
ClusterExecutorImpl(Predicate<? super Address> predicate,
EmbeddedCacheManager manager,
JGroupsTransport transport,
long time,
TimeUnit unit,
Executor localExecutor) |
Modifier and Type | Method and Description |
---|---|
Address |
RemoteClusterListener.getOwnerAddress() |
Modifier and Type | Method and Description |
---|---|
void |
ClusterEventManager.addEvents(Address target,
UUID identifier,
Collection<ClusterEvent<K,V>> events,
boolean sync)
Adds additional cluster events that need to be sent remotely for an event originating locally.
|
Constructor and Description |
---|
ClusterListenerReplicateCallable(UUID identifier,
Address origin,
CacheEventFilter<K,V> filter,
CacheEventConverter<K,V,?> converter,
boolean sync) |
RemoteClusterListener(UUID id,
Address origin,
DistributedExecutorService distExecService,
CacheNotifier cacheNotifier,
CacheManagerNotifier cacheManagerNotifier,
ClusterEventManager eventManager,
boolean sync) |
Modifier and Type | Field and Description |
---|---|
protected Map<Address,org.infinispan.notifications.cachelistener.cluster.impl.BatchingClusterEventManagerImpl.TargetEvents<K,V>> |
BatchingClusterEventManagerImpl.UnicastEventContext.targets |
Modifier and Type | Method and Description |
---|---|
void |
ClusterEventManagerStub.addEvents(Address target,
UUID identifier,
Collection<ClusterEvent<K,V>> clusterEvents,
boolean sync) |
void |
BatchingClusterEventManagerImpl.addEvents(Address target,
UUID identifier,
Collection<ClusterEvent<K,V>> events,
boolean sync) |
void |
BatchingClusterEventManagerImpl.UnicastEventContext.addTargets(Address address,
UUID identifier,
Collection<ClusterEvent<K,V>> events,
boolean sync) |
Modifier and Type | Method and Description |
---|---|
Collection<Address> |
DataRehashedEvent.getMembersAtEnd() |
Collection<Address> |
DataRehashedEvent.getMembersAtStart() |
Modifier and Type | Method and Description |
---|---|
Collection<Address> |
EventImpl.getMembersAtEnd() |
Collection<Address> |
EventImpl.getMembersAtStart() |
Modifier and Type | Method and Description |
---|---|
void |
CacheManagerNotifierImpl.notifyMerge(List<Address> members,
List<Address> oldMembers,
Address myAddress,
int viewId,
List<List<Address>> subgroupsMerged) |
void |
CacheManagerNotifier.notifyMerge(List<Address> members,
List<Address> oldMembers,
Address myAddress,
int viewId,
List<List<Address>> subgroupsMerged) |
void |
CacheManagerNotifierImpl.notifyViewChange(List<Address> members,
List<Address> oldMembers,
Address myAddress,
int viewId) |
void |
CacheManagerNotifier.notifyViewChange(List<Address> members,
List<Address> oldMembers,
Address myAddress,
int viewId)
Notifies all registered listeners of a viewChange event.
|
Modifier and Type | Method and Description |
---|---|
void |
CacheManagerNotifierImpl.notifyMerge(List<Address> members,
List<Address> oldMembers,
Address myAddress,
int viewId,
List<List<Address>> subgroupsMerged) |
void |
CacheManagerNotifierImpl.notifyMerge(List<Address> members,
List<Address> oldMembers,
Address myAddress,
int viewId,
List<List<Address>> subgroupsMerged) |
void |
CacheManagerNotifierImpl.notifyMerge(List<Address> members,
List<Address> oldMembers,
Address myAddress,
int viewId,
List<List<Address>> subgroupsMerged) |
void |
CacheManagerNotifier.notifyMerge(List<Address> members,
List<Address> oldMembers,
Address myAddress,
int viewId,
List<List<Address>> subgroupsMerged) |
void |
CacheManagerNotifier.notifyMerge(List<Address> members,
List<Address> oldMembers,
Address myAddress,
int viewId,
List<List<Address>> subgroupsMerged) |
void |
CacheManagerNotifier.notifyMerge(List<Address> members,
List<Address> oldMembers,
Address myAddress,
int viewId,
List<List<Address>> subgroupsMerged) |
void |
CacheManagerNotifierImpl.notifyViewChange(List<Address> members,
List<Address> oldMembers,
Address myAddress,
int viewId) |
void |
CacheManagerNotifierImpl.notifyViewChange(List<Address> members,
List<Address> oldMembers,
Address myAddress,
int viewId) |
void |
CacheManagerNotifier.notifyViewChange(List<Address> members,
List<Address> oldMembers,
Address myAddress,
int viewId)
Notifies all registered listeners of a viewChange event.
|
void |
CacheManagerNotifier.notifyViewChange(List<Address> members,
List<Address> oldMembers,
Address myAddress,
int viewId)
Notifies all registered listeners of a viewChange event.
|
Modifier and Type | Method and Description |
---|---|
Address |
ViewChangedEvent.getLocalAddress() |
Modifier and Type | Method and Description |
---|---|
List<Address> |
ViewChangedEvent.getNewMembers()
Gets the current list of members.
|
List<Address> |
ViewChangedEvent.getOldMembers()
Gets the previous list of members.
|
List<List<Address>> |
MergeEvent.getSubgroupsMerged() |
Modifier and Type | Method and Description |
---|---|
Address |
EventImpl.getLocalAddress() |
Modifier and Type | Method and Description |
---|---|
List<Address> |
EventImpl.getNewMembers() |
List<Address> |
EventImpl.getOldMembers() |
List<List<Address>> |
EventImpl.getSubgroupsMerged() |
Modifier and Type | Method and Description |
---|---|
void |
EventImpl.setLocalAddress(Address localAddress) |
Modifier and Type | Method and Description |
---|---|
void |
EventImpl.setNewMembers(List<Address> newMembers) |
void |
EventImpl.setOldMembers(List<Address> oldMembers) |
void |
EventImpl.setSubgroupsMerged(List<List<Address>> subgroupsMerged) |
Constructor and Description |
---|
EventImpl(String cacheName,
EmbeddedCacheManager cacheManager,
Event.Type type,
List<Address> newMemberList,
List<Address> oldMemberList,
Address localAddress,
int viewId) |
Constructor and Description |
---|
EventImpl(String cacheName,
EmbeddedCacheManager cacheManager,
Event.Type type,
List<Address> newMemberList,
List<Address> oldMemberList,
Address localAddress,
int viewId) |
EventImpl(String cacheName,
EmbeddedCacheManager cacheManager,
Event.Type type,
List<Address> newMemberList,
List<Address> oldMemberList,
Address localAddress,
int viewId) |
Modifier and Type | Method and Description |
---|---|
List<Address> |
AvailabilityStrategyContext.getExpectedMembers()
The members of the cache.
|
Modifier and Type | Method and Description |
---|---|
void |
AvailabilityStrategy.onGracefulLeave(AvailabilityStrategyContext context,
Address leaver)
Called when a node leaves gracefully.
|
void |
PreferAvailabilityStrategy.onGracefulLeave(AvailabilityStrategyContext context,
Address leaver) |
void |
PreferConsistencyStrategy.onGracefulLeave(AvailabilityStrategyContext context,
Address leaver) |
void |
AvailabilityStrategy.onJoin(AvailabilityStrategyContext context,
Address joiner)
Called when a node joins.
|
void |
PreferAvailabilityStrategy.onJoin(AvailabilityStrategyContext context,
Address joiner) |
void |
PreferConsistencyStrategy.onJoin(AvailabilityStrategyContext context,
Address joiner) |
Modifier and Type | Method and Description |
---|---|
boolean |
PartitionHandlingManager.addPartialCommit1PCTransaction(GlobalTransaction globalTransaction,
Collection<Address> affectedNodes,
Collection<Object> lockedKeys,
List<WriteCommand> modifications)
Adds a partially committed transaction.
|
boolean |
AvailablePartitionHandlingManager.addPartialCommit1PCTransaction(GlobalTransaction globalTransaction,
Collection<Address> affectedNodes,
Collection<Object> lockedKeys,
List<WriteCommand> modifications) |
boolean |
PartitionHandlingManagerImpl.addPartialCommit1PCTransaction(GlobalTransaction globalTransaction,
Collection<Address> affectedNodes,
Collection<Object> lockedKeys,
List<WriteCommand> modifications) |
boolean |
PartitionHandlingManager.addPartialCommit2PCTransaction(GlobalTransaction globalTransaction,
Collection<Address> affectedNodes,
Collection<Object> lockedKeys,
EntryVersionsMap newVersions)
Adds a partially committed transaction.
|
boolean |
AvailablePartitionHandlingManager.addPartialCommit2PCTransaction(GlobalTransaction globalTransaction,
Collection<Address> affectedNodes,
Collection<Object> lockedKeys,
EntryVersionsMap newVersions) |
boolean |
PartitionHandlingManagerImpl.addPartialCommit2PCTransaction(GlobalTransaction globalTransaction,
Collection<Address> affectedNodes,
Collection<Object> lockedKeys,
EntryVersionsMap newVersions) |
boolean |
PartitionHandlingManager.addPartialRollbackTransaction(GlobalTransaction globalTransaction,
Collection<Address> affectedNodes,
Collection<Object> lockedKeys)
Adds a partially aborted transaction.
|
boolean |
AvailablePartitionHandlingManager.addPartialRollbackTransaction(GlobalTransaction globalTransaction,
Collection<Address> affectedNodes,
Collection<Object> lockedKeys) |
boolean |
PartitionHandlingManagerImpl.addPartialRollbackTransaction(GlobalTransaction globalTransaction,
Collection<Address> affectedNodes,
Collection<Object> lockedKeys) |
protected void |
PreferAvailabilityStrategy.checkForLostData(AvailabilityStrategyContext context,
List<Address> newMembers) |
protected AvailabilityMode |
PreferConsistencyStrategy.computeAvailabilityAfterMerge(AvailabilityStrategyContext context,
CacheTopology maxStableTopology,
List<Address> newMembers,
AvailabilityMode initialMode) |
protected boolean |
PreferConsistencyStrategy.isMinorityPartition(List<Address> stableMembers,
List<Address> lostMembers) |
protected boolean |
PreferConsistencyStrategy.isMinorityPartition(List<Address> stableMembers,
List<Address> lostMembers) |
void |
AvailabilityStrategy.onClusterViewChange(AvailabilityStrategyContext context,
List<Address> clusterMembers)
Called when the cluster view changed (e.g.
|
void |
PreferAvailabilityStrategy.onClusterViewChange(AvailabilityStrategyContext context,
List<Address> clusterMembers) |
void |
PreferConsistencyStrategy.onClusterViewChange(AvailabilityStrategyContext context,
List<Address> clusterMembers) |
void |
AvailabilityStrategyContext.queueRebalance(List<Address> newMembers)
Queue (or start) a rebalance.
|
void |
AvailabilityStrategyContext.updateAvailabilityMode(List<Address> actualMembers,
AvailabilityMode mode,
boolean cancelRebalance)
Enter a new availability mode.
|
void |
AvailabilityStrategyContext.updateCurrentTopology(List<Address> newMembers)
Use the configured
ConsistentHashFactory to create a new CH
with the given members , but do not start a rebalance. |
Modifier and Type | Method and Description |
---|---|
static LocalInvocation |
LocalInvocation.newInstance(ResponseGenerator responseGenerator,
CacheRpcCommand command,
CommandsFactory commandsFactory,
Address self) |
Modifier and Type | Method and Description |
---|---|
void |
GlobalInboundInvocationHandler.handleFromCluster(Address origin,
ReplicableCommand command,
Reply reply,
DeliverOrder order) |
void |
InboundInvocationHandler.handleFromCluster(Address origin,
ReplicableCommand command,
Reply reply,
DeliverOrder order)
Handles the
ReplicableCommand from other node belonging to local site. |
Modifier and Type | Method and Description |
---|---|
boolean |
ClusteredGetResponseValidityFilter.isAcceptable(Response response,
Address address) |
boolean |
KeysValidateFilter.isAcceptable(Response response,
Address sender) |
boolean |
SelfDeliverFilter.isAcceptable(Response response,
Address sender) |
boolean |
IgnoreExtraResponsesValidityFilter.isAcceptable(Response response,
Address address) |
Constructor and Description |
---|
ClusteredGetResponseValidityFilter(Collection<Address> targets,
Address self) |
IgnoreExtraResponsesValidityFilter(Collection<Address> targets,
Address self,
boolean removeSelf) |
KeysValidateFilter(Address localAddress,
Set<Object> keysAwaitingValidation) |
SelfDeliverFilter(Address localAddress) |
Constructor and Description |
---|
ClusteredGetResponseValidityFilter(Collection<Address> targets,
Address self) |
IgnoreExtraResponsesValidityFilter(Collection<Address> targets,
Address self,
boolean removeSelf) |
Modifier and Type | Method and Description |
---|---|
Address |
RpcManagerImpl.getAddress() |
Address |
RpcManager.getAddress()
Returns the address associated with this RpcManager or null if not part of the cluster.
|
Modifier and Type | Method and Description |
---|---|
List<Address> |
RpcManagerImpl.getMembers() |
List<Address> |
RpcManager.getMembers()
Returns members of a cluster scoped to the cache owning this RpcManager.
|
Map<Address,Response> |
RpcManagerImpl.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpc,
RpcOptions options) |
Map<Address,Response> |
RpcManager.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpc,
RpcOptions options)
Invokes an RPC call on other caches in the cluster.
|
Map<Address,Response> |
RpcManagerImpl.invokeRemotely(Map<Address,ReplicableCommand> rpcs,
RpcOptions options) |
Map<Address,Response> |
RpcManager.invokeRemotely(Map<Address,ReplicableCommand> rpcs,
RpcOptions options) |
CompletableFuture<Map<Address,Response>> |
RpcManagerImpl.invokeRemotelyAsync(Collection<Address> recipients,
ReplicableCommand rpc,
RpcOptions options) |
CompletableFuture<Map<Address,Response>> |
RpcManager.invokeRemotelyAsync(Collection<Address> recipients,
ReplicableCommand rpc,
RpcOptions options)
Invokes a command on remote nodes.
|
Modifier and Type | Method and Description |
---|---|
boolean |
ResponseFilter.isAcceptable(Response response,
Address sender)
Determines whether a response from a given sender should be added to the response list of the request
|
Modifier and Type | Interface and Description |
---|---|
interface |
TopologyAwareAddress
Wraps a TopologyUUID JGroups address
|
Modifier and Type | Method and Description |
---|---|
Address |
AbstractDelegatingTransport.getAddress() |
Address |
Transport.getAddress()
Retrieves the current cache instance's network address
|
Address |
AbstractDelegatingTransport.getCoordinator() |
Address |
Transport.getCoordinator() |
Modifier and Type | Method and Description |
---|---|
protected Map<Address,Response> |
AbstractDelegatingTransport.afterInvokeRemotely(ReplicableCommand command,
Map<Address,Response> responseMap)
method invoked after a successful remote invocation.
|
List<Address> |
AbstractDelegatingTransport.getMembers() |
List<Address> |
Transport.getMembers()
Returns a list of members in the current cluster view.
|
List<Address> |
AbstractDelegatingTransport.getPhysicalAddresses() |
List<Address> |
Transport.getPhysicalAddresses()
Retrieves the current cache instance's physical network addresses.
|
Map<Address,Response> |
AbstractDelegatingTransport.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
ResponseFilter responseFilter,
DeliverOrder deliverOrder,
boolean anycast) |
Map<Address,Response> |
Transport.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
ResponseFilter responseFilter,
DeliverOrder deliverOrder,
boolean anycast)
Invokes an RPC call on other caches in the cluster.
|
Map<Address,Response> |
AbstractDelegatingTransport.invokeRemotely(Map<Address,ReplicableCommand> rpcCommands,
ResponseMode mode,
long timeout,
boolean usePriorityQueue,
ResponseFilter responseFilter,
boolean totalOrder,
boolean anycast) |
Map<Address,Response> |
Transport.invokeRemotely(Map<Address,ReplicableCommand> rpcCommands,
ResponseMode mode,
long timeout,
boolean usePriorityQueue,
ResponseFilter responseFilter,
boolean totalOrder,
boolean anycast)
Deprecated.
|
Map<Address,Response> |
AbstractDelegatingTransport.invokeRemotely(Map<Address,ReplicableCommand> rpcCommands,
ResponseMode mode,
long timeout,
ResponseFilter responseFilter,
DeliverOrder deliverOrder,
boolean anycast) |
Map<Address,Response> |
Transport.invokeRemotely(Map<Address,ReplicableCommand> rpcCommands,
ResponseMode mode,
long timeout,
ResponseFilter responseFilter,
DeliverOrder deliverOrder,
boolean anycast) |
CompletableFuture<Map<Address,Response>> |
AbstractDelegatingTransport.invokeRemotelyAsync(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
ResponseFilter responseFilter,
DeliverOrder deliverOrder,
boolean anycast) |
CompletableFuture<Map<Address,Response>> |
Transport.invokeRemotelyAsync(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
ResponseFilter responseFilter,
DeliverOrder deliverOrder,
boolean anycast) |
Modifier and Type | Method and Description |
---|---|
Response |
AbstractTransport.checkResponse(Object responseObject,
Address sender,
boolean ignoreCacheNotFoundResponse) |
Modifier and Type | Method and Description |
---|---|
protected Map<Address,Response> |
AbstractDelegatingTransport.afterInvokeRemotely(ReplicableCommand command,
Map<Address,Response> responseMap)
method invoked after a successful remote invocation.
|
Map<Address,Response> |
AbstractDelegatingTransport.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
ResponseFilter responseFilter,
DeliverOrder deliverOrder,
boolean anycast) |
Map<Address,Response> |
Transport.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
ResponseFilter responseFilter,
DeliverOrder deliverOrder,
boolean anycast)
Invokes an RPC call on other caches in the cluster.
|
Map<Address,Response> |
AbstractDelegatingTransport.invokeRemotely(Map<Address,ReplicableCommand> rpcCommands,
ResponseMode mode,
long timeout,
boolean usePriorityQueue,
ResponseFilter responseFilter,
boolean totalOrder,
boolean anycast) |
Map<Address,Response> |
Transport.invokeRemotely(Map<Address,ReplicableCommand> rpcCommands,
ResponseMode mode,
long timeout,
boolean usePriorityQueue,
ResponseFilter responseFilter,
boolean totalOrder,
boolean anycast)
Deprecated.
|
Map<Address,Response> |
AbstractDelegatingTransport.invokeRemotely(Map<Address,ReplicableCommand> rpcCommands,
ResponseMode mode,
long timeout,
ResponseFilter responseFilter,
DeliverOrder deliverOrder,
boolean anycast) |
Map<Address,Response> |
Transport.invokeRemotely(Map<Address,ReplicableCommand> rpcCommands,
ResponseMode mode,
long timeout,
ResponseFilter responseFilter,
DeliverOrder deliverOrder,
boolean anycast) |
CompletableFuture<Map<Address,Response>> |
AbstractDelegatingTransport.invokeRemotelyAsync(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
ResponseFilter responseFilter,
DeliverOrder deliverOrder,
boolean anycast) |
CompletableFuture<Map<Address,Response>> |
Transport.invokeRemotelyAsync(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
ResponseFilter responseFilter,
DeliverOrder deliverOrder,
boolean anycast) |
Modifier and Type | Class and Description |
---|---|
class |
JGroupsAddress
An encapsulation of a JGroups Address
|
class |
JGroupsTopologyAwareAddress
An encapsulation of a JGroups Address
|
Modifier and Type | Field and Description |
---|---|
protected Address |
JGroupsTransport.address |
protected Address |
JGroupsTransport.coordinator |
protected Address |
JGroupsTransport.physicalAddress |
Modifier and Type | Field and Description |
---|---|
protected List<Address> |
JGroupsTransport.members |
Modifier and Type | Method and Description |
---|---|
static Address |
JGroupsAddressCache.fromJGroupsAddress(Object address) |
static Address |
JGroupsAddressCache.fromPersistentUUID(PersistentUUID uuid) |
Address |
JGroupsTransport.getAddress() |
Address |
JGroupsTransport.getCoordinator() |
Address |
SuspectException.getSuspect() |
Modifier and Type | Method and Description |
---|---|
List<Address> |
JGroupsTransport.getMembers() |
List<Address> |
JGroupsTransport.getPhysicalAddresses() |
Map<Address,Response> |
JGroupsTransport.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
ResponseFilter responseFilter,
DeliverOrder deliverOrder,
boolean anycast) |
Map<Address,Response> |
JGroupsTransport.invokeRemotely(Map<Address,ReplicableCommand> rpcCommands,
ResponseMode mode,
long timeout,
boolean usePriorityQueue,
ResponseFilter responseFilter,
boolean totalOrder,
boolean anycast) |
Map<Address,Response> |
JGroupsTransport.invokeRemotely(Map<Address,ReplicableCommand> rpcCommands,
ResponseMode mode,
long timeout,
ResponseFilter responseFilter,
DeliverOrder deliverOrder,
boolean anycast) |
CompletableFuture<Map<Address,Response>> |
JGroupsTransport.invokeRemotelyAsync(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
ResponseFilter responseFilter,
DeliverOrder deliverOrder,
boolean anycast) |
Modifier and Type | Method and Description |
---|---|
protected Response |
JGroupsTransport.checkRsp(org.jgroups.util.Rsp<Response> rsp,
Address sender,
boolean ignoreTimeout,
boolean ignoreLeavers) |
int |
JGroupsAddress.compareTo(Address o) |
protected static org.jgroups.Address |
JGroupsTransport.toJGroupsAddress(Address a) |
Modifier and Type | Method and Description |
---|---|
Map<Address,Response> |
JGroupsTransport.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
ResponseFilter responseFilter,
DeliverOrder deliverOrder,
boolean anycast) |
Map<Address,Response> |
JGroupsTransport.invokeRemotely(Map<Address,ReplicableCommand> rpcCommands,
ResponseMode mode,
long timeout,
boolean usePriorityQueue,
ResponseFilter responseFilter,
boolean totalOrder,
boolean anycast) |
Map<Address,Response> |
JGroupsTransport.invokeRemotely(Map<Address,ReplicableCommand> rpcCommands,
ResponseMode mode,
long timeout,
ResponseFilter responseFilter,
DeliverOrder deliverOrder,
boolean anycast) |
CompletableFuture<Map<Address,Response>> |
JGroupsTransport.invokeRemotelyAsync(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
ResponseFilter responseFilter,
DeliverOrder deliverOrder,
boolean anycast) |
Constructor and Description |
---|
SuspectException(String msg,
Address suspect) |
SuspectException(String msg,
Address suspect,
Throwable cause) |
Modifier and Type | Method and Description |
---|---|
Address |
GetCacheManagerAddress.run() |
Address |
GetCacheManagerCoordinatorAddress.run() |
Modifier and Type | Method and Description |
---|---|
Address |
OutboundTransferTask.getDestination() |
Address |
InboundTransferTask.getSource() |
Modifier and Type | Method and Description |
---|---|
Map<Address,Response> |
StateTransferManagerImpl.forwardCommandIfNeeded(TopologyAffectedCommand command,
Set<Object> affectedKeys,
Address origin) |
Map<Address,Response> |
StateTransferManager.forwardCommandIfNeeded(TopologyAffectedCommand command,
Set<Object> affectedKeys,
Address origin)
If there is an state transfer happening at the moment, this method forwards the supplied
command to the nodes that are new owners of the data, in order to assure consistency.
|
Modifier and Type | Method and Description |
---|---|
void |
StateConsumer.applyState(Address sender,
int topologyId,
Collection<StateChunk> stateChunks) |
void |
StateConsumerImpl.applyState(Address sender,
int topologyId,
Collection<StateChunk> stateChunks) |
void |
StateProvider.cancelOutboundTransfer(Address destination,
int topologyId,
Set<Integer> segments)
Cancel sending of cache entries that belong to the given set of segments.
|
void |
StateProviderImpl.cancelOutboundTransfer(Address destination,
int topologyId,
Set<Integer> segments) |
Map<Address,Response> |
StateTransferManagerImpl.forwardCommandIfNeeded(TopologyAffectedCommand command,
Set<Object> affectedKeys,
Address origin) |
Map<Address,Response> |
StateTransferManager.forwardCommandIfNeeded(TopologyAffectedCommand command,
Set<Object> affectedKeys,
Address origin)
If there is an state transfer happening at the moment, this method forwards the supplied
command to the nodes that are new owners of the data, in order to assure consistency.
|
List<TransactionInfo> |
StateProvider.getTransactionsForSegments(Address destination,
int topologyId,
Set<Integer> segments)
Gets the list of transactions that affect keys from the given segments.
|
List<TransactionInfo> |
StateProviderImpl.getTransactionsForSegments(Address destination,
int requestTopologyId,
Set<Integer> segments) |
void |
StateProvider.startOutboundTransfer(Address destination,
int topologyId,
Set<Integer> segments)
Start to send cache entries that belong to the given set of segments.
|
void |
StateProviderImpl.startOutboundTransfer(Address destination,
int requestTopologyId,
Set<Integer> segments) |
Constructor and Description |
---|
InboundTransferTask(Set<Integer> segments,
Address source,
int topologyId,
StateConsumerImpl stateConsumer,
RpcManager rpcManager,
CommandsFactory commandsFactory,
long timeout,
String cacheName) |
OutboundTransferTask(Address destination,
Set<Integer> segments,
int stateTransferChunkSize,
int topologyId,
ConsistentHash readCh,
StateProviderImpl stateProvider,
DataContainer dataContainer,
PersistenceManager persistenceManager,
RpcManager rpcManager,
CommandsFactory commandsFactory,
InternalEntryFactory ef,
long timeout,
String cacheName) |
StateRequestCommand(String cacheName,
StateRequestCommand.Type type,
Address origin,
int topologyId,
Set<Integer> segments) |
StateResponseCommand(String cacheName,
Address origin,
int topologyId,
Collection<StateChunk> stateChunks) |
Modifier and Type | Method and Description |
---|---|
Address |
ExtendedStatisticRpcManager.getAddress() |
Modifier and Type | Method and Description |
---|---|
List<Address> |
ExtendedStatisticRpcManager.getMembers() |
Map<Address,Response> |
ExtendedStatisticRpcManager.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpc,
RpcOptions options) |
Map<Address,Response> |
ExtendedStatisticRpcManager.invokeRemotely(Map<Address,ReplicableCommand> rpcs,
RpcOptions options) |
CompletableFuture<Map<Address,Response>> |
ExtendedStatisticRpcManager.invokeRemotelyAsync(Collection<Address> recipients,
ReplicableCommand rpc,
RpcOptions options) |
Modifier and Type | Field and Description |
---|---|
protected Address |
AbstractCacheStream.localAddress |
protected Address |
ClusterStreamManagerImpl.localAddress |
Modifier and Type | Method and Description |
---|---|
protected static void |
ClusterStreamManagerImpl.markTrackerWithException(org.infinispan.stream.impl.ClusterStreamManagerImpl.RequestTracker<?> tracker,
Address dest,
Throwable e,
Object uuid) |
void |
ClusterStreamManager.ResultsCallback.onCompletion(Address address,
Set<Integer> completedSegments,
R results)
Essentially the same as
ClusterStreamManager.ResultsCallback.onIntermediateResult(Address address, Object)
except that this is the last time this callback will be invoked and it tells which segments were completed |
Set<Integer> |
ClusterStreamManager.ResultsCallback.onIntermediateResult(Address address,
R results)
Called back for intermediate data returned from an operation.
|
<R1> boolean |
ClusterStreamManager.receiveResponse(Object id,
Address origin,
boolean complete,
Set<Integer> segments,
R1 response)
Receives a response for a given request
|
<R1> boolean |
ClusterStreamManagerImpl.receiveResponse(Object id,
Address origin,
boolean complete,
Set<Integer> missingSegments,
R1 response) |
<R> void |
LocalStreamManagerImpl.streamOperation(Object requestId,
Address origin,
boolean parallelStream,
Set<Integer> segments,
Set<K> keysToInclude,
Set<K> keysToExclude,
boolean includeLoader,
KeyTrackingTerminalOperation<K,R,?> operation) |
<R> void |
LocalStreamManager.streamOperation(Object requestId,
Address origin,
boolean parallelStream,
Set<Integer> segments,
Set<K> keysToInclude,
Set<K> keysToExclude,
boolean includeLoader,
KeyTrackingTerminalOperation<K,R,?> operation)
Stream operation for a key aware operation without rehash enabled
|
<R> void |
LocalStreamManagerImpl.streamOperation(Object requestId,
Address origin,
boolean parallelStream,
Set<Integer> segments,
Set<K> keysToInclude,
Set<K> keysToExclude,
boolean includeLoader,
TerminalOperation<R> operation) |
<R> void |
LocalStreamManager.streamOperation(Object requestId,
Address origin,
boolean parallelStream,
Set<Integer> segments,
Set<K> keysToInclude,
Set<K> keysToExclude,
boolean includeLoader,
TerminalOperation<R> operation)
Stream operation for a non key aware operation without rehash enabled.
|
<R2> void |
LocalStreamManagerImpl.streamOperationRehashAware(Object requestId,
Address origin,
boolean parallelStream,
Set<Integer> segments,
Set<K> keysToInclude,
Set<K> keysToExclude,
boolean includeLoader,
KeyTrackingTerminalOperation<K,?,R2> operation) |
<R2> void |
LocalStreamManager.streamOperationRehashAware(Object requestId,
Address origin,
boolean parallelStream,
Set<Integer> segments,
Set<K> keysToInclude,
Set<K> keysToExclude,
boolean includeLoader,
KeyTrackingTerminalOperation<K,?,R2> operation)
Stream operation for a key aware operation with rehash enabled
|
<R> void |
LocalStreamManagerImpl.streamOperationRehashAware(Object requestId,
Address origin,
boolean parallelStream,
Set<Integer> segments,
Set<K> keysToInclude,
Set<K> keysToExclude,
boolean includeLoader,
TerminalOperation<R> operation) |
<R> void |
LocalStreamManager.streamOperationRehashAware(Object requestId,
Address origin,
boolean parallelStream,
Set<Integer> segments,
Set<K> keysToInclude,
Set<K> keysToExclude,
boolean includeLoader,
TerminalOperation<R> operation)
Stream operation for a non key aware operation with rehash enabled.
|
Constructor and Description |
---|
AbstractCacheStream(Address localAddress,
boolean parallel,
DistributionManager dm,
Supplier<CacheStream<CacheEntry>> supplier,
ClusterStreamManager<Object> csm,
boolean includeLoader,
int distributedBatchSize,
Executor executor,
ComponentRegistry registry) |
DistributedCacheStream(Address localAddress,
boolean parallel,
DistributionManager dm,
Supplier<CacheStream<CacheEntry<K,V>>> supplier,
ClusterStreamManager csm,
boolean includeLoader,
int distributedBatchSize,
Executor executor,
ComponentRegistry registry)
Standard constructor requiring all pertinent information to properly utilize a distributed cache stream
|
DistributedCacheStream(Address localAddress,
boolean parallel,
DistributionManager dm,
Supplier<CacheStream<CacheEntry<K,V>>> supplier,
ClusterStreamManager csm,
boolean includeLoader,
int distributedBatchSize,
Executor executor,
ComponentRegistry registry,
Function<? super CacheEntry<K,V>,R> function)
Constructor that also allows a simple map method to be inserted first to change to another type.
|
StreamRequestCommand(String cacheName,
Address origin,
Object id,
boolean parallelStream,
StreamRequestCommand.Type type,
Set<Integer> segments,
Set<K> keys,
Set<K> excludedKeys,
boolean includeLoader,
Object terminalOperation) |
StreamResponseCommand(String cacheName,
Address origin,
Object id,
boolean complete,
R response) |
StreamSegmentResponseCommand(String cacheName,
Address origin,
Object id,
boolean complete,
R response,
Set<Integer> missedSegments) |
Modifier and Type | Method and Description |
---|---|
<R1> boolean |
TxClusterStreamManager.receiveResponse(Object id,
Address origin,
boolean complete,
Set<Integer> segments,
R1 response) |
Constructor and Description |
---|
TxDistributedCacheStream(Address localAddress,
boolean parallel,
DistributionManager dm,
Supplier<CacheStream<CacheEntry<K,V>>> supplier,
TxClusterStreamManager<?> csm,
boolean includeLoader,
int distributedBatchSize,
Executor executor,
ComponentRegistry registry,
Function<? super CacheEntry<K,V>,R> function,
LocalTxInvocationContext ctx) |
TxDistributedCacheStream(Address localAddress,
boolean parallel,
DistributionManager dm,
Supplier<CacheStream<CacheEntry<K,V>>> supplier,
TxClusterStreamManager<?> csm,
boolean includeLoader,
int distributedBatchSize,
Executor executor,
ComponentRegistry registry,
LocalTxInvocationContext ctx) |
Modifier and Type | Class and Description |
---|---|
class |
PersistentUUID
PersistentUUID.
|
Modifier and Type | Method and Description |
---|---|
Address |
CacheTopologyControlCommand.getOrigin() |
Modifier and Type | Method and Description |
---|---|
List<Address> |
CacheTopology.getActualMembers() |
Map<Address,Float> |
ClusterCacheStatus.getCapacityFactors() |
List<Address> |
ClusterCacheStatus.getExpectedMembers() |
List<Address> |
CacheTopology.getMembers() |
Modifier and Type | Method and Description |
---|---|
int |
PersistentUUID.compareTo(Address o) |
void |
ClusterCacheStatus.doConfirmRebalance(Address member,
int receivedTopologyId) |
protected void |
LocalTopologyManagerImpl.doHandleRebalance(int viewId,
org.infinispan.topology.LocalCacheStatus cacheStatus,
CacheTopology cacheTopology,
String cacheName,
Address sender) |
protected void |
LocalTopologyManagerImpl.doHandleStableTopologyUpdate(String cacheName,
CacheTopology newStableTopology,
int viewId,
Address sender,
org.infinispan.topology.LocalCacheStatus cacheStatus) |
protected boolean |
LocalTopologyManagerImpl.doHandleTopologyUpdate(String cacheName,
CacheTopology cacheTopology,
AvailabilityMode availabilityMode,
int viewId,
Address sender,
org.infinispan.topology.LocalCacheStatus cacheStatus)
Update the cache topology in the LocalCacheStatus and pass it to the CacheTopologyHandler.
|
CacheStatusResponse |
ClusterCacheStatus.doJoin(Address joiner,
CacheJoinInfo joinInfo) |
void |
ClusterCacheStatus.doLeave(Address leaver) |
CacheStatusResponse |
ClusterTopologyManagerImpl.handleJoin(String cacheName,
Address joiner,
CacheJoinInfo joinInfo,
int joinerViewId) |
CacheStatusResponse |
ClusterTopologyManager.handleJoin(String cacheName,
Address joiner,
CacheJoinInfo joinInfo,
int viewId)
Signals that a new member is joining the cache.
|
void |
ClusterTopologyManagerImpl.handleLeave(String cacheName,
Address leaver,
int viewId) |
void |
ClusterTopologyManager.handleLeave(String cacheName,
Address leaver,
int viewId)
Signals that a member is leaving the cache.
|
void |
LocalTopologyManager.handleRebalance(String cacheName,
CacheTopology cacheTopology,
int viewId,
Address sender)
Performs the state transfer.
|
void |
LocalTopologyManagerImpl.handleRebalance(String cacheName,
CacheTopology cacheTopology,
int viewId,
Address sender) |
void |
ClusterTopologyManagerImpl.handleRebalanceCompleted(String cacheName,
Address node,
int topologyId,
Throwable throwable,
int viewId) |
void |
ClusterTopologyManager.handleRebalanceCompleted(String cacheName,
Address node,
int topologyId,
Throwable throwable,
int viewId)
Marks the rebalance as complete on the sender.
|
void |
LocalTopologyManager.handleStableTopologyUpdate(String cacheName,
CacheTopology cacheTopology,
Address sender,
int viewId)
Update the stable cache topology.
|
void |
LocalTopologyManagerImpl.handleStableTopologyUpdate(String cacheName,
CacheTopology newStableTopology,
Address sender,
int viewId) |
void |
LocalTopologyManager.handleTopologyUpdate(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(String cacheName,
CacheTopology cacheTopology,
AvailabilityMode availabilityMode,
int viewId,
Address sender) |
Modifier and Type | Method and Description |
---|---|
void |
ClusterCacheStatus.doMergePartitions(Map<Address,CacheStatusResponse> statusResponses,
List<Address> clusterMembers,
boolean isMergeView) |
void |
ClusterCacheStatus.doMergePartitions(Map<Address,CacheStatusResponse> statusResponses,
List<Address> clusterMembers,
boolean isMergeView) |
void |
ClusterCacheStatus.queueRebalance(List<Address> newMembers) |
void |
ClusterCacheStatus.updateAvailabilityMode(List<Address> actualMembers,
AvailabilityMode newAvailabilityMode,
boolean cancelRebalance) |
void |
ClusterTopologyManagerImpl.updateCacheMembers(List<Address> newClusterMembers) |
void |
ClusterCacheStatus.updateCurrentTopology(List<Address> newMembers) |
Constructor and Description |
---|
CacheTopologyControlCommand(String cacheName,
CacheTopologyControlCommand.Type type,
Address sender,
AvailabilityMode availabilityMode,
int viewId) |
CacheTopologyControlCommand(String cacheName,
CacheTopologyControlCommand.Type type,
Address sender,
CacheJoinInfo joinInfo,
int viewId) |
CacheTopologyControlCommand(String cacheName,
CacheTopologyControlCommand.Type type,
Address sender,
CacheTopology cacheTopology,
AvailabilityMode availabilityMode,
int viewId) |
CacheTopologyControlCommand(String cacheName,
CacheTopologyControlCommand.Type type,
Address sender,
int viewId) |
CacheTopologyControlCommand(String cacheName,
CacheTopologyControlCommand.Type type,
Address sender,
int topologyId,
int rebalanceId,
Throwable throwable,
int viewId) |
Constructor and Description |
---|
CacheTopology(int topologyId,
int rebalanceId,
ConsistentHash currentCH,
ConsistentHash pendingCH,
ConsistentHash unionCH,
List<Address> actualMembers) |
CacheTopology(int topologyId,
int rebalanceId,
ConsistentHash currentCH,
ConsistentHash pendingCH,
List<Address> actualMembers) |
Modifier and Type | Method and Description |
---|---|
Collection<Address> |
LocalTransaction.getCommitNodes(Collection<Address> recipients,
int currentTopologyId,
Collection<Address> members)
Calculates the list of nodes to which a commit/rollback needs to be sent based on the nodes to which prepare
was sent.
|
Collection<Address> |
LocalTransaction.getRemoteLocksAcquired() |
Modifier and Type | Method and Description |
---|---|
void |
TransactionTable.cleanupLeaverTransactions(List<Address> members) |
Collection<Address> |
LocalTransaction.getCommitNodes(Collection<Address> recipients,
int currentTopologyId,
Collection<Address> members)
Calculates the list of nodes to which a commit/rollback needs to be sent based on the nodes to which prepare
was sent.
|
Collection<Address> |
LocalTransaction.getCommitNodes(Collection<Address> recipients,
int currentTopologyId,
Collection<Address> members)
Calculates the list of nodes to which a commit/rollback needs to be sent based on the nodes to which prepare
was sent.
|
void |
LocalTransaction.locksAcquired(Collection<Address> nodes) |
Modifier and Type | Field and Description |
---|---|
protected Address |
GlobalTransaction.addr |
Modifier and Type | Method and Description |
---|---|
Address |
GlobalTransaction.getAddress() |
Modifier and Type | Method and Description |
---|---|
GlobalTransaction |
TransactionFactory.newGlobalTransaction(Address addr,
boolean remote) |
abstract GlobalTransaction |
TransactionFactory.TxFactoryEnum.newGlobalTransaction(Address addr,
boolean remote,
VersionGenerator clusterIdGenerator,
boolean clustered) |
void |
GlobalTransaction.setAddress(Address address) |
Constructor and Description |
---|
DldGlobalTransaction(Address addr,
boolean remote) |
GlobalTransaction(Address addr,
boolean remote) |
Modifier and Type | Method and Description |
---|---|
Set<Address> |
RecoveryManager.InDoubtTxInfo.getOwners()
Returns the set of nodes where this transaction information is maintained.
|
Set<Address> |
InDoubtTxInfoImpl.getOwners() |
Modifier and Type | Method and Description |
---|---|
void |
InDoubtTxInfoImpl.addOwner(Address owner) |
String |
RecoveryManagerImpl.forceTransactionCompletionFromCluster(Xid xid,
Address where,
boolean commit) |
String |
RecoveryManager.forceTransactionCompletionFromCluster(Xid xid,
Address where,
boolean commit)
This method invokes
RecoveryManager.forceTransactionCompletion(javax.transaction.xa.Xid, boolean) on the specified node. |
Modifier and Type | Method and Description |
---|---|
void |
RecoveryAwareTransactionTable.cleanupLeaverTransactions(List<Address> members)
First moves the prepared transactions originated on the leavers into the recovery cache and then cleans up the
transactions that are not yet prepared.
|
void |
RecoveryAwareRemoteTransaction.computeOrphan(Collection<Address> currentMembers)
Check's if this transaction's originator is no longer part of the cluster (orphan transaction) and updates
RecoveryAwareRemoteTransaction.isOrphan() . |
void |
RecoveryManagerImpl.removeRecoveryInformation(Collection<Address> lockOwners,
Xid xid,
boolean sync,
GlobalTransaction gtx,
boolean fromCluster) |
void |
RecoveryManager.removeRecoveryInformation(Collection<Address> where,
Xid xid,
boolean sync,
GlobalTransaction gtx,
boolean fromCluster)
Removes from the specified nodes (or all nodes if the value of 'where' is null) the recovery information
associated with these Xids.
|
void |
RecoveryManagerImpl.removeRecoveryInformationFromCluster(Collection<Address> where,
long internalId,
boolean sync) |
void |
RecoveryManager.removeRecoveryInformationFromCluster(Collection<Address> where,
long internalId,
boolean sync)
Same as
RecoveryManager.removeRecoveryInformation(java.util.Collection, javax.transaction.xa.Xid, boolean,
org.infinispan.transaction.xa.GlobalTransaction, boolean) but the transaction is identified by its internal id,
and not by its xid. |
Constructor and Description |
---|
RecoveryAwareDldGlobalTransaction(Address addr,
boolean remote) |
RecoveryAwareGlobalTransaction(Address addr,
boolean remote) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractControlledLocalTopologyManager.handleRebalance(String cacheName,
CacheTopology cacheTopology,
int viewId,
Address sender) |
void |
AbstractControlledLocalTopologyManager.handleStableTopologyUpdate(String cacheName,
CacheTopology cacheTopology,
Address sender,
int viewId) |
void |
AbstractControlledLocalTopologyManager.handleTopologyUpdate(String cacheName,
CacheTopology cacheTopology,
AvailabilityMode availabilityMode,
int viewId,
Address sender) |
Modifier and Type | Method and Description |
---|---|
void |
Log.cannotSelectRandomMembers(int numNeeded,
List<Address> members) |
void |
Log.expectedJustOneResponse(Map<Address,Response> lr) |
void |
Log.keyDoesNotMapToLocalNode(Object key,
Collection<Address> nodes) |
void |
Log.localAndPhysicalAddress(String cluster,
Address address,
List<Address> physicalAddresses) |
void |
Log.noLiveOwnersFoundForSegment(int segmentId,
String cacheName,
Collection<Address> owners,
Collection<Address> faultySources) |
void |
Log.noLiveOwnersFoundForSegment(int segmentId,
String cacheName,
Collection<Address> owners,
Collection<Address> faultySources) |
Modifier and Type | Method and Description |
---|---|
String |
Messages_$bundle.enteringDegradedModeGracefulLeaver(Address leaver) |
String |
Messages.enteringDegradedModeGracefulLeaver(Address leaver) |
String |
Messages_$bundle.lostDataBecauseOfGracefulLeaver(Address leaver) |
String |
Messages.lostDataBecauseOfGracefulLeaver(Address leaver) |
String |
Messages_$bundle.nodeJoined(Address joiner) |
String |
Messages.nodeJoined(Address joiner) |
String |
Messages_$bundle.nodeLeft(Address leaver) |
String |
Messages.nodeLeft(Address leaver) |
default EventLogger |
EventLogger.scope(Address scope)
Sets a node address as the scope of this event log
|
Modifier and Type | Method and Description |
---|---|
EventLogger |
DecoratedEventLogger.scope(Address scope) |
Modifier and Type | Method and Description |
---|---|
boolean |
XSiteStateTransferCollector.confirmStateTransfer(Address node,
boolean statusOk) |
void |
XSiteStateTransferManagerImpl.notifyStatePushFinished(String siteName,
Address node,
boolean statusOk) |
void |
XSiteStateTransferManager.notifyStatePushFinished(String siteName,
Address node,
boolean statusOk)
It receives the notifications from local site when some node finishes pushing the state to the remote site.
|
void |
XSiteStateProvider.startStateTransfer(String siteName,
Address requestor,
int minTopologyId)
It notifies this node to start sending state to the remote site.
|
void |
XSiteStateProviderImpl.startStateTransfer(String siteName,
Address origin,
int minTopologyId) |
Modifier and Type | Method and Description |
---|---|
Collection<String> |
XSiteStateProvider.getSitesMissingCoordinator(Collection<Address> currentMembers) |
Collection<String> |
XSiteStateProviderImpl.getSitesMissingCoordinator(Collection<Address> currentMembers) |
boolean |
XSiteStateTransferCollector.updateMembers(Collection<Address> members) |
Constructor and Description |
---|
XSiteStateTransferCollector(Collection<Address> confirmationPending) |
Modifier and Type | Method and Description |
---|---|
void |
CacheSiteStatusBuilder.addMember(Address address,
boolean online)
Adds a member with an online/offline connection to the server based on the
online parameter. |
Modifier and Type | Method and Description |
---|---|
protected SiteStatus |
CacheSiteStatusBuilder.createMixedStatus(List<Address> onlineElements,
List<Address> offlineElements) |
protected SiteStatus |
CacheSiteStatusBuilder.createMixedStatus(List<Address> onlineElements,
List<Address> offlineElements) |
Constructor and Description |
---|
CacheMixedSiteStatus(List<Address> onlineMembers,
List<Address> offlineMembers) |
CacheMixedSiteStatus(List<Address> onlineMembers,
List<Address> offlineMembers) |
Copyright © 2023 JBoss, a division of Red Hat. All rights reserved.