| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
IgniteCluster.localNode()
Gets local grid node.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<ClusterNode> |
IgniteCluster.topology(long topVer)
Gets a topology by version.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable ClusterNode |
Affinity.mapKeyToNode(K key)
This method provides ability to detect to which primary node the given key
is mapped.
|
ClusterNode |
Affinity.mapPartitionToNode(int part)
Gets primary node for the given partition.
|
| Modifier and Type | Method and Description |
|---|---|
List<List<ClusterNode>> |
AffinityFunction.assignPartitions(AffinityFunctionContext affCtx)
Gets affinity nodes for a partition.
|
List<ClusterNode> |
AffinityFunctionContext.currentTopologySnapshot()
Gets current topology snapshot.
|
Map<ClusterNode,Collection<K>> |
Affinity.mapKeysToNodes(Collection<? extends K> keys)
This method provides ability to detect which keys are mapped to which nodes.
|
Collection<ClusterNode> |
Affinity.mapKeyToPrimaryAndBackups(K key)
Gets primary and backup nodes for the key.
|
Map<Integer,ClusterNode> |
Affinity.mapPartitionsToNodes(Collection<Integer> parts)
Gets primary nodes for the given partitions.
|
Collection<ClusterNode> |
Affinity.mapPartitionToPrimaryAndBackups(int part)
Gets primary and backup nodes for partition.
|
| Modifier and Type | Method and Description |
|---|---|
int[] |
Affinity.allPartitions(ClusterNode n)
Gets partition ids for which given cluster node has any ownership
(either primary or backup).
|
int[] |
Affinity.backupPartitions(ClusterNode n)
Gets partition ids for which given cluster node has backup ownership.
|
boolean |
Affinity.isBackup(ClusterNode n,
K key)
Returns
true if local node is one of the backup nodes for given key. |
boolean |
Affinity.isPrimary(ClusterNode n,
K key)
Returns
true if given node is the primary node for given key. |
boolean |
Affinity.isPrimaryOrBackup(ClusterNode n,
K key)
Returns
true if local node is primary or one of the backup nodes
This method is essentially equivalent to calling
"Affinity.isPrimary(ClusterNode, Object) || Affinity.isBackup(ClusterNode, Object))",
however it is more efficient as it makes both checks at once. |
int[] |
Affinity.primaryPartitions(ClusterNode n)
Gets partition ids for which the given cluster node has primary ownership.
|
| Modifier and Type | Method and Description |
|---|---|
List<ClusterNode> |
RendezvousAffinityFunction.assignPartition(int part,
List<ClusterNode> nodes,
int backups,
@Nullable Map<UUID,Collection<ClusterNode>> neighborhoodCache)
Returns collection of nodes (primary first) for specified partition.
|
List<List<ClusterNode>> |
RendezvousAffinityFunction.assignPartitions(AffinityFunctionContext affCtx)
Gets affinity nodes for a partition.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
ClusterNodeAttributeColocatedBackupFilter.apply(ClusterNode candidate,
List<ClusterNode> previouslySelected)
Defines a predicate which returns
true if a node is acceptable for a backup
or false otherwise. |
boolean |
ClusterNodeAttributeAffinityBackupFilter.apply(ClusterNode candidate,
List<ClusterNode> previouslySelected)
Defines a predicate which returns
true if a node is acceptable for a backup
or false otherwise. |
Object |
RendezvousAffinityFunction.resolveNodeHash(ClusterNode node)
Resolves node hash.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
ClusterNodeAttributeColocatedBackupFilter.apply(ClusterNode candidate,
List<ClusterNode> previouslySelected)
Defines a predicate which returns
true if a node is acceptable for a backup
or false otherwise. |
boolean |
ClusterNodeAttributeAffinityBackupFilter.apply(ClusterNode candidate,
List<ClusterNode> previouslySelected)
Defines a predicate which returns
true if a node is acceptable for a backup
or false otherwise. |
List<ClusterNode> |
RendezvousAffinityFunction.assignPartition(int part,
List<ClusterNode> nodes,
int backups,
@Nullable Map<UUID,Collection<ClusterNode>> neighborhoodCache)
Returns collection of nodes (primary first) for specified partition.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
ClientClusterGroup.node()
Gets first node from the list of nodes in this cluster group.
|
ClusterNode |
ClientClusterGroup.node(UUID nid)
Gets a node for given ID from this cluster group.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<ClusterNode> |
ClientClusterGroup.nodes()
Gets the read-only collection of nodes in this cluster group.
|
| Modifier and Type | Method and Description |
|---|---|
ClientClusterGroup |
ClientClusterGroup.forHost(ClusterNode node)
Gets cluster group consisting from the nodes in this cluster group residing on the
same host (with the same MAC address) as the given node.
|
ClientClusterGroup |
ClientClusterGroup.forNode(ClusterNode node,
ClusterNode... nodes)
Creates a cluster group for the given node.
|
ClientClusterGroup |
ClientClusterGroup.forNode(ClusterNode node,
ClusterNode... nodes)
Creates a cluster group for the given node.
|
ClientClusterGroup |
ClientClusterGroup.forOthers(ClusterNode node,
ClusterNode... nodes)
Creates a cluster group for nodes other than the given nodes.
|
ClientClusterGroup |
ClientClusterGroup.forOthers(ClusterNode node,
ClusterNode... nodes)
Creates a cluster group for nodes other than the given nodes.
|
| Modifier and Type | Method and Description |
|---|---|
ClientClusterGroup |
ClientClusterGroup.forNodes(Collection<? extends ClusterNode> nodes)
Creates a cluster group over a given set of nodes.
|
ClientClusterGroup |
ClientClusterGroup.forPredicate(Predicate<ClusterNode> p)
Creates a new cluster group which includes all nodes that pass the given predicate filter.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
ClusterGroup.node()
Gets first node from the list of nodes in this cluster group.
|
ClusterNode |
ClusterGroup.node(UUID nid)
Gets a node for given ID from this cluster group.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<ClusterNode> |
ClusterGroup.nodes()
Gets the read-only collection of nodes in this cluster group.
|
IgnitePredicate<ClusterNode> |
ClusterGroup.predicate()
Gets predicate that defines a subset of nodes for this cluster group.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterGroup |
ClusterGroup.forHost(ClusterNode node)
Gets cluster group consisting from the nodes in this cluster group residing on the
same host as the given node.
|
ClusterGroup |
ClusterGroup.forNode(ClusterNode node,
ClusterNode... nodes)
Creates a cluster group for the given node.
|
ClusterGroup |
ClusterGroup.forNode(ClusterNode node,
ClusterNode... nodes)
Creates a cluster group for the given node.
|
ClusterGroup |
ClusterGroup.forOthers(ClusterNode node,
ClusterNode... nodes)
Creates a cluster group for nodes other than the given nodes.
|
ClusterGroup |
ClusterGroup.forOthers(ClusterNode node,
ClusterNode... nodes)
Creates a cluster group for nodes other than the given nodes.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterGroup |
ClusterGroup.forNodes(Collection<? extends ClusterNode> nodes)
Creates a cluster group over a given set of nodes.
|
ClusterGroup |
ClusterGroup.forPredicate(IgnitePredicate<ClusterNode> p)
Creates a new cluster group which includes all nodes that pass the given predicate filter.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable ClusterNode |
ComputeLoadBalancer.getBalancedNode(ComputeJob job,
@Nullable Collection<ClusterNode> exclNodes)
Gets the next balanced node according to the underlying load balancing policy.
|
ClusterNode |
ComputeJobResult.getNode()
Gets node this job executed on.
|
| Modifier and Type | Method and Description |
|---|---|
void |
ComputeTaskContinuousMapper.send(ComputeJob job,
ClusterNode node)
Sends given job to a specific grid node.
|
| Modifier and Type | Method and Description |
|---|---|
@NotNull Map<? extends ComputeJob,ClusterNode> |
ComputeTask.map(List<ClusterNode> subgrid,
T arg)
This method is called to map or split grid task into multiple grid jobs.
|
@NotNull Map<? extends ComputeJob,ClusterNode> |
ComputeTaskSplitAdapter.map(List<ClusterNode> subgrid,
T arg)
This method is called to map or split grid task into multiple grid jobs.
|
void |
ComputeTaskContinuousMapper.send(Map<? extends ComputeJob,ClusterNode> mappedJobs)
Sends collection of grid jobs to assigned nodes.
|
| Modifier and Type | Field and Description |
|---|---|
static IgnitePredicate<ClusterNode> |
CacheConfiguration.ALL_NODES
Filter that accepts all nodes.
|
| Modifier and Type | Method and Description |
|---|---|
List<List<ClusterNode>> |
CommunicationFailureContext.cacheAffinity(String cacheName) |
List<List<ClusterNode>> |
CommunicationFailureContext.cachePartitionOwners(String cacheName) |
IgnitePredicate<ClusterNode> |
CollectionConfiguration.getNodeFilter() |
IgnitePredicate<ClusterNode> |
CacheConfiguration.getNodeFilter()
Gets filter which determines on what nodes the cache should be started.
|
List<ClusterNode> |
CommunicationFailureContext.topologySnapshot() |
| Modifier and Type | Method and Description |
|---|---|
boolean |
CacheConfiguration.IgniteAllNodesPredicate.apply(ClusterNode node)
Predicate body.
|
boolean |
CommunicationFailureContext.connectionAvailable(ClusterNode node1,
ClusterNode node2) |
void |
CommunicationFailureContext.killNode(ClusterNode node) |
| Modifier and Type | Method and Description |
|---|---|
CollectionConfiguration |
CollectionConfiguration.setNodeFilter(IgnitePredicate<ClusterNode> nodeFilter) |
CacheConfiguration<K,V> |
CacheConfiguration.setNodeFilter(IgnitePredicate<ClusterNode> nodeFilter)
Sets filter which determines on what nodes the cache should be started.
|
boolean |
TopologyValidator.validate(Collection<ClusterNode> nodes)
Validates topology.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
CacheRebalancingEvent.discoveryNode()
Gets shadow of the node that triggered this rebalancing event.
|
ClusterNode |
CacheEvent.eventNode()
Gets node which initiated cache operation or
null if that node is not available. |
ClusterNode |
DiscoveryEvent.eventNode()
Gets node that caused this event to be generated.
|
ClusterNode |
NodeValidationFailedEvent.eventNode() |
ClusterNode |
EventAdapter.node()
Node where event occurred and was recorded
|
ClusterNode |
Event.node()
Node where event occurred and was recorded
|
ClusterNode |
JobEvent.taskNode()
Get node where parent task of the job has originated.
|
| Modifier and Type | Method and Description |
|---|---|
Map<ClusterNode,CacheConsistencyViolationEvent.EntryInfo> |
CacheConsistencyViolationEvent.EntriesInfo.getMapping() |
Collection<ClusterNode> |
DiscoveryEvent.topologyNodes()
Gets topology nodes from topology snapshot.
|
| Modifier and Type | Method and Description |
|---|---|
void |
DiscoveryEvent.eventNode(ClusterNode evtNode)
Sets node this event is referring to.
|
void |
EventAdapter.node(ClusterNode node)
Sets node where even is occurred (i.e. node local to the event).
|
void |
JobEvent.taskNode(ClusterNode taskNode)
Sets node where parent task of the job has originated.
|
| Modifier and Type | Method and Description |
|---|---|
void |
DiscoveryEvent.topologySnapshot(long topVer,
Collection<ClusterNode> topSnapshot)
Sets the topology snapshot.
|
| Constructor and Description |
|---|
BaselineChangedEvent(ClusterNode node,
String msg,
int type,
Collection<BaselineNode> baselineNodes)
Creates baseline changed event with given parameters.
|
BaselineConfigurationChangedEvent(ClusterNode node,
String msg,
int type,
boolean autoAdjustEnabled,
long autoAdjustTimeout)
Creates baseline configuration changed event with given parameters.
|
CacheConsistencyViolationEvent(String cacheName,
ClusterNode node,
String msg,
Map<Object,CacheConsistencyViolationEvent.EntriesInfo> entries,
Map<Object,Object> repaired,
ReadRepairStrategy strategy)
Creates a new instance of CacheConsistencyViolationEvent.
|
CacheEvent(String cacheName,
ClusterNode node,
@Nullable ClusterNode evtNode,
String msg,
int type,
int part,
boolean near,
Object key,
IgniteUuid xid,
String txLbl,
Object lockId,
Object newVal,
boolean hasNewVal,
Object oldVal,
boolean hasOldVal,
UUID subjId,
String cloClsName,
String taskName)
Constructs cache event.
|
CacheEvent(String cacheName,
ClusterNode node,
@Nullable ClusterNode evtNode,
String msg,
int type,
int part,
boolean near,
Object key,
IgniteUuid xid,
String txLbl,
Object lockId,
Object newVal,
boolean hasNewVal,
Object oldVal,
boolean hasOldVal,
UUID subjId,
String cloClsName,
String taskName)
Constructs cache event.
|
CacheObjectTransformedEvent(ClusterNode node,
String msg,
int type,
byte[] original,
byte[] transformed,
boolean restore) |
CacheQueryExecutedEvent(ClusterNode node,
String msg,
int type,
String qryType,
@Nullable String cacheName,
@Nullable String clsName,
@Nullable String clause,
@Nullable IgniteBiPredicate<K,V> scanQryFilter,
@Nullable CacheEntryEventSerializableFilter<K,V> contQryFilter,
@Nullable Object[] args,
@Nullable UUID subjId,
@Nullable String taskName) |
CacheQueryReadEvent(ClusterNode node,
String msg,
int type,
String qryType,
@Nullable String cacheName,
@Nullable String clsName,
@Nullable String clause,
@Nullable IgniteBiPredicate<K,V> scanQryFilter,
@Nullable CacheEntryEventSerializableFilter<K,V> contQryFilter,
@Nullable Object[] args,
@Nullable UUID subjId,
@Nullable String taskName,
K key,
V val,
V oldVal,
@Nullable Object row) |
CacheRebalancingEvent(String cacheName,
ClusterNode node,
String msg,
int type,
int part,
ClusterNode discoNode,
int discoEvtType,
long discoTs)
Constructs cache event.
|
CheckpointEvent(ClusterNode node,
String msg,
int type,
String cpKey)
Creates new checkpoint event with given parameters.
|
ClusterActivationEvent(ClusterNode node,
String msg,
int type,
Collection<BaselineNode> baselineNodes)
Deprecated.
Creates activation event with given parameters.
|
ClusterStateChangeEvent(ClusterState prevState,
ClusterState state,
@Nullable Collection<? extends BaselineNode> baselineNodes,
ClusterNode node,
String msg) |
ClusterStateChangeStartedEvent(ClusterState prevState,
ClusterState state,
ClusterNode node,
String msg) |
ClusterTagUpdatedEvent(ClusterNode node,
String msg,
UUID clusterId,
String prevTag,
String newTag) |
DeploymentEvent(ClusterNode node,
String msg,
int type)
Creates deployment event with given parameters.
|
DiscoveryEvent(ClusterNode node,
String msg,
int type,
ClusterNode evtNode)
Creates new discovery event with given parameters.
|
EventAdapter(ClusterNode node,
String msg,
int type)
Creates event based with given parameters.
|
JobEvent(ClusterNode node,
String msg,
int type)
Creates job event with given parameters.
|
NodeValidationFailedEvent(ClusterNode node,
ClusterNode evtNode,
IgniteNodeValidationResult res)
Creates new node validation event with given parameters.
|
PageReplacementStartedEvent(ClusterNode node,
String msg,
String dataRegionName) |
SnapshotEvent(ClusterNode node,
String msg,
String snpName,
int type) |
SqlQueryExecutionEvent(ClusterNode node,
String msg,
@Nullable String text,
@Nullable Object[] args,
@Nullable UUID subjId) |
TaskEvent(ClusterNode node,
String msg,
int type,
IgniteUuid sesId,
String taskName,
String taskClsName,
boolean internal,
@Nullable UUID subjId)
Creates task event with given parameters.
|
TransactionStateChangedEvent(ClusterNode node,
String msg,
int type,
Transaction tx) |
WalSegmentArchivedEvent(@NotNull ClusterNode node,
long absWalSegmentIdx,
File archiveFile)
Creates WAL segment event
|
WalSegmentArchivedEvent(@NotNull ClusterNode node,
long absWalSegmentIdx,
File archiveFile,
int evtType) |
WalSegmentCompactedEvent(@NotNull ClusterNode node,
long absWalSegmentIdx,
File archiveFile)
Creates WAL segment compaction event.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
GridJobResultImpl.getNode()
Gets node this job executed on.
|
ClusterNode |
IgniteEx.localNode()
Gets local grid node.
|
ClusterNode |
IgniteKernal.localNode()
Gets local grid node.
|
ClusterNode |
GridCachePluginContext.localNode()
Gets local grid node.
|
ClusterNode |
GridPluginContext.localNode()
Gets local grid node.
|
| Modifier and Type | Method and Description |
|---|---|
IgnitePredicate<ClusterNode> |
GridJobExecuteRequest.getTopologyPredicate() |
Map<org.apache.ignite.internal.CheckCpHistTask.CheckCpHistClosureJob,ClusterNode> |
CheckCpHistTask.map(List<ClusterNode> subgrid,
Map<UUID,Map<Integer,Set<Integer>>> arg)
This method is called to map or split grid task into multiple grid jobs.
|
Collection<ClusterNode> |
GridPluginContext.nodes()
Gets a collection of all grid nodes.
|
| Modifier and Type | Method and Description |
|---|---|
static boolean |
IgniteFeatures.nodeSupports(ClusterNode clusterNode,
IgniteFeatures feature)
Checks that feature supported by node.
|
IgniteInternalFuture |
IgniteKernal.sendIoTest(ClusterNode node,
byte[] payload,
boolean procFromNioThread) |
void |
GridJobResultImpl.setNode(ClusterNode node) |
@Nullable IgniteNodeValidationResult |
GridComponent.validateNode(ClusterNode node)
Validates that new node can join grid topology, this method is called on coordinator
node before new node joins topology.
|
@Nullable IgniteNodeValidationResult |
GridPluginComponent.validateNode(ClusterNode node)
Validates that new node can join grid topology, this method is called on coordinator
node before new node joins topology.
|
@Nullable IgniteNodeValidationResult |
GridComponent.validateNode(ClusterNode node,
DiscoveryDataBag.JoiningNodeDiscoveryData discoData)
Validates that new node can join grid topology, this method is called on coordinator
node before new node joins topology.
|
@Nullable IgniteNodeValidationResult |
GridPluginComponent.validateNode(ClusterNode node,
DiscoveryDataBag.JoiningNodeDiscoveryData discoData)
Validates that new node can join grid topology, this method is called on coordinator
node before new node joins topology.
|
| Modifier and Type | Method and Description |
|---|---|
static boolean |
IgniteFeatures.allNodesSupports(Iterable<ClusterNode> nodes,
IgniteFeatures feature)
Checks that feature supported by all nodes.
|
Map<org.apache.ignite.internal.CheckCpHistTask.CheckCpHistClosureJob,ClusterNode> |
CheckCpHistTask.map(List<ClusterNode> subgrid,
Map<UUID,Map<Integer,Set<Integer>>> arg)
This method is called to map or split grid task into multiple grid jobs.
|
IgniteInternalFuture |
IgniteKernal.sendIoTest(List<ClusterNode> nodes,
byte[] payload,
boolean procFromNioThread) |
IgniteComputeHandler |
IgniteComputeHandler.withProjection(Collection<ClusterNode> prj) |
IgniteComputeHandler |
IgniteComputeHandler.withProjectionPredicate(IgnitePredicate<ClusterNode> predicate) |
| Constructor and Description |
|---|
GridJobResultImpl(ComputeJob job,
IgniteUuid jobId,
ClusterNode node,
GridJobSiblingImpl sib) |
IgniteNeedReconnectException(ClusterNode node,
@Nullable Throwable cause) |
| Modifier and Type | Class and Description |
|---|---|
class |
DetachedClusterNode
Representation of cluster node that either isn't currently present in cluster, or semantically detached.
|
| Modifier and Type | Field and Description |
|---|---|
static Comparator<ClusterNode> |
NodeOrderLegacyComparator.INSTANCE |
protected IgnitePredicate<ClusterNode> |
ClusterGroupAdapter.p
Cluster group predicate.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
IgniteClusterAsyncImpl.localNode()
Gets local grid node.
|
ClusterNode |
IgniteClusterImpl.localNode()
Gets local grid node.
|
ClusterNode |
ClusterGroupAdapter.node()
Gets first node from the list of nodes in this cluster group.
|
@Nullable ClusterNode |
IgniteClusterAsyncImpl.node()
Gets first node from the list of nodes in this cluster group.
|
ClusterNode |
ClusterGroupAdapter.node(UUID id)
Gets a node for given ID from this cluster group.
|
@Nullable ClusterNode |
IgniteClusterAsyncImpl.node(UUID id)
Gets a node for given ID from this cluster group.
|
| Modifier and Type | Method and Description |
|---|---|
static Comparator<ClusterNode> |
NodeOrderComparator.getInstance() |
Collection<ClusterNode> |
ClusterGroupAdapter.nodes()
Gets the read-only collection of nodes in this cluster group.
|
Collection<ClusterNode> |
IgniteClusterAsyncImpl.nodes()
Gets the read-only collection of nodes in this cluster group.
|
IgnitePredicate<ClusterNode> |
ClusterGroupAdapter.predicate()
Gets predicate that defines a subset of nodes for this cluster group.
|
IgnitePredicate<ClusterNode> |
IgniteClusterAsyncImpl.predicate()
Gets predicate that defines a subset of nodes for this cluster group.
|
protected Collection<ClusterNode> |
ClusterGroupAdapter.resolveCurrentNodes() |
Collection<ClusterNode> |
IgniteClusterImpl.topology(long topVer)
Gets a topology by version.
|
| Modifier and Type | Method and Description |
|---|---|
int |
NodeOrderLegacyComparator.compare(ClusterNode n1,
ClusterNode n2) |
int |
NodeOrderComparator.compare(ClusterNode n1,
ClusterNode n2) |
ClusterGroup |
ClusterGroupAdapter.forHost(ClusterNode node)
Gets cluster group consisting from the nodes in this cluster group residing on the
same host as the given node.
|
ClusterGroup |
IgniteClusterAsyncImpl.forHost(ClusterNode node)
Gets cluster group consisting from the nodes in this cluster group residing on the
same host as the given node.
|
ClusterGroup |
ClusterGroupAdapter.forNode(ClusterNode node,
ClusterNode... nodes)
Creates a cluster group for the given node.
|
ClusterGroup |
ClusterGroupAdapter.forNode(ClusterNode node,
ClusterNode... nodes)
Creates a cluster group for the given node.
|
ClusterGroup |
IgniteClusterAsyncImpl.forNode(ClusterNode node,
ClusterNode... nodes)
Creates a cluster group for the given node.
|
ClusterGroup |
IgniteClusterAsyncImpl.forNode(ClusterNode node,
ClusterNode... nodes)
Creates a cluster group for the given node.
|
ClusterGroup |
ClusterGroupAdapter.forOthers(ClusterNode node,
ClusterNode... nodes)
Creates a cluster group for nodes other than the given nodes.
|
ClusterGroup |
ClusterGroupAdapter.forOthers(ClusterNode node,
ClusterNode... nodes)
Creates a cluster group for nodes other than the given nodes.
|
ClusterGroup |
IgniteClusterAsyncImpl.forOthers(ClusterNode node,
ClusterNode... nodes)
Creates a cluster group for nodes other than the given nodes.
|
ClusterGroup |
IgniteClusterAsyncImpl.forOthers(ClusterNode node,
ClusterNode... nodes)
Creates a cluster group for nodes other than the given nodes.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterGroup |
ClusterGroupAdapter.forNodes(Collection<? extends ClusterNode> nodes)
Creates a cluster group over a given set of nodes.
|
ClusterGroup |
IgniteClusterAsyncImpl.forNodes(Collection<? extends ClusterNode> nodes)
Creates a cluster group over a given set of nodes.
|
ClusterGroup |
ClusterGroupAdapter.forPredicate(IgnitePredicate<ClusterNode> p)
Creates a new cluster group which includes all nodes that pass the given predicate filter.
|
ClusterGroup |
IgniteClusterAsyncImpl.forPredicate(IgnitePredicate<ClusterNode> p)
Creates a new cluster group which includes all nodes that pass the given predicate filter.
|
| Constructor and Description |
|---|
ClusterGraph(CommunicationFailureContext ctx,
Predicate<ClusterNode> nodeFilterOut)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable IgniteNodeValidationResult |
GridManagerAdapter.validateNode(ClusterNode node)
Validates that new node can join grid topology, this method is called on coordinator
node before new node joins topology.
|
@Nullable IgniteNodeValidationResult |
GridManagerAdapter.validateNode(ClusterNode node,
DiscoveryDataBag.JoiningNodeDiscoveryData discoData)
Validates that new node can join grid topology, this method is called on coordinator
node before new node joins topology.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridIoManager.fileTransmissionSupported(ClusterNode node)
This method must be used prior to opening a
GridIoManager.TransmissionSender by calling
GridIoManager.openTransmissionSender(UUID, Object) to ensure that remote and local nodes
are fully support direct SocketChannel connection to transfer data. |
void |
GridIoManager.sendGeneric(ClusterNode node,
Object topic,
int topicOrd,
Message msg,
byte plc) |
IgniteInternalFuture<List<IgniteIoTestMessage>> |
GridIoManager.sendIoTest(ClusterNode node,
byte[] payload,
boolean procFromNioThread) |
void |
GridIoManager.sendOrderedMessage(ClusterNode node,
Object topic,
Message msg,
byte plc,
long timeout,
boolean skipOnTimeout) |
void |
GridIoManager.sendOrderedMessage(ClusterNode node,
Object topic,
Message msg,
byte plc,
long timeout,
boolean skipOnTimeout,
IgniteInClosure<IgniteException> ackC) |
void |
GridIoManager.sendToCustomTopic(ClusterNode node,
Object topic,
Message msg,
byte plc) |
void |
GridIoManager.sendToGridTopic(ClusterNode node,
GridTopic topic,
Message msg,
byte plc) |
void |
GridIoManager.sendToGridTopic(ClusterNode node,
GridTopic topic,
Message msg,
byte plc,
IgniteInClosure<IgniteException> ackC) |
void |
GridIoManager.sendToGridTopic(ClusterNode node,
GridTopic topic,
Message msg,
byte plc,
Span span) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridIoManager.runIoTest(long warmup,
long duration,
int threads,
long latencyLimit,
int rangesCnt,
int payLoadSize,
boolean procFromNioThread,
List<ClusterNode> nodes) |
IgniteInternalFuture |
GridIoManager.sendIoTest(List<ClusterNode> nodes,
byte[] payload,
boolean procFromNioThread) |
void |
GridIoManager.sendToGridTopic(Collection<? extends ClusterNode> nodes,
GridTopic topic,
Message msg,
byte plc) |
void |
GridIoManager.sendUserMessage(Collection<? extends ClusterNode> nodes,
Object msg,
@Nullable Object topic,
boolean ordered,
long timeout,
boolean async)
Sends a peer deployable user message.
|
| Modifier and Type | Method and Description |
|---|---|
IgnitePredicate<ClusterNode> |
GridDeploymentMetadata.nodeFilter() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDeploymentMetadata.nodeFilter(IgnitePredicate<ClusterNode> nodeFilter) |
void |
GridDeploymentManager.undeployTask(String taskName,
boolean locUndeploy,
Collection<ClusterNode> rmtNodes) |
| Modifier and Type | Interface and Description |
|---|---|
interface |
IgniteClusterNode |
| Modifier and Type | Method and Description |
|---|---|
@Nullable ClusterNode |
GridDiscoveryManager.getAlive(UUID nodeId) |
ClusterNode |
GridDiscoveryManager.historicalNode(UUID nodeId)
Resolves by ID cluster node which is alive or has recently left the cluster.
|
ClusterNode |
GridDiscoveryManager.localNode() |
ClusterNode |
DiscoCache.localNode() |
ClusterNode |
GridDiscoveryManager.node(AffinityTopologyVersion topVer,
UUID id)
Gets node from history for given topology version.
|
@Nullable ClusterNode |
GridDiscoveryManager.node(UUID nodeId) |
@Nullable ClusterNode |
DiscoCache.node(UUID id) |
@Nullable ClusterNode |
DiscoCache.oldestAliveServerNode() |
@Nullable ClusterNode |
GridDiscoveryManager.oldestAliveServerNode(AffinityTopologyVersion topVer) |
@Nullable ClusterNode |
DiscoCache.oldestServerNode() |
@Nullable ClusterNode |
DiscoCache.serverNodeByOrder(long order) |
| Modifier and Type | Method and Description |
|---|---|
Collection<ClusterNode> |
GridDiscoveryManager.aliveServerNodes() |
Collection<ClusterNode> |
DiscoCache.aliveServerNodes()
Gets collection of server nodes with at least one cache configured.
|
Collection<ClusterNode> |
GridDiscoveryManager.allNodes() |
List<ClusterNode> |
DiscoCache.allNodes() |
List<ClusterNode> |
DiscoCache.cacheGroupAffinityNodes(int grpId) |
Collection<ClusterNode> |
GridDiscoveryManager.cacheGroupAffinityNodes(int grpId,
AffinityTopologyVersion topVer)
Gets cache nodes for cache with given ID that participate in affinity calculation.
|
List<ClusterNode> |
DiscoCache.cacheNodes(Integer cacheId)
Gets all nodes that have cache with given ID.
|
List<ClusterNode> |
DiscoCache.cacheNodes(@Nullable String cacheName)
Gets all nodes that have cache with given name.
|
List<ClusterNode> |
GridDiscoveryManager.cacheNodes(@Nullable String cacheName,
AffinityTopologyVersion topVer)
Gets cache nodes for cache with given name.
|
Collection<ClusterNode> |
GridDiscoveryManager.nodes(AffinityTopologyVersion topVer)
Gets all nodes for given topology version.
|
Collection<ClusterNode> |
GridDiscoveryManager.nodes(@Nullable Collection<UUID> ids,
IgnitePredicate<UUID>... p)
Gets collection of node for given node IDs and predicates.
|
Collection<ClusterNode> |
GridDiscoveryManager.nodes(long topVer)
Gets all nodes for given topology version.
|
Collection<ClusterNode> |
DiscoCache.remoteAliveNodesWithCaches()
Gets all alive remote nodes that have at least one cache configured.
|
Collection<ClusterNode> |
GridDiscoveryManager.remoteAliveNodesWithCaches(AffinityTopologyVersion topVer)
Gets cache remote nodes for cache with given name.
|
Collection<ClusterNode> |
GridDiscoveryManager.remoteNodes() |
List<ClusterNode> |
DiscoCache.remoteNodes() |
List<ClusterNode> |
DiscoCache.serverNodes() |
List<ClusterNode> |
GridDiscoveryManager.serverNodes(AffinityTopologyVersion topVer) |
Collection<ClusterNode> |
GridDiscoveryManager.serverTopologyNodes(long topVer)
Gets server nodes topology by specified version from snapshots history storage.
|
Collection<ClusterNode> |
GridDiscoveryTopologySnapshot.topologyNodes()
Gets topology nodes from topology snapshot.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridDiscoveryManager.ackTopology(long topVer,
int evtType,
ClusterNode evtNode)
Prints the latest topology info into log taking into account logging/verbosity settings.
|
boolean |
GridDiscoveryManager.alive(ClusterNode node) |
boolean |
DiscoCache.baselineNode(ClusterNode node) |
void |
IgniteDiscoverySpiInternalListener.beforeJoin(ClusterNode locNode,
IgniteLogger log) |
default void |
IgniteDiscoverySpiInternalListener.beforeReconnect(ClusterNode locNode,
IgniteLogger log) |
boolean |
GridDiscoveryManager.cacheAffinityNode(ClusterNode node,
String cacheName)
Checks if node is a data node for the given cache.
|
boolean |
GridDiscoveryManager.cacheClientNode(ClusterNode node,
String cacheName) |
boolean |
GridDiscoveryManager.cacheGroupAffinityNode(ClusterNode node,
int grpId)
Checks if node is a data node for the given cache group.
|
boolean |
GridDiscoveryManager.cacheNearNode(ClusterNode node,
String cacheName) |
boolean |
GridDiscoveryManager.cacheNode(ClusterNode node,
String cacheName) |
void |
GridDiscoveryManager.metricsUpdateEvent(DiscoCache discoCache,
ClusterNode node)
Adds metrics update event to discovery worker queue.
|
Map<String,CacheConfiguration> |
GridDiscoveryManager.nodePublicCaches(ClusterNode node) |
void |
CustomEventListener.onCustomEvent(AffinityTopologyVersion topVer,
ClusterNode snd,
T msg) |
void |
GridDiscoveryManager.resolveCommunicationError(ClusterNode node,
Exception err) |
void |
IgniteDiscoverySpi.resolveCommunicationFailure(ClusterNode node,
Exception err) |
void |
DiscoCache.updateAlives(ClusterNode rmvd)
Removes left node from alives lists.
|
protected abstract boolean |
DiscoveryMessageResultsCollector.waitForNode(DiscoCache discoCache,
ClusterNode node) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDiscoveryManager.addCacheGroup(CacheGroupDescriptor grpDesc,
IgnitePredicate<ClusterNode> filter,
CacheMode cacheMode) |
void |
GridDiscoveryManager.addLocalNodeInitializedEventListener(IgniteInClosure<ClusterNode> lsnr)
Adds a listener for local node initialized event.
|
| Constructor and Description |
|---|
GridDiscoveryTopologySnapshot(long topVer,
Collection<ClusterNode> topNodes)
Creates a topology snapshot with given topology version and topology nodes.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable IgniteNodeValidationResult |
GridEncryptionManager.validateNode(ClusterNode node,
DiscoveryDataBag.JoiningNodeDiscoveryData discoData)
Validates that new node can join grid topology, this method is called on coordinator
node before new node joins topology.
|
| Modifier and Type | Method and Description |
|---|---|
<T extends Event> |
GridEventStorageManager.remoteEventsAsync(IgnitePredicate<T> p,
Collection<? extends ClusterNode> nodes,
long timeout) |
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
GridFailoverManager.failover(GridTaskSessionImpl taskSes,
ComputeJobResult jobRes,
List<ClusterNode> top,
int affPartId,
@Nullable String affCacheName,
@Nullable AffinityTopologyVersion topVer) |
ClusterNode |
GridFailoverContextImpl.getBalancedNode(List<ClusterNode> top)
Gets the next balanced node for failed job.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
GridFailoverManager.failover(GridTaskSessionImpl taskSes,
ComputeJobResult jobRes,
List<ClusterNode> top,
int affPartId,
@Nullable String affCacheName,
@Nullable AffinityTopologyVersion topVer) |
ClusterNode |
GridFailoverContextImpl.getBalancedNode(List<ClusterNode> top)
Gets the next balanced node for failed job.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
GridLoadBalancerManager.getBalancedNode(GridTaskSessionImpl ses,
List<ClusterNode> top,
ComputeJob job) |
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
GridLoadBalancerManager.getBalancedNode(GridTaskSessionImpl ses,
List<ClusterNode> top,
ComputeJob job) |
ComputeLoadBalancer |
GridLoadBalancerManager.getLoadBalancer(GridTaskSessionImpl ses,
List<ClusterNode> top) |
| Modifier and Type | Method and Description |
|---|---|
@Nullable IgniteNodeValidationResult |
GridProcessorAdapter.validateNode(ClusterNode node)
Validates that new node can join grid topology, this method is called on coordinator
node before new node joins topology.
|
@Nullable IgniteNodeValidationResult |
GridProcessorAdapter.validateNode(ClusterNode node,
DiscoveryDataBag.JoiningNodeDiscoveryData discoData)
Validates that new node can join grid topology, this method is called on coordinator
node before new node joins topology.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
IdealAffinityAssignment.currentPrimary(int partition) |
<K> @Nullable ClusterNode |
GridAffinityProcessor.mapKeyToNode(String cacheName,
K key)
Maps single key to a node.
|
<K> @Nullable ClusterNode |
GridAffinityProcessor.mapKeyToNode(String cacheName,
K key,
AffinityTopologyVersion topVer)
Maps single key to a node.
|
@Nullable ClusterNode |
GridAffinityProcessor.mapPartitionToNode(String cacheName,
int partId,
AffinityTopologyVersion topVer)
Maps partition to a node.
|
| Modifier and Type | Method and Description |
|---|---|
List<List<ClusterNode>> |
IdealAffinityAssignment.assignment() |
List<List<ClusterNode>> |
GridAffinityAssignmentV2.assignment() |
List<List<ClusterNode>> |
HistoryAffinityAssignmentImpl.assignment() |
List<List<ClusterNode>> |
GridAffinityAssignment.assignment()
Deprecated.
|
List<List<ClusterNode>> |
AffinityAssignment.assignment() |
List<List<ClusterNode>> |
HistoryAffinityAssignmentShallowCopy.assignment() |
List<List<ClusterNode>> |
GridAffinityAssignmentCache.assignments(AffinityTopologyVersion topVer) |
List<ClusterNode> |
GridAffinityFunctionContextImpl.currentTopologySnapshot()
Gets current topology snapshot.
|
List<ClusterNode> |
GridAffinityAssignmentV2.get(int part)
Get affinity nodes for partition.
|
List<ClusterNode> |
HistoryAffinityAssignmentImpl.get(int part)
Get affinity nodes for partition.
|
List<ClusterNode> |
GridAffinityAssignment.get(int part)
Deprecated.
Get affinity nodes for partition.
|
List<ClusterNode> |
AffinityAssignment.get(int part)
Get affinity nodes for partition.
|
List<ClusterNode> |
HistoryAffinityAssignmentShallowCopy.get(int part)
Get affinity nodes for partition.
|
List<List<ClusterNode>> |
GridAffinityAssignmentV2.idealAssignment() |
List<List<ClusterNode>> |
HistoryAffinityAssignmentImpl.idealAssignment() |
List<List<ClusterNode>> |
GridAffinityAssignment.idealAssignment()
Deprecated.
|
List<List<ClusterNode>> |
AffinityAssignment.idealAssignment() |
List<List<ClusterNode>> |
HistoryAffinityAssignmentShallowCopy.idealAssignment() |
<K> Map<ClusterNode,Collection<K>> |
GridAffinityProcessor.mapKeysToNodes(String cacheName,
@Nullable Collection<? extends K> keys)
Maps keys to nodes for given cache.
|
<K> List<ClusterNode> |
GridAffinityProcessor.mapKeyToPrimaryAndBackups(String cacheName,
K key,
AffinityTopologyVersion topVer)
Map single key to primary and backup nodes.
|
Set<ClusterNode> |
GridAffinityAssignmentV2.nodes() |
Set<ClusterNode> |
HistoryAffinityAssignmentImpl.nodes() |
Set<ClusterNode> |
GridAffinityAssignment.nodes()
Deprecated.
|
Set<ClusterNode> |
AffinityAssignment.nodes() |
Set<ClusterNode> |
HistoryAffinityAssignmentShallowCopy.nodes() |
List<ClusterNode> |
GridAffinityAssignmentCache.nodes(int part,
AffinityTopologyVersion topVer)
Gets affinity nodes for specified partition.
|
List<List<ClusterNode>> |
GridAffinityFunctionContextImpl.prevAssignment()
Gets the previous assignment.
|
Set<ClusterNode> |
GridAffinityAssignmentV2.primaryPartitionNodes() |
Set<ClusterNode> |
HistoryAffinityAssignmentImpl.primaryPartitionNodes() |
Set<ClusterNode> |
GridAffinityAssignment.primaryPartitionNodes()
Deprecated.
|
Set<ClusterNode> |
AffinityAssignment.primaryPartitionNodes() |
Set<ClusterNode> |
HistoryAffinityAssignmentShallowCopy.primaryPartitionNodes() |
List<List<ClusterNode>> |
GridAffinityAssignmentCache.readyAssignments(AffinityTopologyVersion topVer) |
| Modifier and Type | Method and Description |
|---|---|
Set<Integer> |
IdealAffinityAssignment.idealPrimaries(ClusterNode clusterNode) |
| Modifier and Type | Method and Description |
|---|---|
default Collection<UUID> |
AffinityAssignment.assignments2ids(List<ClusterNode> assignmentPart)
Converts List of Cluster Nodes to HashSet of UUIDs wrapped as unmodifiable collection.
|
static Map<Object,Set<Integer>> |
IdealAffinityAssignment.calculatePrimaries(@Nullable List<ClusterNode> nodes,
List<List<ClusterNode>> assignment) |
static IdealAffinityAssignment |
IdealAffinityAssignment.create(AffinityTopologyVersion topVer,
@Nullable List<ClusterNode> nodes,
List<List<ClusterNode>> assignment) |
static IdealAffinityAssignment |
IdealAffinityAssignment.create(AffinityTopologyVersion topVer,
List<List<ClusterNode>> assignment) |
static IdealAffinityAssignment |
IdealAffinityAssignment.createWithPreservedPrimaries(AffinityTopologyVersion topVer,
List<List<ClusterNode>> assignment,
IdealAffinityAssignment previousAssignment) |
void |
GridAffinityAssignmentCache.idealAssignment(AffinityTopologyVersion topVer,
List<List<ClusterNode>> assignment) |
void |
GridAffinityAssignmentCache.initialize(AffinityTopologyVersion topVer,
List<List<ClusterNode>> affAssignment)
Initializes affinity with given topology version and assignment.
|
Object |
GridAffinityProcessor.similaryAffinityKey(AffinityFunction aff,
IgnitePredicate<ClusterNode> nodeFilter,
int backups,
int parts) |
| Constructor and Description |
|---|
GridAffinityAssignmentV2(AffinityTopologyVersion topVer,
List<List<ClusterNode>> assignment,
List<List<ClusterNode>> idealAssignment) |
GridAffinityAssignmentV2(AffinityTopologyVersion topVer,
List<List<ClusterNode>> assignment,
List<List<ClusterNode>> idealAssignment) |
GridAffinityFunctionContextImpl(List<ClusterNode> topSnapshot,
List<List<ClusterNode>> prevAssignment,
DiscoveryEvent discoEvt,
@NotNull AffinityTopologyVersion topVer,
int backups) |
GridAffinityFunctionContextImpl(List<ClusterNode> topSnapshot,
List<List<ClusterNode>> prevAssignment,
DiscoveryEvent discoEvt,
@NotNull AffinityTopologyVersion topVer,
int backups) |
| Modifier and Type | Method and Description |
|---|---|
SecurityContext |
IgniteAuthenticationProcessor.authenticateNode(ClusterNode node,
SecurityCredentials cred)
Authenticates grid node with it's attributes via underlying Authenticator.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
GridCacheContext.localNode() |
ClusterNode |
GridCacheSharedContext.localNode() |
ClusterNode |
WalStateNodeLeaveExchangeTask.node() |
@Nullable ClusterNode |
GridCacheContext.node(UUID nodeId) |
@Nullable ClusterNode |
GridCacheSharedContext.node(UUID nodeId) |
static @Nullable ClusterNode |
GridCacheUtils.oldest(Collection<ClusterNode> nodes) |
static ClusterNode |
GridCacheUtils.primary(Iterable<? extends ClusterNode> nodes) |
@Nullable ClusterNode |
GridCacheAffinityManager.primaryByKey(Object key,
AffinityTopologyVersion topVer) |
@Nullable ClusterNode |
GridCacheAffinityManager.primaryByPartition(int part,
AffinityTopologyVersion topVer) |
@Nullable ClusterNode |
GridCacheContext.selectAffinityNodeBalanced(List<ClusterNode> affNodes,
Set<ClusterNode> invalidNodes,
int partId,
boolean canRemap,
boolean forcePrimary)
Determines an affinity node to send get request to.
|
| Modifier and Type | Method and Description |
|---|---|
void |
CacheGroupContext.addRebalanceEvent(int part,
int type,
ClusterNode discoNode,
int discoType,
long discoTs)
Adds rebalancing event.
|
static boolean |
GridCacheUtils.affinityNode(ClusterNode node,
IgnitePredicate<ClusterNode> filter) |
boolean |
GridCacheAffinityManager.backupByPartition(ClusterNode n,
int part,
AffinityTopologyVersion topVer) |
static boolean |
GridCacheUtils.baselineNode(ClusterNode node,
DiscoveryDataClusterState discoveryDataClusterState) |
static @Nullable DataStorageConfiguration |
GridCacheUtils.extractDataStorage(ClusterNode node,
JdkMarshaller marshaller,
ClassLoader clsLdr)
Extract and unmarshal data storage configuration from given node.
|
static @Nullable DataRegionConfiguration |
GridCacheUtils.findRemoteDataRegionConfiguration(ClusterNode node,
JdkMarshaller marshaller,
ClassLoader clsLdr,
@Nullable String name)
Finds and returns a data region configuration with the specified name that is configured on remote node.
|
boolean |
GridCacheProcessor.hasCachesReceivedFromJoin(ClusterNode node) |
boolean |
GridCacheContext.isLocalNode(ClusterNode n) |
boolean |
ClusterCachesInfo.isMergeConfigSupports(ClusterNode joiningNode) |
void |
ClusterCachesInfo.onClientCacheChange(ClientCacheChangeDiscoveryMessage msg,
ClusterNode node) |
boolean |
GridCacheProcessor.onCustomEvent(DiscoveryCustomMessage msg,
AffinityTopologyVersion topVer,
ClusterNode node)
Callback invoked from discovery thread when discovery custom message is received.
|
void |
ClusterCachesInfo.onDiscoveryEvent(int type,
ClusterNode node,
AffinityTopologyVersion topVer)
Discovery event callback, executed from discovery thread.
|
void |
GridCacheProcessor.onDiscoveryEvent(int type,
@Nullable DiscoveryCustomMessage customMsg,
ClusterNode node,
AffinityTopologyVersion topVer,
DiscoveryDataClusterState state) |
boolean |
GridCacheAffinityManager.partitionBelongs(ClusterNode node,
int part,
AffinityTopologyVersion topVer) |
IgniteInternalFuture<?> |
GridCacheSharedContext.partitionRecoveryFuture(AffinityTopologyVersion topVer,
ClusterNode node)
Captures all prepared operations that we need to wait before we able to perform PME-free switch.
|
boolean |
GridCacheAffinityManager.primaryByKey(ClusterNode n,
Object key,
AffinityTopologyVersion topVer) |
boolean |
GridCacheAffinityManager.primaryByPartition(ClusterNode n,
int part,
AffinityTopologyVersion topVer) |
void |
GridCachePartitionExchangeManager.processFullPartitionUpdate(ClusterNode node,
GridDhtPartitionsFullMessage msg) |
void |
GridCacheMvccCandidate.removeMappedNode(ClusterNode node) |
void |
GridCacheIoManager.send(ClusterNode node,
GridCacheMessage msg,
byte plc)
Sends communication message.
|
void |
GridCacheIoManager.sendOrderedMessage(ClusterNode node,
Object topic,
GridCacheMessage msg,
byte plc,
long timeout) |
@Nullable IgniteNodeValidationResult |
GridCacheProcessor.validateNode(ClusterNode node)
Validates that new node can join grid topology, this method is called on coordinator
node before new node joins topology.
|
@Nullable IgniteNodeValidationResult |
GridCacheProcessor.validateNode(ClusterNode node,
DiscoveryDataBag.JoiningNodeDiscoveryData discoData)
Validates that new node can join grid topology, this method is called on coordinator
node before new node joins topology.
|
| Modifier and Type | Method and Description |
|---|---|
void |
CacheAffinitySharedManager.addToWaitGroup(int grpId,
int part,
AffinityTopologyVersion topVer,
List<ClusterNode> assignment)
Adds group partition to wait list.
|
static boolean |
GridCacheUtils.affinityNode(ClusterNode node,
IgnitePredicate<ClusterNode> filter) |
static Collection<ClusterNode> |
GridCacheUtils.backups(Collection<ClusterNode> nodes) |
void |
GridCacheContext.dhtMap(GridDhtCacheEntry entry,
GridCacheVersion explicitLockVer,
IgniteLogger log,
Map<ClusterNode,List<GridDhtCacheEntry>> dhtMap,
Map<ClusterNode,List<GridDhtCacheEntry>> nearMap) |
void |
GridCacheContext.dhtMap(GridDhtCacheEntry entry,
GridCacheVersion explicitLockVer,
IgniteLogger log,
Map<ClusterNode,List<GridDhtCacheEntry>> dhtMap,
Map<ClusterNode,List<GridDhtCacheEntry>> nearMap) |
void |
GridCacheContext.dhtMap(UUID nearNodeId,
AffinityTopologyVersion topVer,
GridDhtCacheEntry entry,
GridCacheVersion explicitLockVer,
IgniteLogger log,
Map<ClusterNode,List<GridDhtCacheEntry>> dhtMap,
@Nullable Map<ClusterNode,List<GridDhtCacheEntry>> nearMap) |
static boolean |
GridCacheUtils.isInMemoryCluster(Collection<ClusterNode> nodes,
JdkMarshaller marshaller,
ClassLoader clsLdr) |
void |
GridCacheMvccCandidate.mappedNodeIds(Collection<ClusterNode> mappedDhtNodes,
Collection<ClusterNode> mappedNearNodes) |
void |
GridCacheMvccCandidate.mappedNodeIds(Collection<ClusterNode> mappedDhtNodes,
Collection<ClusterNode> mappedNearNodes) |
static Map<UUID,Collection<ClusterNode>> |
GridCacheUtils.neighbors(Collection<ClusterNode> topSnapshot)
Builds neighborhood map for all nodes in snapshot.
|
static Collection<ClusterNode> |
GridCacheUtils.neighborsForNodes(Map<UUID,Collection<ClusterNode>> neighborhood,
Iterable<ClusterNode> nodes)
Returns neighbors for all
nodes. |
static Collection<ClusterNode> |
GridCacheUtils.neighborsForNodes(Map<UUID,Collection<ClusterNode>> neighborhood,
Iterable<ClusterNode> nodes)
Returns neighbors for all
nodes. |
static @Nullable ClusterNode |
GridCacheUtils.oldest(Collection<ClusterNode> nodes) |
static ClusterNode |
GridCacheUtils.primary(Iterable<? extends ClusterNode> nodes) |
@Nullable ClusterNode |
GridCacheContext.selectAffinityNodeBalanced(List<ClusterNode> affNodes,
Set<ClusterNode> invalidNodes,
int partId,
boolean canRemap,
boolean forcePrimary)
Determines an affinity node to send get request to.
|
@Nullable ClusterNode |
GridCacheContext.selectAffinityNodeBalanced(List<ClusterNode> affNodes,
Set<ClusterNode> invalidNodes,
int partId,
boolean canRemap,
boolean forcePrimary)
Determines an affinity node to send get request to.
|
| Constructor and Description |
|---|
DynamicCacheChangeFailureMessage(ClusterNode locNode,
GridDhtPartitionExchangeId exchId,
IgniteCheckedException cause,
Collection<String> cacheNames)
Creates new DynamicCacheChangeFailureMessage instance.
|
WalStateNodeLeaveExchangeTask(SecurityContext secCtx,
ClusterNode node)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable ClusterNode |
GridCacheAffinityProxy.mapKeyToNode(K key)
This method provides ability to detect to which primary node the given key
is mapped.
|
@Nullable ClusterNode |
GridCacheAffinityImpl.mapKeyToNode(K key)
This method provides ability to detect to which primary node the given key
is mapped.
|
ClusterNode |
GridCacheAffinityProxy.mapPartitionToNode(int part)
Gets primary node for the given partition.
|
ClusterNode |
GridCacheAffinityImpl.mapPartitionToNode(int part)
Gets primary node for the given partition.
|
| Modifier and Type | Method and Description |
|---|---|
Map<ClusterNode,Collection<K>> |
GridCacheAffinityProxy.mapKeysToNodes(@Nullable Collection<? extends K> keys)
This method provides ability to detect which keys are mapped to which nodes.
|
Map<ClusterNode,Collection<K>> |
GridCacheAffinityImpl.mapKeysToNodes(@Nullable Collection<? extends K> keys)
This method provides ability to detect which keys are mapped to which nodes.
|
Collection<ClusterNode> |
GridCacheAffinityProxy.mapKeyToPrimaryAndBackups(K key)
Gets primary and backup nodes for the key.
|
Collection<ClusterNode> |
GridCacheAffinityImpl.mapKeyToPrimaryAndBackups(K key)
Gets primary and backup nodes for the key.
|
Map<Integer,ClusterNode> |
GridCacheAffinityProxy.mapPartitionsToNodes(Collection<Integer> parts)
Gets primary nodes for the given partitions.
|
Map<Integer,ClusterNode> |
GridCacheAffinityImpl.mapPartitionsToNodes(Collection<Integer> parts)
Gets primary nodes for the given partitions.
|
Collection<ClusterNode> |
GridCacheAffinityProxy.mapPartitionToPrimaryAndBackups(int part)
Gets primary and backup nodes for partition.
|
Collection<ClusterNode> |
GridCacheAffinityImpl.mapPartitionToPrimaryAndBackups(int part)
Gets primary and backup nodes for partition.
|
| Modifier and Type | Method and Description |
|---|---|
int[] |
GridCacheAffinityProxy.allPartitions(ClusterNode n)
Gets partition ids for which given cluster node has any ownership
(either primary or backup).
|
int[] |
GridCacheAffinityImpl.allPartitions(ClusterNode n)
Gets partition ids for which given cluster node has any ownership
(either primary or backup).
|
int[] |
GridCacheAffinityProxy.backupPartitions(ClusterNode n)
Gets partition ids for which given cluster node has backup ownership.
|
int[] |
GridCacheAffinityImpl.backupPartitions(ClusterNode n)
Gets partition ids for which given cluster node has backup ownership.
|
boolean |
GridCacheAffinityProxy.isBackup(ClusterNode n,
K key)
Returns
true if local node is one of the backup nodes for given key. |
boolean |
GridCacheAffinityImpl.isBackup(ClusterNode n,
K key)
Returns
true if local node is one of the backup nodes for given key. |
boolean |
GridCacheAffinityProxy.isPrimary(ClusterNode n,
K key)
Returns
true if given node is the primary node for given key. |
boolean |
GridCacheAffinityImpl.isPrimary(ClusterNode n,
K key)
Returns
true if given node is the primary node for given key. |
boolean |
GridCacheAffinityProxy.isPrimaryOrBackup(ClusterNode n,
K key)
Returns
true if local node is primary or one of the backup nodes
This method is essentially equivalent to calling
"Affinity.isPrimary(ClusterNode, Object) || Affinity.isBackup(ClusterNode, Object))",
however it is more efficient as it makes both checks at once. |
boolean |
GridCacheAffinityImpl.isPrimaryOrBackup(ClusterNode n,
K key)
Returns
true if local node is primary or one of the backup nodes
This method is essentially equivalent to calling
"Affinity.isPrimary(ClusterNode, Object) || Affinity.isBackup(ClusterNode, Object))",
however it is more efficient as it makes both checks at once. |
int[] |
GridCacheAffinityProxy.primaryPartitions(ClusterNode n)
Gets partition ids for which the given cluster node has primary ownership.
|
int[] |
GridCacheAffinityImpl.primaryPartitions(ClusterNode n)
Gets partition ids for which the given cluster node has primary ownership.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable IgniteNodeValidationResult |
CacheObjectBinaryProcessorImpl.validateNode(ClusterNode rmtNode,
DiscoveryDataBag.JoiningNodeDiscoveryData discoData)
Validates that new node can join grid topology, this method is called on coordinator
node before new node joins topology.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
GridDistributedTxMapping.primary() |
| Constructor and Description |
|---|
GridDistributedTxMapping(ClusterNode primary) |
| Modifier and Type | Field and Description |
|---|---|
protected ClusterNode |
GridPartitionedGetFuture.affNode
Explicit predefined single mapping (backup or primary).
|
protected ClusterNode |
CacheDistributedGetFutureAdapter.AbstractMiniFuture.node
Mapped node.
|
| Modifier and Type | Field and Description |
|---|---|
protected Map<AffinityTopologyVersion,Map<Integer,Set<ClusterNode>>> |
CacheDistributedGetFutureAdapter.invalidNodes |
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
GridPartitionedGetFuture.affNode()
Explicit predefined single mapping (backup or primary).
|
ClusterNode |
CacheDistributedGetFutureAdapter.AbstractMiniFuture.node() |
| Modifier and Type | Method and Description |
|---|---|
List<List<ClusterNode>> |
GridDhtAffinityAssignmentResponse.affinityAssignment(DiscoCache discoCache) |
protected Set<ClusterNode> |
GridPartitionedSingleGetFuture.getInvalidNodes() |
protected Set<ClusterNode> |
CacheDistributedGetFutureAdapter.getInvalidNodes(int part,
AffinityTopologyVersion topVer) |
List<List<ClusterNode>> |
GridDhtAffinityAssignmentResponse.idealAffinityAssignment(DiscoCache discoCache) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
CacheDistributedGetFutureAdapter.addNodeAsInvalid(ClusterNode node,
int part,
AffinityTopologyVersion topVer) |
protected boolean |
CacheDistributedGetFutureAdapter.checkRetryPermits(KeyCacheObject key,
ClusterNode node,
Map<ClusterNode,LinkedHashMap<KeyCacheObject,Boolean>> missedNodesToKeysMapping) |
GridDhtTxLocal |
GridDhtTransactionalCacheAdapter.initTxTopologyVersion(UUID nodeId,
ClusterNode nearNode,
GridCacheVersion nearLockVer,
IgniteUuid nearFutId,
int nearMiniId,
boolean firstClientReq,
AffinityTopologyVersion topVer,
long nearThreadId,
long timeout,
int txTaskNameHash,
MvccSnapshot snapshot) |
IgniteInternalFuture<GridNearLockResponse> |
GridDhtTransactionalCacheAdapter.lockAllAsync(GridCacheContext<?,?> cacheCtx,
ClusterNode nearNode,
GridNearLockRequest req,
@Nullable CacheEntryPredicate[] filter0) |
protected abstract void |
GridDhtCacheAdapter.MessageHandler.onMessage(ClusterNode node,
M msg) |
protected void |
GridDhtCacheAdapter.processForceKeyResponse(ClusterNode node,
GridDhtForceKeysResponse msg) |
protected void |
GridDhtCacheAdapter.processForceKeysRequest(ClusterNode node,
GridDhtForceKeysRequest msg) |
void |
GridDhtCacheEntry.removeMapping(GridCacheVersion ver,
ClusterNode mappedNode) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtTxMapping.addMapping(List<ClusterNode> nodes)
Adds information about next mapping.
|
protected boolean |
CacheDistributedGetFutureAdapter.checkRetryPermits(KeyCacheObject key,
ClusterNode node,
Map<ClusterNode,LinkedHashMap<KeyCacheObject,Boolean>> missedNodesToKeysMapping) |
void |
GridDhtAffinityAssignmentResponse.idealAffinityAssignment(List<List<ClusterNode>> idealAffAssignment) |
protected void |
GridPartitionedGetFuture.map(Collection<KeyCacheObject> keys,
Map<ClusterNode,LinkedHashMap<KeyCacheObject,Boolean>> mapped,
AffinityTopologyVersion topVer) |
protected abstract void |
CacheDistributedGetFutureAdapter.map(Collection<KeyCacheObject> keys,
Map<ClusterNode,LinkedHashMap<KeyCacheObject,Boolean>> mapped,
AffinityTopologyVersion topVer) |
@Nullable GridCacheMvccCandidate |
GridDhtCacheEntry.mappings(GridCacheVersion ver,
Collection<ClusterNode> dhtNodeIds,
Collection<ClusterNode> nearNodeIds)
Sets mappings into entry.
|
@Nullable GridCacheMvccCandidate |
GridDhtCacheEntry.mappings(GridCacheVersion ver,
Collection<ClusterNode> dhtNodeIds,
Collection<ClusterNode> nearNodeIds)
Sets mappings into entry.
|
protected GridDhtTopologyFutureAdapter.CacheGroupValidation |
GridDhtTopologyFutureAdapter.validateCacheGroup(CacheGroupContext grp,
Collection<ClusterNode> topNodes) |
| Constructor and Description |
|---|
AbstractMiniFuture(ClusterNode node,
LinkedHashMap<KeyCacheObject,Boolean> keys,
AffinityTopologyVersion topVer) |
GridPartitionedGetFuture(GridCacheContext<K,V> cctx,
Collection<KeyCacheObject> keys,
boolean readThrough,
boolean forcePrimary,
String taskName,
boolean deserializeBinary,
boolean recovery,
@Nullable IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals,
boolean needVer,
boolean keepCacheObjects,
@Nullable String txLbl,
@Nullable MvccSnapshot mvccSnapshot,
ClusterNode affNode) |
| Constructor and Description |
|---|
GridDhtAffinityAssignmentResponse(long futId,
int grpId,
@NotNull AffinityTopologyVersion topVer,
List<List<ClusterNode>> affAssignment) |
| Modifier and Type | Method and Description |
|---|---|
protected abstract void |
GridDhtAtomicAbstractUpdateFuture.addDhtKey(KeyCacheObject key,
List<ClusterNode> dhtNodes) |
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
GridDhtPartitionExchangeId.eventNode() |
ClusterNode |
GridDhtPreloaderAssignments.supplier(int part)
Gets a supplier node for a partition.
|
| Modifier and Type | Method and Description |
|---|---|
List<List<ClusterNode>> |
CacheGroupAffinityMessage.createAssignments(Map<Long,ClusterNode> nodesByOrder,
DiscoCache discoCache) |
static List<ClusterNode> |
CacheGroupAffinityMessage.toNodes(GridLongList assign,
Map<Long,ClusterNode> nodesByOrder,
DiscoCache discoCache) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridDhtPartitionsExchangeFuture.addOrMergeDelayedFullMessage(ClusterNode node,
GridDhtPartitionsFullMessage fullMsg)
Add or merge updates received from coordinator while exchange in progress.
|
boolean |
GridDhtPartitionsExchangeFuture.fastReplyOnSingleMessage(ClusterNode node,
GridDhtPartitionsSingleMessage msg)
Tries to fast reply with
GridDhtPartitionsFullMessage on received single message in case of exchange
future has already completed. |
void |
GridDhtPartitionsExchangeFuture.forceClientReconnect(ClusterNode node,
GridDhtPartitionsSingleMessage msg)
Method is called on coordinator in situation when initial ExchangeFuture created on client join event was
preempted from exchange history because of IGNITE_EXCHANGE_HISTORY_SIZE property.
|
void |
GridDhtPartitionsExchangeFuture.onAffinityChangeMessage(ClusterNode node,
CacheAffinityChangeMessage msg)
Affinity change message callback, processed from the same thread as
GridDhtPartitionsExchangeFuture.onNodeLeft(org.apache.ignite.cluster.ClusterNode). |
void |
GridDhtPartitionsExchangeFuture.onDynamicCacheChangeFail(ClusterNode node,
DynamicCacheChangeFailureMessage msg)
Cache change failure message callback, processed from the discovery thread.
|
void |
InitNewCoordinatorFuture.onMessage(ClusterNode node,
GridDhtPartitionsSingleMessage msg) |
void |
GridDhtPartitionsExchangeFuture.onNodeLeft(ClusterNode node)
Node left callback, processed from the same thread as
GridDhtPartitionsExchangeFuture.onAffinityChangeMessage(org.apache.ignite.cluster.ClusterNode, org.apache.ignite.internal.processors.cache.CacheAffinityChangeMessage). |
void |
GridDhtPartitionsExchangeFuture.onReceiveFullMessage(ClusterNode node,
GridDhtPartitionsFullMessage msg) |
void |
GridDhtPartitionsExchangeFuture.onReceivePartitionRequest(ClusterNode node,
GridDhtPartitionsSingleRequest msg) |
void |
GridDhtPartitionsExchangeFuture.onReceiveSingleMessage(ClusterNode node,
GridDhtPartitionsSingleMessage msg)
Processing of received single message.
|
| Modifier and Type | Method and Description |
|---|---|
List<List<ClusterNode>> |
CacheGroupAffinityMessage.createAssignments(Map<Long,ClusterNode> nodesByOrder,
DiscoCache discoCache) |
@Nullable List<List<ClusterNode>> |
CacheGroupAffinityMessage.createIdealAssignments(Map<Long,ClusterNode> nodesByOrder,
DiscoCache discoCache) |
static List<ClusterNode> |
CacheGroupAffinityMessage.toNodes(GridLongList assign,
Map<Long,ClusterNode> nodesByOrder,
DiscoCache discoCache) |
| Modifier and Type | Method and Description |
|---|---|
List<List<ClusterNode>> |
GridDhtPartitionTopology.allOwners() |
List<List<ClusterNode>> |
GridDhtPartitionTopologyImpl.allOwners() |
List<List<ClusterNode>> |
GridClientPartitionTopology.allOwners() |
List<ClusterNode> |
GridDhtPartitionTopology.moving(int p) |
List<ClusterNode> |
GridDhtPartitionTopologyImpl.moving(int p) |
List<ClusterNode> |
GridClientPartitionTopology.moving(int p) |
List<ClusterNode> |
GridDhtPartitionTopology.nodes(int p,
AffinityTopologyVersion topVer) |
List<ClusterNode> |
GridDhtPartitionTopologyImpl.nodes(int p,
AffinityTopologyVersion topVer) |
List<ClusterNode> |
GridClientPartitionTopology.nodes(int p,
AffinityTopologyVersion topVer) |
List<ClusterNode> |
GridDhtPartitionTopology.owners(int p) |
List<ClusterNode> |
GridDhtPartitionTopologyImpl.owners(int p) |
List<ClusterNode> |
GridClientPartitionTopology.owners(int p) |
List<ClusterNode> |
GridDhtPartitionTopology.owners(int p,
AffinityTopologyVersion topVer) |
List<ClusterNode> |
GridDhtPartitionTopologyImpl.owners(int p,
AffinityTopologyVersion topVer) |
List<ClusterNode> |
GridClientPartitionTopology.owners(int p,
AffinityTopologyVersion topVer) |
| Modifier and Type | Method and Description |
|---|---|
@Nullable List<ClusterNode> |
GridDhtPartitionTopology.nodes(int p,
AffinityAssignment affAssignment,
List<ClusterNode> affNodes) |
@Nullable List<ClusterNode> |
GridDhtPartitionTopologyImpl.nodes(int p,
AffinityAssignment affAssignment,
List<ClusterNode> affNodes) |
@Nullable List<ClusterNode> |
GridClientPartitionTopology.nodes(int p,
AffinityAssignment affAssignment,
List<ClusterNode> affNodes) |
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
GridNearLockMapping.node() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridNearTxLocal.addKeyMapping(IgniteTxKey key,
ClusterNode node)
Adds key mapping to dht mapping.
|
protected void |
GridNearTxAbstractEnlistFuture.updateMappings(ClusterNode node) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
GridNearGetFuture.map(Collection<KeyCacheObject> keys,
Map<ClusterNode,LinkedHashMap<KeyCacheObject,Boolean>> mapped,
AffinityTopologyVersion topVer) |
| Constructor and Description |
|---|
GridNearLockMapping(ClusterNode node,
KeyCacheObject firstKey)
Creates near lock mapping for specified node and key.
|
| Modifier and Type | Field and Description |
|---|---|
protected Map<ClusterNode,GridPartitionedGetFuture<KeyCacheObject,EntryGetResult>> |
GridNearReadRepairAbstractFuture.futs
Affinity node's get futures.
|
protected Map<KeyCacheObject,ClusterNode> |
GridNearReadRepairAbstractFuture.primaries
Primaries per key.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable IgniteNodeValidationResult |
MvccProcessorImpl.validateNode(ClusterNode node)
Validates that new node can join grid topology, this method is called on coordinator
node before new node joins topology.
|
| Modifier and Type | Field and Description |
|---|---|
protected Map<ClusterNode,List<SnapshotMetadata>> |
AbstractSnapshotVerificationTask.metas
Map of snapshot metadata information found on each cluster node.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
SnapshotHandlerContext.localNode() |
ClusterNode |
SnapshotHandlerResult.node() |
| Modifier and Type | Method and Description |
|---|---|
Map<ClusterNode,List<SnapshotMetadata>> |
SnapshotPartitionsVerifyTaskArg.clusterMetadata() |
Map<ClusterNode,Exception> |
IgniteSnapshotVerifyException.exceptions() |
Map<ClusterNode,Exception> |
SnapshotPartitionsVerifyTaskResult.exceptions() |
Map<ClusterNode,Exception> |
SnapshotMetadataVerificationTaskResult.exceptions() |
Map<ComputeJob,ClusterNode> |
AbstractSnapshotVerificationTask.map(List<ClusterNode> subgrid,
SnapshotPartitionsVerifyTaskArg arg)
This method is called to map or split grid task into multiple grid jobs.
|
Map<ClusterNode,List<SnapshotMetadata>> |
SnapshotMetadataVerificationTaskResult.meta() |
Map<ClusterNode,List<SnapshotMetadata>> |
SnapshotPartitionsVerifyTaskResult.metas() |
| Modifier and Type | Method and Description |
|---|---|
@NotNull Map<? extends ComputeJob,ClusterNode> |
SnapshotMetadataVerificationTask.map(List<ClusterNode> subgrid,
SnapshotMetadataVerificationTaskArg arg)
This method is called to map or split grid task into multiple grid jobs.
|
Map<ComputeJob,ClusterNode> |
AbstractSnapshotVerificationTask.map(List<ClusterNode> subgrid,
SnapshotPartitionsVerifyTaskArg arg)
This method is called to map or split grid task into multiple grid jobs.
|
| Constructor and Description |
|---|
SnapshotHandlerContext(SnapshotMetadata metadata,
@Nullable Collection<String> grps,
ClusterNode locNode,
File snpDir,
boolean streamerWrn,
boolean check) |
SnapshotHandlerResult(T data,
@Nullable Exception err,
ClusterNode node) |
| Constructor and Description |
|---|
IgniteSnapshotVerifyException(Map<ClusterNode,? extends Exception> map) |
SnapshotMetadataVerificationTaskResult(Map<ClusterNode,List<SnapshotMetadata>> meta,
Map<ClusterNode,Exception> exceptions) |
SnapshotMetadataVerificationTaskResult(Map<ClusterNode,List<SnapshotMetadata>> meta,
Map<ClusterNode,Exception> exceptions) |
SnapshotPartitionsVerifyTaskArg(Collection<String> grpNames,
Map<ClusterNode,List<SnapshotMetadata>> clusterMetas,
@Nullable String snpPath,
int incIdx,
boolean check) |
SnapshotPartitionsVerifyTaskResult(Map<ClusterNode,List<SnapshotMetadata>> metas,
@Nullable IdleVerifyResultV2 idleRes) |
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
StandaloneNoopDiscoverySpi.getLocalNode()
Gets local node.
|
@Nullable ClusterNode |
StandaloneNoopDiscoverySpi.getNode(UUID nodeId)
Gets node by ID.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<ClusterNode> |
StandaloneNoopDiscoverySpi.getRemoteNodes()
Gets collection of remote nodes in grid or empty collection if no remote nodes found.
|
| Modifier and Type | Method and Description |
|---|---|
void |
StandaloneNoopCommunicationSpi.sendMessage(ClusterNode destNode,
Serializable msg)
Sends given message to destination node.
|
| Modifier and Type | Method and Description |
|---|---|
abstract CacheQueryFuture<?> |
GridCacheQueryManager.queryDistributed(GridCacheQueryBean qry,
Collection<ClusterNode> nodes)
Executes distributed query.
|
CacheQueryFuture<?> |
GridCacheDistributedQueryManager.queryDistributed(GridCacheQueryBean qry,
Collection<ClusterNode> nodes)
Executes distributed query.
|
abstract CacheQueryFuture<?> |
GridCacheQueryManager.queryFieldsDistributed(GridCacheQueryBean qry,
Collection<ClusterNode> nodes)
Executes distributed fields query.
|
CacheQueryFuture<?> |
GridCacheDistributedQueryManager.queryFieldsDistributed(GridCacheQueryBean qry,
Collection<ClusterNode> nodes)
Executes distributed fields query.
|
abstract GridCloseableIterator |
GridCacheQueryManager.scanQueryDistributed(GridCacheQueryAdapter qry,
Collection<ClusterNode> nodes)
Executes distributed SCAN query.
|
GridCloseableIterator |
GridCacheDistributedQueryManager.scanQueryDistributed(GridCacheQueryAdapter qry,
Collection<ClusterNode> nodes)
Executes distributed SCAN query.
|
| Constructor and Description |
|---|
GridCacheDistributedFieldsQueryFuture(GridCacheContext<?,?> ctx,
long reqId,
GridCacheQueryBean qry,
Collection<ClusterNode> nodes) |
GridCacheDistributedQueryFuture(GridCacheContext<K,V> ctx,
long reqId,
GridCacheQueryBean qry,
Collection<ClusterNode> nodes) |
| Modifier and Type | Method and Description |
|---|---|
@Nullable List<PartitionUpdateCountersMessage> |
IgniteTxHandler.filterUpdateCountersForBackupNode(IgniteInternalTx tx,
ClusterNode node) |
IgniteInternalFuture<Boolean> |
IgniteTxManager.recoverLocalTxs(AffinityTopologyVersion topVer,
ClusterNode node)
Creates a future that will wait for all transactions with failed primary recovery.
|
void |
IgniteTxManager.sendTransactionMessage(ClusterNode n,
GridCacheMessage msg,
IgniteInternalTx tx,
byte plc)
Sends transaction message after transforming it.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
ContentionInfo.getNode() |
| Modifier and Type | Method and Description |
|---|---|
Map<ClusterNode,Exception> |
IdleVerifyResultV2.exceptions() |
| Modifier and Type | Method and Description |
|---|---|
void |
ContentionInfo.setNode(ClusterNode node) |
| Modifier and Type | Method and Description |
|---|---|
@NotNull Map<? extends ComputeJob,ClusterNode> |
RetrieveConflictPartitionValuesTask.map(List<ClusterNode> subgrid,
Map<PartitionHashRecord,List<PartitionEntryHashRecord>> collectTaskRes)
This method is called to map or split grid task into multiple grid jobs.
|
@NotNull Map<? extends ComputeJob,ClusterNode> |
CollectConflictPartitionKeysTask.map(List<ClusterNode> subgrid,
PartitionKey partKey)
This method is called to map or split grid task into multiple grid jobs.
|
@NotNull Map<? extends ComputeJob,ClusterNode> |
VerifyBackupPartitionsTask.map(List<ClusterNode> subgrid,
Set<String> cacheNames)
Deprecated.
This method is called to map or split grid task into multiple grid jobs.
|
@NotNull Map<? extends ComputeJob,ClusterNode> |
VerifyBackupPartitionsDumpTask.map(List<ClusterNode> subgrid,
VisorIdleVerifyTaskArg arg)
This method is called to map or split grid task into multiple grid jobs.
|
@NotNull Map<? extends ComputeJob,ClusterNode> |
VerifyBackupPartitionsTaskV2.map(List<ClusterNode> subgrid,
VisorIdleVerifyTaskArg arg)
This method is called to map or split grid task into multiple grid jobs.
|
| Constructor and Description |
|---|
IdleVerifyResultV2(Map<ClusterNode,Exception> exceptions) |
IdleVerifyResultV2(Map<PartitionKeyV2,List<PartitionHashRecordV2>> clusterHashes,
List<List<TransactionsHashRecord>> txHashConflicts,
Map<ClusterNode,Collection<GridCacheVersion>> partiallyCommittedTxs) |
IdleVerifyResultV2(Map<PartitionKeyV2,List<PartitionHashRecordV2>> clusterHashes,
Map<ClusterNode,Exception> exceptions) |
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
BaselineTopology.baselineNode(Object consId) |
| Modifier and Type | Method and Description |
|---|---|
List<ClusterNode> |
BaselineTopology.createBaselineView(Collection<ClusterNode> aliveNodes,
@Nullable IgnitePredicate<ClusterNode> nodeFilter) |
| Modifier and Type | Method and Description |
|---|---|
@Nullable ChangeGlobalStateFinishMessage |
GridClusterStateProcessor.onNodeLeft(ClusterNode node) |
@Nullable ChangeGlobalStateFinishMessage |
IGridClusterStateProcessor.onNodeLeft(ClusterNode node) |
@Nullable IgniteNodeValidationResult |
GridClusterStateProcessor.validateNode(ClusterNode node)
Validates that new node can join grid topology, this method is called on coordinator
node before new node joins topology.
|
@Nullable IgniteNodeValidationResult |
GridClusterStateProcessor.validateNode(ClusterNode node,
DiscoveryDataBag.JoiningNodeDiscoveryData discoData)
Validates that new node can join grid topology, this method is called on coordinator
node before new node joins topology.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridClusterStateProcessor.autoAdjustInMemoryClusterState(UUID nodeId,
Collection<ClusterNode> topSnapshot,
DiscoCache discoCache,
long topVer,
int minorTopVer)
Update baseline locally if cluster is not persistent and baseline autoadjustment is enabled with zero timeout.
|
List<ClusterNode> |
BaselineTopology.createBaselineView(Collection<ClusterNode> aliveNodes,
@Nullable IgnitePredicate<ClusterNode> nodeFilter) |
| Modifier and Type | Method and Description |
|---|---|
static byte |
DataStreamProcessor.ioPolicy(@Nullable IgniteClosure<ClusterNode,Byte> rslvr,
ClusterNode node)
Get IO policy for particular node with provided resolver.
|
| Modifier and Type | Method and Description |
|---|---|
void |
DataStreamerImpl.ioPolicyResolver(IgniteClosure<ClusterNode,Byte> ioPlcRslvr) |
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
GridJobWorker.getTaskNode() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridJobProcessor.processJobExecuteRequest(ClusterNode node,
GridJobExecuteRequest req) |
| Modifier and Type | Method and Description |
|---|---|
@Nullable IgniteNodeValidationResult |
DistributedMetaStorageImpl.validateNode(ClusterNode node,
DiscoveryDataBag.JoiningNodeDiscoveryData discoData)
Validates that new node can join grid topology, this method is called on coordinator
node before new node joins topology.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable IgniteNodeValidationResult |
OsDiscoveryNodeValidationProcessor.validateNode(ClusterNode node)
Validates that new node can join grid topology, this method is called on coordinator
node before new node joins topology.
|
| Modifier and Type | Method and Description |
|---|---|
void |
PlatformContextImpl.addNode(ClusterNode node)
Sends node info to native platform, if necessary.
|
void |
PlatformContext.addNode(ClusterNode node)
Sends node info to native platform, if necessary.
|
void |
PlatformContextImpl.writeNode(BinaryRawWriterEx writer,
ClusterNode node)
Writes a node id to a stream and sends node info to native platform, if necessary.
|
void |
PlatformContext.writeNode(BinaryRawWriterEx writer,
ClusterNode node)
Writes a node id to a stream and sends node info to native platform, if necessary.
|
| Modifier and Type | Method and Description |
|---|---|
void |
PlatformContextImpl.writeNodes(BinaryRawWriterEx writer,
Collection<ClusterNode> nodes)
Writes multiple node ids to a stream and sends node info to native platform, if necessary.
|
void |
PlatformContext.writeNodes(BinaryRawWriterEx writer,
Collection<ClusterNode> nodes)
Writes multiple node ids to a stream and sends node info to native platform, if necessary.
|
| Modifier and Type | Method and Description |
|---|---|
List<List<ClusterNode>> |
PlatformAffinityFunction.assignPartitions(AffinityFunctionContext affCtx)
Gets affinity nodes for a partition.
|
| Modifier and Type | Method and Description |
|---|---|
static void |
PlatformAffinityUtils.writePartitionAssignment(Collection<List<ClusterNode>> partitions,
BinaryRawWriterEx writer,
PlatformContext ctx)
Writes the partition assignment to a stream.
|
| Constructor and Description |
|---|
ClientClusterGroupGetNodesDetailsResponse(long reqId,
Collection<ClusterNode> nodes)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
PlatformClusterNodeFilterImpl.apply(ClusterNode clusterNode)
Predicate body.
|
| Modifier and Type | Method and Description |
|---|---|
@NotNull Map<? extends ComputeJob,ClusterNode> |
PlatformBalancingMultiClosureTask.map(List<ClusterNode> subgrid,
@Nullable Object arg)
This method is called to map or split grid task into multiple grid jobs.
|
@NotNull Map<? extends ComputeJob,ClusterNode> |
PlatformBalancingSingleClosureTask.map(List<ClusterNode> subgrid,
@Nullable Object arg)
This method is called to map or split grid task into multiple grid jobs.
|
@NotNull Map<? extends ComputeJob,ClusterNode> |
PlatformBroadcastingSingleClosureTask.map(List<ClusterNode> subgrid,
@Nullable Object arg)
This method is called to map or split grid task into multiple grid jobs.
|
@NotNull Map<? extends ComputeJob,ClusterNode> |
PlatformBroadcastingMultiClosureTask.map(List<ClusterNode> subgrid,
@Nullable Object arg)
This method is called to map or split grid task into multiple grid jobs.
|
@NotNull Map<? extends ComputeJob,ClusterNode> |
PlatformFullTask.map(List<ClusterNode> subgrid,
@Nullable Object arg)
This method is called to map or split grid task into multiple grid jobs.
|
| Modifier and Type | Method and Description |
|---|---|
void |
CachePluginManager.validateRemotes(CacheConfiguration rmtCfg,
ClusterNode rmtNode)
Checks that remote caches has configuration compatible with the local.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridQueryProcessor.onNodeLeave(ClusterNode node)
Handle node leave.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
SchemaNodeLeaveExchangeWorkerTask.node() |
| Modifier and Type | Method and Description |
|---|---|
void |
SchemaOperationManager.onNodeLeave(UUID nodeId,
ClusterNode curCrd)
Handle node leave event.
|
| Constructor and Description |
|---|
SchemaNodeLeaveExchangeWorkerTask(SecurityContext secCtx,
ClusterNode node)
Constructor.
|
SchemaOperationManager(GridKernalContext ctx,
GridQueryProcessor qryProc,
SchemaOperationWorker worker,
@Nullable ClusterNode crd)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
static SecurityContext |
SecurityUtils.authenticateLocalNode(ClusterNode node,
SecurityCredentials cred,
DiscoverySpiNodeAuthenticator nodeAuth)
Performs local node authentication.
|
SecurityContext |
IgniteSecurityProcessor.authenticateNode(ClusterNode node,
SecurityCredentials cred)
|
SecurityContext |
IgniteSecurity.authenticateNode(ClusterNode node,
SecurityCredentials cred)
|
SecurityContext |
GridSecurityProcessor.authenticateNode(ClusterNode node,
SecurityCredentials cred)
Authenticates grid node with it's attributes via underlying Authenticator.
|
SecurityContext |
NoOpIgniteSecurityProcessor.authenticateNode(ClusterNode node,
SecurityCredentials cred)
|
static SecurityContext |
SecurityUtils.nodeSecurityContext(Marshaller marsh,
ClassLoader ldr,
ClusterNode node)
Gets the node's security context.
|
@Nullable IgniteNodeValidationResult |
IgniteSecurityProcessor.validateNode(ClusterNode node)
Validates that new node can join grid topology, this method is called on coordinator
node before new node joins topology.
|
@Nullable IgniteNodeValidationResult |
NoOpIgniteSecurityProcessor.validateNode(ClusterNode node)
Validates that new node can join grid topology, this method is called on coordinator
node before new node joins topology.
|
@Nullable IgniteNodeValidationResult |
IgniteSecurityProcessor.validateNode(ClusterNode node,
DiscoveryDataBag.JoiningNodeDiscoveryData discoData)
Validates that new node can join grid topology, this method is called on coordinator
node before new node joins topology.
|
@Nullable IgniteNodeValidationResult |
NoOpIgniteSecurityProcessor.validateNode(ClusterNode node,
DiscoveryDataBag.JoiningNodeDiscoveryData discoData)
Validates that new node can join grid topology, this method is called on coordinator
node before new node joins topology.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable IgniteNodeValidationResult |
IgniteServiceProcessor.validateNode(ClusterNode node,
DiscoveryDataBag.JoiningNodeDiscoveryData data)
Validates that new node can join grid topology, this method is called on coordinator
node before new node joins topology.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<ClusterNode> |
TaskExecutionOptions.projection() |
IgnitePredicate<ClusterNode> |
TaskExecutionOptions.projectionPredicate() |
| Modifier and Type | Method and Description |
|---|---|
static TaskExecutionOptions |
TaskExecutionOptions.options(Collection<ClusterNode> projection) |
TaskExecutionOptions |
TaskExecutionOptions.withProjection(Collection<ClusterNode> projection) |
TaskExecutionOptions |
TaskExecutionOptions.withProjectionPredicate(IgnitePredicate<ClusterNode> projectionPredicate) |
| Modifier and Type | Method and Description |
|---|---|
static ClusterNode |
IgniteUtils.oldest(Collection<ClusterNode> c,
@Nullable IgnitePredicate<ClusterNode> p)
Gets oldest node out of collection of nodes.
|
static ClusterNode |
IgniteUtils.randomServerNode(GridKernalContext ctx) |
static ClusterNode |
IgniteUtils.youngest(Collection<ClusterNode> c,
@Nullable IgnitePredicate<ClusterNode> p)
Gets youngest node out of collection of nodes.
|
| Modifier and Type | Method and Description |
|---|---|
static IgniteClosure<UUID,ClusterNode> |
IgniteUtils.id2Node(GridKernalContext ctx) |
static Map<String,Collection<ClusterNode>> |
IgniteUtils.neighborhood(Iterable<ClusterNode> nodes)
Groups given nodes by the node's physical computer (host).
|
| Modifier and Type | Method and Description |
|---|---|
static String |
IgniteUtils.addressesAsString(ClusterNode node)
Returns string representation of node addresses.
|
static GridCacheAttributes[] |
IgniteUtils.cacheAttributes(ClusterNode n)
Gets cache attributes for the node.
|
static boolean |
IgniteUtils.hasNearCache(ClusterNode n,
String cacheName)
Checks if given node has near cache enabled for the specified
partitioned cache.
|
static double |
IgniteUtils.heapSize(ClusterNode node,
int precision)
Gets heap size in GB rounded to specified precision.
|
static IgniteProductVersion |
IgniteUtils.productVersion(ClusterNode node)
Gets node product version based on node attributes.
|
static boolean |
IgniteUtils.sameMacs(ClusterNode loc,
ClusterNode rmt) |
static Collection<InetAddress> |
IgniteUtils.toInetAddresses(ClusterNode node)
Returns tha list of resolved inet addresses.
|
static String |
IgniteUtils.toShortString(ClusterNode n)
Short node representation.
|
static Collection<InetSocketAddress> |
IgniteUtils.toSocketAddresses(ClusterNode node,
int port)
Returns tha list of resolved socket addresses.
|
| Modifier and Type | Method and Description |
|---|---|
static IgniteFuture<Void> |
IgniteUtils.broadcastToNodesWithFilterAsync(GridKernalContext kctx,
IgniteRunnable job,
boolean srvrsOnly,
IgnitePredicate<ClusterNode> nodeFilter)
Broadcasts given job to nodes that match filter.
|
static double |
IgniteUtils.heapSize(Iterable<ClusterNode> nodes,
int precision)
Gets total heap size in GB rounded to specified precision.
|
static boolean |
IgniteUtils.isOldestNodeVersionAtLeast(IgniteProductVersion ver,
Iterable<ClusterNode> nodes)
Check that node Ignite product version is not less then specified.
|
static Map<String,Collection<ClusterNode>> |
IgniteUtils.neighborhood(Iterable<ClusterNode> nodes)
Groups given nodes by the node's physical computer (host).
|
static double |
IgniteUtils.offheapSize(Iterable<ClusterNode> nodes,
int precision)
Gets total offheap size in GB rounded to specified precision.
|
static ClusterNode |
IgniteUtils.oldest(Collection<ClusterNode> c,
@Nullable IgnitePredicate<ClusterNode> p)
Gets oldest node out of collection of nodes.
|
static String |
IgniteUtils.toShortString(Collection<? extends ClusterNode> ns)
Short node representation.
|
static ClusterNode |
IgniteUtils.youngest(Collection<ClusterNode> c,
@Nullable IgnitePredicate<ClusterNode> p)
Gets youngest node out of collection of nodes.
|
| Modifier and Type | Method and Description |
|---|---|
@NotNull Map<? extends ComputeJob,ClusterNode> |
IgniteRemoteMapTask.map(List<ClusterNode> subgrid,
T arg)
This method is called to map or split grid task into multiple grid jobs.
|
| Constructor and Description |
|---|
IgniteRemoteMapTask(ClusterNode node,
ComputeTask<T,R> remoteTask) |
| Modifier and Type | Method and Description |
|---|---|
static <T extends ClusterNode> |
GridFunc.localNode(UUID locNodeId)
Gets predicate that evaluates to
true only for given local node ID. |
static <T extends ClusterNode> |
GridFunc.nodeForNodeId(UUID nodeId)
Creates grid node predicate evaluating on the given node ID.
|
static <T extends ClusterNode> |
GridFunc.nodeForNodeIds(@Nullable Collection<UUID> nodeIds)
Creates grid node predicate evaluating on the given node IDs.
|
static <T extends ClusterNode> |
GridFunc.remoteNodes(UUID locNodeId)
Gets predicate that evaluates to
false for given local node ID. |
| Modifier and Type | Method and Description |
|---|---|
static IgniteClosure<? super ClusterNode,UUID> |
GridFunc.node2id()
Gets closure which converts node to node ID.
|
static IgnitePredicate<ClusterNode> |
GridFunc.nodeForNodes(ClusterNode... nodes)
Creates predicates that evaluates to
true for each node in given collection. |
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridNodePredicate.apply(ClusterNode n)
Predicate body.
|
static IgnitePredicate<ClusterNode> |
GridFunc.nodeForNodes(ClusterNode... nodes)
Creates predicates that evaluates to
true for each node in given collection. |
| Constructor and Description |
|---|
GridNodePredicate(ClusterNode... nodes)
Creates node predicate that evaluates to
true for all
provided nodes. |
| Modifier and Type | Class and Description |
|---|---|
class |
ContainsNodeIdsPredicate<T extends ClusterNode>
Grid node predicate evaluating on the given node IDs.
|
class |
EqualsClusterNodeIdPredicate<T extends ClusterNode>
Creates grid node predicate evaluating on the given node ID.
|
class |
HasEqualIdPredicate<T extends ClusterNode>
ClusterNode has equal id predicate. |
class |
HasNotEqualIdPredicate<T extends ClusterNode>
ClusterNode node has NOT equal id predicate. |
| Modifier and Type | Method and Description |
|---|---|
boolean |
EqualsClusterNodeIdPredicate.apply(ClusterNode e)
Predicate body.
|
UUID |
ClusterNodeGetIdClosure.apply(ClusterNode n)
Closure body.
|
boolean |
ContainsNodeIdsPredicate.apply(ClusterNode e)
Predicate body.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
GridNioRecoveryDescriptor.node() |
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridNioRecoveryDescriptor.nodeAlive(@Nullable ClusterNode node) |
| Constructor and Description |
|---|
GridNioRecoveryDescriptor(boolean pairedConnections,
int queueLimit,
ClusterNode node,
IgniteLogger log) |
| Modifier and Type | Method and Description |
|---|---|
protected Map<? extends ComputeJob,ClusterNode> |
VisorMultiNodeTask.map0(List<ClusterNode> subgrid,
VisorTaskArgument<A> arg)
Actual map logic.
|
| Modifier and Type | Method and Description |
|---|---|
@NotNull Map<? extends ComputeJob,ClusterNode> |
VisorMultiNodeTask.map(List<ClusterNode> subgrid,
VisorTaskArgument<A> arg)
This method is called to map or split grid task into multiple grid jobs.
|
protected Map<? extends ComputeJob,ClusterNode> |
VisorMultiNodeTask.map0(List<ClusterNode> subgrid,
VisorTaskArgument<A> arg)
Actual map logic.
|
| Constructor and Description |
|---|
VisorClusterNode(ClusterNode node)
Create data transfer object for baseline node.
|
| Modifier and Type | Method and Description |
|---|---|
static void |
VisorTaskUtils.logMapped(@Nullable IgniteLogger log,
Class<?> clazz,
Collection<ClusterNode> nodes)
Log task mapped.
|
| Modifier and Type | Method and Description |
|---|---|
List<List<ClusterNode>> |
PlatformDotNetAffinityFunction.assignPartitions(AffinityFunctionContext affCtx)
Gets affinity nodes for a partition.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
CachePluginContext.localNode()
Gets local grid node.
|
ClusterNode |
PluginContext.localNode()
Gets local grid node.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<ClusterNode> |
PluginContext.nodes()
Gets a collection of all grid nodes.
|
| Modifier and Type | Method and Description |
|---|---|
void |
PluginProvider.validateNewNode(ClusterNode node)
Deprecated.
|
default void |
PluginProvider.validateNewNode(ClusterNode node,
Serializable data)
Validates that new node can join grid topology, this method is called on coordinator
node before new node joins topology.
|
void |
CachePluginProvider.validateRemote(CacheConfiguration locCfg,
CacheConfiguration rmtCfg,
ClusterNode rmtNode)
Checks that remote caches has configuration compatible with the local.
|
| Modifier and Type | Field and Description |
|---|---|
protected IgnitePredicate<ClusterNode> |
ServiceConfiguration.nodeFilter
Node filter.
|
| Modifier and Type | Method and Description |
|---|---|
IgnitePredicate<ClusterNode> |
ServiceConfiguration.getNodeFilter()
Gets node filter used to filter nodes on which the service will be deployed.
|
| Modifier and Type | Method and Description |
|---|---|
ServiceConfiguration |
ServiceConfiguration.setNodeFilter(IgnitePredicate<ClusterNode> nodeFilter)
Sets node filter used to filter nodes on which the service will be deployed.
|
| Modifier and Type | Method and Description |
|---|---|
protected ClusterNode |
IgniteSpiAdapter.getLocalNode() |
ClusterNode |
IgniteSpiContext.localNode()
Gets local grid node.
|
@Nullable ClusterNode |
IgniteSpiContext.node(UUID nodeId)
Gets a node instance based on its ID.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<ClusterNode> |
IgniteSpiContext.nodes()
Gets a collection of all grid nodes.
|
Collection<ClusterNode> |
IgniteSpiContext.remoteNodes()
Gets a collection of remote grid nodes.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
IgniteSpiAdapter.checkConfigurationConsistency0(IgniteSpiContext spiCtx,
ClusterNode node,
boolean starting)
Method which is called in the end of checkConfigurationConsistency() method.
|
void |
IgniteSpiContext.resolveCommunicationFailure(ClusterNode node,
Exception err) |
void |
IgniteSpiContext.send(ClusterNode node,
Serializable msg,
String topic)
Sends a message to a remote node.
|
@Nullable IgniteNodeValidationResult |
IgniteSpiContext.validateNode(ClusterNode node)
Validates that new node can join grid topology, this method is called on coordinator
node before new node joins topology.
|
@Nullable IgniteNodeValidationResult |
IgniteSpiContext.validateNode(ClusterNode node,
DiscoveryDataBag discoData) |
| Modifier and Type | Method and Description |
|---|---|
void |
CommunicationSpi.sendMessage(ClusterNode destNode,
T msg)
Sends given message to destination node.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
TcpCommunicationSpi.checkConfigurationConsistency0(IgniteSpiContext spiCtx,
ClusterNode node,
boolean starting)
Method which is called in the end of checkConfigurationConsistency() method.
|
protected GridCommunicationClient |
TcpCommunicationSpi.createTcpClient(ClusterNode node,
int connIdx)
Establish TCP connection to remote node and returns client.
|
static boolean |
ClientExceptionsUtils.isClientNodeTopologyException(Throwable t,
ClusterNode node)
Returns
true if the exception relates to cluster topology change that prevents a connection, AND the given node is client. |
Collection<InetSocketAddress> |
TcpCommunicationSpi.nodeAddresses(ClusterNode node,
boolean filterReachableAddrs) |
IgniteInternalFuture<Channel> |
TcpCommunicationSpi.openChannel(ClusterNode remote,
Message initMsg) |
protected void |
TcpCommunicationSpi.processSessionCreationError(ClusterNode node,
Collection<InetSocketAddress> addrs,
IgniteCheckedException errs)
Process errors if TCP/IP
GridNioSession creation to remote node hasn't been performed. |
void |
TcpCommunicationSpi.sendMessage(ClusterNode node,
Message msg)
Sends given message to destination node.
|
void |
TcpCommunicationSpi.sendMessage(ClusterNode node,
Message msg,
IgniteInClosure<IgniteException> ackC)
Sends given message to destination node.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteFuture<BitSet> |
TcpCommunicationSpi.checkConnection(List<ClusterNode> nodes) |
| Modifier and Type | Method and Description |
|---|---|
void |
ConnectionClientPool.addNodeClient(ClusterNode node,
int connIdx,
GridCommunicationClient addClient) |
String |
ConnectionClientPool.clientString(GridCommunicationClient client,
ClusterNode node)
Returns the string representation of client with protection from null client value.
|
@Nullable GridCommunicationClient |
ConnectionClientPool.createCommunicationClient(ClusterNode node,
int connIdx) |
GridNioSession |
GridNioServerWrapper.createNioSession(ClusterNode node,
int connIdx)
Deprecated.
Returns the established TCP/IP connection between the current node and remote server.
|
GridCommunicationClient |
GridNioServerWrapper.createTcpClient(ClusterNode node,
int connIdx,
boolean backwardCompatibility)
Deprecated.
Establish TCP connection to remote node and returns client.
|
static void |
CommunicationTcpUtils.failNode(ClusterNode nodeToFail,
IgniteSpiContext spiCtx,
Throwable err,
IgniteLogger log)
Forcibly fails client node.
|
GridNioRecoveryDescriptor |
GridNioServerWrapper.inRecoveryDescriptor(ClusterNode node,
ConnectionKey key)
Deprecated.
|
static Collection<InetSocketAddress> |
CommunicationTcpUtils.nodeAddresses(ClusterNode node,
boolean filterReachableAddrs,
AttributeNames attrs,
Supplier<ClusterNode> localNode) |
IgniteInternalFuture<Channel> |
GridNioServerWrapper.openChannel(ClusterNode remote,
Message initMsg)
Deprecated.
|
void |
GridNioServerWrapper.processSessionCreationError(ClusterNode node,
Collection<InetSocketAddress> addrs,
IgniteCheckedException errs)
Deprecated.
Process errors if TCP/IP
GridNioSession creation to remote node hasn't been performed. |
void |
ConnectionRequestor.request(ClusterNode node,
int connIdx)
Request opening of TCP connection from node
node with index connIdx. |
GridCommunicationClient |
ConnectionClientPool.reserveClient(ClusterNode node,
int connIdx)
Returns existing or just created client to node.
|
static boolean |
CommunicationTcpUtils.usePairedConnections(ClusterNode node,
String attributeName) |
| Modifier and Type | Method and Description |
|---|---|
static Collection<InetSocketAddress> |
CommunicationTcpUtils.nodeAddresses(ClusterNode node,
boolean filterReachableAddrs,
AttributeNames attrs,
Supplier<ClusterNode> localNode) |
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
DiscoverySpi.getLocalNode()
Gets local node.
|
ClusterNode |
DiscoveryNotification.getNode() |
@Nullable ClusterNode |
DiscoverySpi.getNode(UUID nodeId)
Gets node by ID.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<ClusterNode> |
DiscoverySpi.getRemoteNodes()
Gets collection of remote nodes in grid or empty collection if no remote nodes found.
|
Map<Long,Collection<ClusterNode>> |
DiscoveryNotification.getTopHist() |
Collection<ClusterNode> |
DiscoveryNotification.getTopSnapshot() |
| Modifier and Type | Method and Description |
|---|---|
SecurityContext |
DiscoverySpiNodeAuthenticator.authenticateNode(ClusterNode node,
SecurityCredentials cred)
Security credentials.
|
void |
DiscoverySpiListener.onLocalNodeInitialized(ClusterNode locNode)
Notification of local node initialization.
|
| Constructor and Description |
|---|
DiscoveryNotification(int eventType,
long topVer,
ClusterNode node,
Collection<ClusterNode> topSnapshot) |
DiscoveryNotification(int eventType,
long topVer,
ClusterNode node,
Collection<ClusterNode> topSnapshot,
@Nullable Map<Long,Collection<ClusterNode>> topHist,
@Nullable DiscoverySpiCustomMessage customMsgData,
SpanContainer spanContainer) |
| Constructor and Description |
|---|
DiscoveryNotification(int eventType,
long topVer,
ClusterNode node,
Collection<ClusterNode> topSnapshot) |
DiscoveryNotification(int eventType,
long topVer,
ClusterNode node,
Collection<ClusterNode> topSnapshot,
@Nullable Map<Long,Collection<ClusterNode>> topHist,
@Nullable DiscoverySpiCustomMessage customMsgData,
SpanContainer spanContainer) |
| Modifier and Type | Class and Description |
|---|---|
class |
IsolatedNode
Special isolated node.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
IsolatedDiscoverySpi.getLocalNode()
Gets local node.
|
ClusterNode |
IsolatedDiscoverySpi.getNode(UUID nodeId)
Gets node by ID.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<ClusterNode> |
IsolatedDiscoverySpi.getRemoteNodes()
Gets collection of remote nodes in grid or empty collection if no remote nodes found.
|
| Modifier and Type | Method and Description |
|---|---|
void |
IsolatedDiscoverySpi.resolveCommunicationFailure(ClusterNode node,
Exception err) |
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
TcpDiscoverySpi.getLocalNode()
Gets local node.
|
@Nullable ClusterNode |
TcpDiscoverySpi.getNode(UUID nodeId)
Gets node by ID.
|
ClusterNode |
TcpDiscoverySpi.getNode0(UUID id) |
| Modifier and Type | Method and Description |
|---|---|
Collection<ClusterNode> |
TcpDiscoverySpi.getRemoteNodes()
Gets collection of remote nodes in grid or empty collection if no remote nodes found.
|
| Modifier and Type | Method and Description |
|---|---|
void |
TcpDiscoverySpi.resolveCommunicationFailure(ClusterNode node,
Exception err) |
protected void |
TcpDiscoverySpi.writeToSocket(ClusterNode node,
Socket sock,
OutputStream out,
TcpDiscoveryAbstractMessage msg,
long timeout) |
| Modifier and Type | Class and Description |
|---|---|
class |
TcpDiscoveryNode
Node for
TcpDiscoverySpi. |
| Constructor and Description |
|---|
TcpDiscoveryNode(ClusterNode node)
IMPORTANT!
|
| Modifier and Type | Method and Description |
|---|---|
Map<Long,Collection<ClusterNode>> |
TcpDiscoveryNodeAddedMessage.topologyHistory()
Gets topology snapshots history.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
FailoverSpi.failover(FailoverContext ctx,
List<ClusterNode> top)
This method is called when method
ComputeTask.result(org.apache.ignite.compute.ComputeJobResult, List) returns
value ComputeJobResultPolicy.FAILOVER policy indicating that the result of
job execution must be failed over. |
ClusterNode |
FailoverContext.getBalancedNode(List<ClusterNode> top)
Gets the next balanced node for failed job.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
FailoverSpi.failover(FailoverContext ctx,
List<ClusterNode> top)
This method is called when method
ComputeTask.result(org.apache.ignite.compute.ComputeJobResult, List) returns
value ComputeJobResultPolicy.FAILOVER policy indicating that the result of
job execution must be failed over. |
ClusterNode |
FailoverContext.getBalancedNode(List<ClusterNode> top)
Gets the next balanced node for failed job.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
AlwaysFailoverSpi.failover(FailoverContext ctx,
List<ClusterNode> top)
This method is called when method
ComputeTask.result(org.apache.ignite.compute.ComputeJobResult, List) returns
value ComputeJobResultPolicy.FAILOVER policy indicating that the result of
job execution must be failed over. |
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
AlwaysFailoverSpi.failover(FailoverContext ctx,
List<ClusterNode> top)
This method is called when method
ComputeTask.result(org.apache.ignite.compute.ComputeJobResult, List) returns
value ComputeJobResultPolicy.FAILOVER policy indicating that the result of
job execution must be failed over. |
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
JobStealingFailoverSpi.failover(FailoverContext ctx,
List<ClusterNode> top)
This method is called when method
ComputeTask.result(org.apache.ignite.compute.ComputeJobResult, List) returns
value ComputeJobResultPolicy.FAILOVER policy indicating that the result of
job execution must be failed over. |
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
JobStealingFailoverSpi.failover(FailoverContext ctx,
List<ClusterNode> top)
This method is called when method
ComputeTask.result(org.apache.ignite.compute.ComputeJobResult, List) returns
value ComputeJobResultPolicy.FAILOVER policy indicating that the result of
job execution must be failed over. |
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
NeverFailoverSpi.failover(FailoverContext ctx,
List<ClusterNode> top)
This method is called when method
ComputeTask.result(org.apache.ignite.compute.ComputeJobResult, List) returns
value ComputeJobResultPolicy.FAILOVER policy indicating that the result of
job execution must be failed over. |
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
NeverFailoverSpi.failover(FailoverContext ctx,
List<ClusterNode> top)
This method is called when method
ComputeTask.result(org.apache.ignite.compute.ComputeJobResult, List) returns
value ComputeJobResultPolicy.FAILOVER policy indicating that the result of
job execution must be failed over. |
| Constructor and Description |
|---|
IndexingQueryCacheFilter(GridCacheAffinityManager aff,
Set<Integer> parts,
AffinityTopologyVersion topVer,
ClusterNode locNode)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
LoadBalancingSpi.getBalancedNode(ComputeTaskSession ses,
List<ClusterNode> top,
ComputeJob job)
Gets balanced node for specified job within given task session.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
LoadBalancingSpi.getBalancedNode(ComputeTaskSession ses,
List<ClusterNode> top,
ComputeJob job)
Gets balanced node for specified job within given task session.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
AdaptiveLoadBalancingSpi.getBalancedNode(ComputeTaskSession ses,
List<ClusterNode> top,
ComputeJob job)
Gets balanced node for specified job within given task session.
|
| Modifier and Type | Method and Description |
|---|---|
double |
AdaptiveLoadProbe.getLoad(ClusterNode node,
int jobsSentSinceLastUpdate)
Calculates load value for a given node.
|
double |
AdaptiveProcessingTimeLoadProbe.getLoad(ClusterNode node,
int jobsSentSinceLastUpdate)
Calculates load value for a given node.
|
double |
AdaptiveCpuLoadProbe.getLoad(ClusterNode node,
int jobsSentSinceLastUpdate)
Calculates load value for a given node.
|
double |
AdaptiveJobCountLoadProbe.getLoad(ClusterNode node,
int jobsSentSinceLastUpdate)
Calculates load value for a given node.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
AdaptiveLoadBalancingSpi.getBalancedNode(ComputeTaskSession ses,
List<ClusterNode> top,
ComputeJob job)
Gets balanced node for specified job within given task session.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
RoundRobinLoadBalancingSpi.getBalancedNode(ComputeTaskSession ses,
List<ClusterNode> top,
ComputeJob job)
Gets balanced node for specified job within given task session.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
RoundRobinLoadBalancingSpi.getBalancedNode(ComputeTaskSession ses,
List<ClusterNode> top,
ComputeJob job)
Gets balanced node for specified job within given task session.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
WeightedRandomLoadBalancingSpi.getBalancedNode(ComputeTaskSession ses,
List<ClusterNode> top,
ComputeJob job)
Gets balanced node for specified job within given task session.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
WeightedRandomLoadBalancingSpi.getBalancedNode(ComputeTaskSession ses,
List<ClusterNode> top,
ComputeJob job)
Gets balanced node for specified job within given task session.
|
| Constructor and Description |
|---|
ClusterNodeView(ClusterNode n) |
NodeMetricsView(ClusterNode node) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
AttributeNodeFilter.apply(ClusterNode node)
Predicate body.
|
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.15.0 Release Date : April 25 2023