| Package | Description |
|---|---|
| org.apache.ignite.spi.discovery.tcp.internal |
Contains internal implementation.
|
| org.apache.ignite.spi.discovery.tcp.messages |
Contains implementation messages.
|
| Modifier and Type | Method and Description |
|---|---|
void |
TcpDiscoveryStatistics.onMessageProcessingFinished(TcpDiscoveryAbstractMessage msg)
Collects necessary stats for message processed by SPI.
|
void |
TcpDiscoveryStatistics.onMessageProcessingStarted(TcpDiscoveryAbstractMessage msg)
Collects necessary stats for message processed by SPI.
|
void |
TcpDiscoveryStatistics.onMessageReceived(TcpDiscoveryAbstractMessage msg)
Collects necessary stats for message received by SPI.
|
void |
TcpDiscoveryStatistics.onMessageSent(TcpDiscoveryAbstractMessage msg,
long time)
Called by coordinator when ring message is sent.
|
void |
TcpDiscoveryStatistics.onRingMessageReceived(TcpDiscoveryAbstractMessage msg)
Called by coordinator when ring message makes full pass.
|
| Modifier and Type | Class and Description |
|---|---|
class |
TcpDiscoveryAuthFailedMessage
Message telling joining node that its authentication failed on coordinator.
|
class |
TcpDiscoveryCheckFailedMessage
Message telling joining node that it failed coordinator's validation check.
|
class |
TcpDiscoveryClientReconnectMessage
Message telling that client node is reconnecting to topology.
|
class |
TcpDiscoveryCustomEventMessage
Wrapped for custom message.
|
class |
TcpDiscoveryDiscardMessage
Message sent by coordinator when some operation handling is over.
|
class |
TcpDiscoveryDuplicateIdMessage
Message telling joining node that new topology already contain
different node with same ID.
|
class |
TcpDiscoveryHandshakeRequest
Handshake request.
|
class |
TcpDiscoveryHandshakeResponse
Handshake response.
|
class |
TcpDiscoveryHeartbeatMessage
Heartbeat message.
|
class |
TcpDiscoveryJoinRequestMessage
Initial message sent by a node that wants to enter topology.
|
class |
TcpDiscoveryLoopbackProblemMessage
Message telling joining node that it has loopback problem (misconfiguration).
|
class |
TcpDiscoveryNodeAddedMessage
Message telling nodes that new node should be added to topology.
|
class |
TcpDiscoveryNodeAddFinishedMessage
Sent by coordinator across the ring to finish node add process.
|
class |
TcpDiscoveryNodeFailedMessage
Sent by node that has detected node failure to coordinator across the ring,
then sent by coordinator across the ring.
|
class |
TcpDiscoveryNodeLeftMessage
Sent by node that is stopping to coordinator across the ring,
then sent by coordinator across the ring.
|
class |
TcpDiscoveryPingRequest
Ping request.
|
class |
TcpDiscoveryPingResponse
Ping response.
|
class |
TcpDiscoveryStatusCheckMessage
Message sent by node to its next to ensure that next node and
connection to it are alive.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<TcpDiscoveryAbstractMessage> |
TcpDiscoveryNodeAddedMessage.messages()
Gets pending messages sent to new node by its previous.
|
Collection<TcpDiscoveryAbstractMessage> |
TcpDiscoveryClientReconnectMessage.pendingMessages() |
| Modifier and Type | Method and Description |
|---|---|
void |
TcpDiscoveryNodeAddedMessage.messages(Collection<TcpDiscoveryAbstractMessage> msgs,
IgniteUuid discardMsgId)
Sets pending messages to send to new node.
|
void |
TcpDiscoveryClientReconnectMessage.pendingMessages(Collection<TcpDiscoveryAbstractMessage> msgs) |
Follow @ApacheIgnite
Ignite Fabric : ver. 1.0.0-RC3 Release Date : March 24 2015