@MXBeanDescription(value="MBean provide access to TCP-based discovery SPI.") public interface TcpDiscoverySpiMBean extends IgniteSpiManagementMBean, DiscoverySpiMBean
TcpDiscoverySpi
.Modifier and Type | Method and Description |
---|---|
void |
checkRingLatency(int maxHops)
Diagnosis method for determining ring message latency.
|
void |
dumpDebugInfo()
Dumps debug info using configured logger.
|
void |
dumpRingStructure()
Dumps ring structure to log.
|
long |
getAckTimeout()
Gets message acknowledgement timeout.
|
long |
getAvgMessageProcessingTime()
Gets avg message processing time.
|
long |
getConnectionCheckInterval()
Gets connection check interval in ms.
|
UUID |
getCoordinator()
Gets current coordinator.
|
long |
getCoordinatorSinceTimestamp()
Gets time local node has been coordinator since.
|
long |
getCurrentTopologyVersion()
Current topology version.
|
long |
getIpFinderCleanFrequency()
Gets frequency with which coordinator cleans IP finder and keeps it in the correct state, unregistering addresses
of the nodes that have left the topology.
|
String |
getIpFinderFormatted()
Gets
TcpDiscoveryIpFinder (string representation). |
long |
getJoinTimeout()
The join timeout, in milliseconds.
|
int |
getLocalPort()
Gets local TCP port SPI listens to.
|
int |
getLocalPortRange()
Gets local TCP port range.
|
long |
getMaxAckTimeout()
Gets maximum message acknowledgement timeout.
|
long |
getMaxMessageProcessingTime()
Gets max message processing time.
|
int |
getMessageWorkerQueueSize()
Gets message worker queue current size.
|
long |
getNetworkTimeout()
Gets network timeout.
|
long |
getNodesFailed()
Gets failed nodes count.
|
long |
getNodesJoined()
Gets joined nodes count.
|
long |
getNodesLeft()
Gets left nodes count.
|
long |
getPendingMessagesDiscarded()
Gets pending messages discarded count.
|
long |
getPendingMessagesRegistered()
Gets pending messages registered count.
|
Map<String,Integer> |
getProcessedMessages()
Gets processed messages counts (grouped by type).
|
Map<String,Integer> |
getReceivedMessages()
Gets received messages counts (grouped by type).
|
int |
getReconnectCount()
Gets number of connection attempts.
|
long |
getSocketTimeout()
Gets socket timeout.
|
String |
getSpiState()
Gets current SPI state.
|
long |
getStatisticsPrintFrequency()
Gets statistics print frequency.
|
int |
getThreadPriority()
Gets thread priority.
|
int |
getTotalProcessedMessages()
Gets total processed messages count.
|
int |
getTotalReceivedMessages()
Gets total received messages count.
|
boolean |
isClientMode()
Whether or not discovery is started in client mode.
|
getIgniteHome, getLocalNodeId, getName, getStartTimestamp, getStartTimestampFormatted, getUpTime, getUpTimeFormatted
excludeNode, getCoordinatorNodeFormatted, getLocalNodeFormatted
@MXBeanDescription(value="SPI state.") String getSpiState()
getSpiState
in interface DiscoverySpiMBean
@MXBeanDescription(value="IP Finder.") String getIpFinderFormatted()
TcpDiscoveryIpFinder
(string representation).@MXBeanDescription(value="Reconnect count.") int getReconnectCount()
@MXBeanDescription(value="Connection check interval.") long getConnectionCheckInterval()
@MXBeanDescription(value="Network timeout.") long getNetworkTimeout()
@MXBeanDescription(value="Local TCP port.") int getLocalPort()
@MXBeanDescription(value="Local TCP port range.") int getLocalPortRange()
@MXBeanDescription(value="Threads priority.") int getThreadPriority()
@MXBeanDescription(value="The frequency with which coordinator cleans IP finder and keeps it in the correct state, unregistering addresses of the nodes that have left the topology.") long getIpFinderCleanFrequency()
@MXBeanDescription(value="Statistics print frequency.") long getStatisticsPrintFrequency()
@MXBeanDescription(value="Message worker queue current size.") int getMessageWorkerQueueSize()
@MXBeanDescription(value="Nodes joined count.") long getNodesJoined()
getNodesJoined
in interface DiscoverySpiMBean
@MXBeanDescription(value="Nodes left count.") long getNodesLeft()
getNodesLeft
in interface DiscoverySpiMBean
@MXBeanDescription(value="Nodes failed count.") long getNodesFailed()
getNodesFailed
in interface DiscoverySpiMBean
@MXBeanDescription(value="Pending messages registered.") long getPendingMessagesRegistered()
@MXBeanDescription(value="Pending messages discarded.") long getPendingMessagesDiscarded()
@MXBeanDescription(value="Avg message processing time.") long getAvgMessageProcessingTime()
@MXBeanDescription(value="Max message processing time.") long getMaxMessageProcessingTime()
@MXBeanDescription(value="Total received messages count.") int getTotalReceivedMessages()
@MXBeanDescription(value="Received messages by type.") Map<String,Integer> getReceivedMessages()
@MXBeanDescription(value="Total processed messages count.") int getTotalProcessedMessages()
@MXBeanDescription(value="Processed messages by type.") Map<String,Integer> getProcessedMessages()
@MXBeanDescription(value="Local node is coordinator since.") long getCoordinatorSinceTimestamp()
@MXBeanDescription(value="Coordinator node ID.") UUID getCoordinator()
getCoordinator
in interface DiscoverySpiMBean
null
if for some reason coordintator cannot be reported).@MXBeanDescription(value="Message acknowledgement timeout.") long getAckTimeout()
@MXBeanDescription(value="Maximum message acknowledgement timeout.") long getMaxAckTimeout()
@MXBeanDescription(value="Socket timeout.") long getSocketTimeout()
@MXBeanDescription(value="The join timeout, in milliseconds. Time to wait for joining. If node cannot connect to any address from the IP finder, the node continues to try to join during this timeout. If all addresses still do not respond, an exception will occur and the node will fail to start. If 0 is specified, it means wait forever.") long getJoinTimeout()
@MXBeanDescription(value="Dump debug info.") void dumpDebugInfo()
@MXBeanDescription(value="Client mode.") boolean isClientMode() throws IllegalStateException
true
if node is in client mode.IllegalStateException
- If discovery SPI is not started.@MXBeanDescription(value="Check ring latency.") void checkRingLatency(@MXBeanParameter(name="maxHops",description="Maximum hops for the message (3 * TOTAL_NODE_CNT is recommended).") int maxHops)
maxHops
- Maximum hops for the message (3 * TOTAL_NODE_CNT is recommended).@MXBeanDescription(value="Get current topology version.") long getCurrentTopologyVersion()
@MXBeanDescription(value="Dumps ring structure to log.") void dumpRingStructure()
GridGain In-Memory Computing Platform : ver. 8.9.14 Release Date : November 5 2024