| Package | Description |
|---|---|
| org.apache.ignite.spi.discovery.tcp |
Contains default TCP/IP implementation for discovery SPI.
|
| org.apache.ignite.spi.discovery.tcp.internal |
Contains internal implementation.
|
| org.apache.ignite.spi.discovery.tcp.messages |
Contains implementation messages.
|
| Modifier and Type | Field and Description |
|---|---|
protected TcpDiscoveryNode |
TcpDiscoverySpi.locNode
Local node.
|
| Modifier and Type | Field and Description |
|---|---|
static IgnitePredicate<TcpDiscoveryNode> |
TcpDiscoveryNodesRing.VISIBLE_NODES
Visible nodes filter.
|
| Modifier and Type | Method and Description |
|---|---|
TcpDiscoveryNode |
TcpDiscoveryNode.clientReconnectNode() |
TcpDiscoveryNode |
TcpDiscoveryNodesRing.coordinator()
Finds coordinator in the topology.
|
TcpDiscoveryNode |
TcpDiscoveryNodesRing.coordinator(Collection<TcpDiscoveryNode> excluded)
Finds coordinator in the topology filtering excluded nodes from the search.
|
TcpDiscoveryNode |
TcpDiscoveryNodesRing.nextNode()
Finds next node in the topology.
|
TcpDiscoveryNode |
TcpDiscoveryNodesRing.nextNode(Collection<TcpDiscoveryNode> excluded)
Finds next node in the topology filtering excluded nodes from search.
|
TcpDiscoveryNode |
TcpDiscoveryNodesRing.node(UUID nodeId)
Finds node by ID.
|
TcpDiscoveryNode |
TcpDiscoveryNodesRing.removeNode(UUID nodeId)
Removes node from the topology.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<TcpDiscoveryNode> |
TcpDiscoveryNodesRing.allNodes()
Gets all nodes in the topology.
|
Collection<TcpDiscoveryNode> |
TcpDiscoveryNodesRing.clientNodes() |
Collection<TcpDiscoveryNode> |
TcpDiscoveryNodesRing.remoteNodes()
Gets remote nodes.
|
Collection<TcpDiscoveryNode> |
TcpDiscoveryNodesRing.visibleNodes()
Gets visible nodes in the topology.
|
Collection<TcpDiscoveryNode> |
TcpDiscoveryNodesRing.visibleRemoteNodes()
Gets visible remote nodes in the topology.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
TcpDiscoveryNodesRing.add(TcpDiscoveryNode node)
Adds node to topology, also initializes node last update time with current
system time.
|
int |
TcpDiscoveryNode.compareTo(TcpDiscoveryNode node) |
void |
TcpDiscoveryNodesRing.localNode(TcpDiscoveryNode locNode)
Sets local node.
|
| Modifier and Type | Method and Description |
|---|---|
TcpDiscoveryNode |
TcpDiscoveryNodesRing.coordinator(Collection<TcpDiscoveryNode> excluded)
Finds coordinator in the topology filtering excluded nodes from the search.
|
TcpDiscoveryNode |
TcpDiscoveryNodesRing.nextNode(Collection<TcpDiscoveryNode> excluded)
Finds next node in the topology filtering excluded nodes from search.
|
void |
TcpDiscoveryNodesRing.restoreTopology(Iterable<TcpDiscoveryNode> nodes,
long topVer)
Restores topology from parameters values.
|
| Modifier and Type | Method and Description |
|---|---|
TcpDiscoveryNode |
TcpDiscoveryStatusCheckMessage.creatorNode()
Gets creator node.
|
TcpDiscoveryNode |
TcpDiscoveryNodeAddedMessage.node()
Gets newly added node.
|
TcpDiscoveryNode |
TcpDiscoveryDuplicateIdMessage.node() |
TcpDiscoveryNode |
TcpDiscoveryJoinRequestMessage.node()
Gets new node that wants to join the topology.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<TcpDiscoveryNode> |
TcpDiscoveryNodeAddedMessage.clientTopology() |
Collection<TcpDiscoveryNode> |
TcpDiscoveryNodeAddedMessage.topology()
Gets topology.
|
| Modifier and Type | Method and Description |
|---|---|
void |
TcpDiscoveryNodeAddedMessage.clientTopology(Collection<TcpDiscoveryNode> top) |
void |
TcpDiscoveryNodeAddedMessage.topology(Collection<TcpDiscoveryNode> top)
Sets topology.
|
| Constructor and Description |
|---|
TcpDiscoveryConnectionCheckMessage(TcpDiscoveryNode creatorNode)
Constructor.
|
TcpDiscoveryDuplicateIdMessage(UUID creatorNodeId,
TcpDiscoveryNode node)
Constructor.
|
TcpDiscoveryJoinRequestMessage(TcpDiscoveryNode node,
Map<Integer,byte[]> discoData)
Constructor.
|
TcpDiscoveryNodeAddedMessage(UUID creatorNodeId,
TcpDiscoveryNode node,
Map<Integer,byte[]> newNodeDiscoData,
long gridStartTime)
Constructor.
|
TcpDiscoveryStatusCheckMessage(TcpDiscoveryNode creatorNode,
UUID failedNodeId)
Constructor.
|
Follow @ApacheIgnite
Ignite Fabric : ver. 1.6.0 Release Date : May 18 2016