Class TcpCommunicationMetricsListener
- java.lang.Object
- 
- org.apache.ignite.spi.communication.tcp.TcpCommunicationMetricsListener
 
- 
 public class TcpCommunicationMetricsListener extends Object Statistics forTcpCommunicationSpi.
- 
- 
Constructor SummaryConstructors Constructor Description TcpCommunicationMetricsListener(Ignite ignite, IgniteSpiContext spiCtx)
 - 
Method SummaryAll Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description protected Map<UUID,Long>collectMessagesCountByNodeId(String metricName)Collect messages count by nodeIdprotected Map<String,Long>collectMessagesCountByType(String prefix)Collect messages count by typeMetricRegistrymetricRegistry()voidonMessageReceived(Message msg, Object consistentId)Collects statistics for message received by SPI.voidonMessageSent(Message msg, Object consistentId)Collects statistics for message sent by SPI.voidonNodeLeft(Object consistentId)longreceivedBytesCount()Gets received bytes count.Map<UUID,Long>receivedMessagesByNode()Gets received messages counts (grouped by node).Map<String,Long>receivedMessagesByType()Gets received messages counts (grouped by type).static StringreceivedMessagesByTypeMetricName(Short directType)Generate metric name by message direct type id.intreceivedMessagesCount()Gets received messages count.voidresetMetrics()Resets metrics for this instance.longsentBytesCount()Gets sent bytes count.Map<UUID,Long>sentMessagesByNode()Gets sent messages counts (grouped by node).Map<String,Long>sentMessagesByType()Gets sent messages counts (grouped by type).static StringsentMessagesByTypeMetricName(Short directType)Generate metric name by message direct type id.intsentMessagesCount()Gets sent messages count.
 
- 
- 
- 
Constructor Detail- 
TcpCommunicationMetricsListenerpublic TcpCommunicationMetricsListener(Ignite ignite, IgniteSpiContext spiCtx) - Parameters:
- ignite- Ignite instance.
- spiCtx- Ignite SPI context.
 
 
- 
 - 
Method Detail- 
metricRegistrypublic MetricRegistry metricRegistry() - Returns:
- Metrics registry.
 
 - 
onMessageSentpublic void onMessageSent(Message msg, Object consistentId) Collects statistics for message sent by SPI.- Parameters:
- msg- Sent message.
- consistentId- Receiver node consistent id.
 
 - 
onMessageReceivedpublic void onMessageReceived(Message msg, Object consistentId) Collects statistics for message received by SPI.- Parameters:
- msg- Received message.
- consistentId- Sender node consistent id.
 
 - 
sentMessagesCountpublic int sentMessagesCount() Gets sent messages count.- Returns:
- Sent messages count.
 
 - 
sentBytesCountpublic long sentBytesCount() Gets sent bytes count.- Returns:
- Sent bytes count.
 
 - 
receivedMessagesCountpublic int receivedMessagesCount() Gets received messages count.- Returns:
- Received messages count.
 
 - 
receivedBytesCountpublic long receivedBytesCount() Gets received bytes count.- Returns:
- Received bytes count.
 
 - 
receivedMessagesByTypepublic Map<String,Long> receivedMessagesByType() Gets received messages counts (grouped by type).- Returns:
- Map containing message types and respective counts.
 
 - 
receivedMessagesByNodepublic Map<UUID,Long> receivedMessagesByNode() Gets received messages counts (grouped by node).- Returns:
- Map containing sender nodes and respective counts.
 
 - 
sentMessagesByTypepublic Map<String,Long> sentMessagesByType() Gets sent messages counts (grouped by type).- Returns:
- Map containing message types and respective counts.
 
 - 
sentMessagesByNodepublic Map<UUID,Long> sentMessagesByNode() Gets sent messages counts (grouped by node).- Returns:
- Map containing receiver nodes and respective counts.
 
 - 
collectMessagesCountByTypeprotected Map<String,Long> collectMessagesCountByType(String prefix) Collect messages count by type
 - 
collectMessagesCountByNodeIdprotected Map<UUID,Long> collectMessagesCountByNodeId(String metricName) Collect messages count by nodeId
 - 
resetMetricspublic void resetMetrics() Resets metrics for this instance.
 - 
onNodeLeftpublic void onNodeLeft(Object consistentId) - Parameters:
- consistentId- Consistent id of the node.
 
 - 
sentMessagesByTypeMetricNamepublic static String sentMessagesByTypeMetricName(Short directType) Generate metric name by message direct type id.- Parameters:
- directType- Direct type ID of sent message.
- Returns:
- Metric name for sent message.
 
 
- 
 
-