public class TcpCommunicationMetricsListener extends Object implements org.apache.ignite.internal.util.nio.GridNioMetricsListener
TcpCommunicationSpi
.Constructor and Description |
---|
TcpCommunicationMetricsListener() |
Modifier and Type | Method and Description |
---|---|
void |
onBytesReceived(int bytesCnt) |
void |
onBytesSent(int bytesCnt) |
void |
onMessageReceived(Message msg,
UUID nodeId)
Collects statistics for message received by SPI.
|
void |
onMessageSent(Message msg,
UUID nodeId)
Collects statistics for message sent by SPI.
|
long |
receivedBytesCount()
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).
|
int |
receivedMessagesCount()
Gets received messages count.
|
void |
resetMetrics()
Resets metrics for this instance.
|
long |
sentBytesCount()
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).
|
int |
sentMessagesCount()
Gets sent messages count.
|
public void onBytesSent(int bytesCnt)
onBytesSent
in interface org.apache.ignite.internal.util.nio.GridNioMetricsListener
bytesCnt
- Number of sent bytes.public void onBytesReceived(int bytesCnt)
onBytesReceived
in interface org.apache.ignite.internal.util.nio.GridNioMetricsListener
bytesCnt
- Number of received bytes.public void onMessageSent(Message msg, UUID nodeId)
msg
- Sent message.nodeId
- Receiver node id.public void onMessageReceived(Message msg, UUID nodeId)
msg
- Received message.nodeId
- Sender node id.public int sentMessagesCount()
public long sentBytesCount()
public int receivedMessagesCount()
public long receivedBytesCount()
public Map<String,Long> receivedMessagesByType()
public Map<UUID,Long> receivedMessagesByNode()
public Map<String,Long> sentMessagesByType()
public Map<UUID,Long> sentMessagesByNode()
public void resetMetrics()
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.7.2 Release Date : February 6 2019