mirrors/bisq
1
0
Fork 0
mirror of https://github.com/bisq-network/bisq.git synced 2025-02-24 15:10:44 +01:00
Code Issues Projects Releases Packages Wiki Activity

Add num requests to monitor

Browse source
This commit is contained in:
Manfred Karrer 2017-12-17 21:56:07 +01:00
parent ef8796be3c
commit 2ca59a819d
No known key found for this signature in database
GPG key ID: 401250966A6B2C46
1 changed files with 8 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
seednode_monitor/src/main/java/io/bisq/seednode_monitor/MetricsByNodeAddressMap.java
View file

@ -93,6 +93,7 @@ public class MetricsByNodeAddressMap extends HashMap<NodeAddress, Metrics> {
"<tr>" + "<tr>" +
"<th align=\"left\">Operator</th>" + "<th align=\"left\">Operator</th>" +
"<th align=\"left\">Node address</th>" + "<th align=\"left\">Node address</th>" +
"<th align=\"left\">Num requests</th>" +
"<th align=\"left\">Num errors</th>" + "<th align=\"left\">Num errors</th>" +
"<th align=\"left\">Last error message</th>" + "<th align=\"left\">Last error message</th>" +
"<th align=\"left\">Duration average</th>" + "<th align=\"left\">Duration average</th>" +
@ -117,9 +118,11 @@ public class MetricsByNodeAddressMap extends HashMap<NodeAddress, Metrics> {
Map<String, Integer> lastReceivedData = !allReceivedData.isEmpty() ? allReceivedData.get(allReceivedData.size() - 1) : new HashMap<>(); Map<String, Integer> lastReceivedData = !allReceivedData.isEmpty() ? allReceivedData.get(allReceivedData.size() - 1) : new HashMap<>();
final String lastReceivedDataString = lastReceivedData.entrySet().stream().map(Object::toString).collect(Collectors.joining("<br/>")); final String lastReceivedDataString = lastReceivedData.entrySet().stream().map(Object::toString).collect(Collectors.joining("<br/>"));
final String allReceivedDataString = allReceivedData.stream().map(Object::toString).collect(Collectors.joining("<br/>")); final String allReceivedDataString = allReceivedData.stream().map(Object::toString).collect(Collectors.joining("<br/>"));
int numRequests = allDurations.size();
sb.append("\nOperator: ").append(operator) sb.append("\nOperator: ").append(operator)
.append("\nNode address: ").append(nodeAddress) .append("\nNode address: ").append(nodeAddress)
.append("\nNum requests: ").append(numRequests)
.append("\nNum errors: ").append(numErrors) .append("\nNum errors: ").append(numErrors)
.append("\nLast error message: ").append(lastErrorMsg) .append("\nLast error message: ").append(lastErrorMsg)
.append("\nDuration average: ").append(durationAverage) .append("\nDuration average: ").append(durationAverage)
@ -130,6 +133,7 @@ public class MetricsByNodeAddressMap extends HashMap<NodeAddress, Metrics> {
html.append("<tr>") html.append("<tr>")
.append("<td>").append("<font color=\"" + colorNumErrors + "\">" + operator + "</font> ").append("</td>") .append("<td>").append("<font color=\"" + colorNumErrors + "\">" + operator + "</font> ").append("</td>")
.append("<td>").append("<font color=\"" + colorNumErrors + "\">" + nodeAddress + "</font> ").append("</td>") .append("<td>").append("<font color=\"" + colorNumErrors + "\">" + nodeAddress + "</font> ").append("</td>")
.append("<td>").append("<font color=\"" + colorNumErrors + "\">" + numRequests + "</font> ").append("</td>")
.append("<td>").append("<font color=\"" + colorNumErrors + "\">" + numErrors + "</font> ").append("</td>") .append("<td>").append("<font color=\"" + colorNumErrors + "\">" + numErrors + "</font> ").append("</td>")
.append("<td>").append("<font color=\"" + colorNumErrors + "\">" + lastErrorMsg + "</font> ").append("</td>") .append("<td>").append("<font color=\"" + colorNumErrors + "\">" + lastErrorMsg + "</font> ").append("</td>")
.append("<td>").append("<font color=\"" + colorDurationAverage + "\">" + durationAverage + "</font> ").append("</td>") .append("<td>").append("<font color=\"" + colorDurationAverage + "\">" + durationAverage + "</font> ").append("</td>")
@ -143,16 +147,17 @@ public class MetricsByNodeAddressMap extends HashMap<NodeAddress, Metrics> {
String str = dataItem + ": " + deviation + "%"; String str = dataItem + ": " + deviation + "%";
sb.append(str).append("\n"); sb.append(str).append("\n");
String color; String color;
if (Math.abs(deviation - 100) == 0) final double devAbs = Math.abs(deviation - 100);
if (devAbs < 5)
color = "black"; color = "black";
else if (Math.abs(deviation - 100) < 10) else if (devAbs < 10)
color = "blue"; color = "blue";
else else
color = "red"; color = "red";
html.append("<font color=\"" + color + "\">" + str + "</font> ").append("<br/>"); html.append("<font color=\"" + color + "\">" + str + "</font> ").append("<br/>");
if (deviation > 120 || deviation < 80) { if (devAbs >= 20) {
if (slackApi != null) if (slackApi != null)
slackApi.call(new SlackMessage("Warning: " + nodeAddress.getFullAddress(), slackApi.call(new SlackMessage("Warning: " + nodeAddress.getFullAddress(),
"<" + operator + ">" + " Your seed node delivers diverging results for " + dataItem + ". " + "<" + operator + ">" + " Your seed node delivers diverging results for " + dataItem + ". " +