[skywalking] branch master updated: Add missing tcp throughput metrics (#10356)

[ke...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

kezhenxu94 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/skywalking.git


The following commit(s) were added to refs/heads/master by this push:
     new 974cecb67f Add missing tcp throughput metrics (#10356)
974cecb67f is described below

commit 974cecb67f5238e9017347affb4380897011ae47
Author: kezhenxu94 <ke...@apache.org>
AuthorDate: Tue Feb 7 18:38:54 2023 +0800

    Add missing tcp throughput metrics (#10356)
---
 docs/en/changes/changes.md                                        | 1 +
 .../aop/server/receiver/mesh/TelemetryDataDispatcher.java         | 8 ++++++++
 2 files changed, 9 insertions(+)

diff --git a/docs/en/changes/changes.md b/docs/en/changes/changes.md
index d138685d9b..4762334a20 100644
--- a/docs/en/changes/changes.md
+++ b/docs/en/changes/changes.md
@@ -89,6 +89,7 @@
 * Add aws-firehose-receiver to support collecting AWS CloudWatch metric(OpenTelemetry format)
 * Avoid Antlr dependencies' versions might be different in compile time and runtime.
 * Now `PrometheusMetricConverter#escapedName` also support converting `/` to `_`.
+* Add missing TCP throughput metrics.
 
 #### UI
 
diff --git a/oap-server/server-receiver-plugin/skywalking-mesh-receiver-plugin/src/main/java/org/apache/skywalking/aop/server/receiver/mesh/TelemetryDataDispatcher.java b/oap-server/server-receiver-plugin/skywalking-mesh-receiver-plugin/src/main/java/org/apache/skywalking/aop/server/receiver/mesh/TelemetryDataDispatcher.java
index 9059622ab3..11cdf191ac 100644
--- a/oap-server/server-receiver-plugin/skywalking-mesh-receiver-plugin/src/main/java/org/apache/skywalking/aop/server/receiver/mesh/TelemetryDataDispatcher.java
+++ b/oap-server/server-receiver-plugin/skywalking-mesh-receiver-plugin/src/main/java/org/apache/skywalking/aop/server/receiver/mesh/TelemetryDataDispatcher.java
@@ -224,6 +224,8 @@ public class TelemetryDataDispatcher {
         service.getSideCar().setInternalErrorCode(metrics.getInternalErrorCode());
         service.getSideCar().setInternalRequestLatencyNanos(metrics.getInternalRequestLatencyNanos());
         service.getSideCar().setInternalResponseLatencyNanos(metrics.getInternalResponseLatencyNanos());
+        service.setReceivedBytes(metrics.getReceivedBytes());
+        service.setSentBytes(metrics.getSentBytes());
 
         SOURCE_RECEIVER.receive(service);
     }
@@ -267,6 +269,8 @@ public class TelemetryDataDispatcher {
         serviceRelation.getSideCar().setInternalErrorCode(metrics.getInternalErrorCode());
         serviceRelation.getSideCar().setInternalRequestLatencyNanos(metrics.getInternalRequestLatencyNanos());
         serviceRelation.getSideCar().setInternalResponseLatencyNanos(metrics.getInternalResponseLatencyNanos());
+        serviceRelation.setReceivedBytes(metrics.getReceivedBytes());
+        serviceRelation.setSentBytes(metrics.getSentBytes());
 
         SOURCE_RECEIVER.receive(serviceRelation);
     }
@@ -298,6 +302,8 @@ public class TelemetryDataDispatcher {
         serviceInstance.getSideCar().setInternalErrorCode(metrics.getInternalErrorCode());
         serviceInstance.getSideCar().setInternalRequestLatencyNanos(metrics.getInternalRequestLatencyNanos());
         serviceInstance.getSideCar().setInternalResponseLatencyNanos(metrics.getInternalResponseLatencyNanos());
+        serviceInstance.setReceivedBytes(metrics.getReceivedBytes());
+        serviceInstance.setSentBytes(metrics.getSentBytes());
 
         SOURCE_RECEIVER.receive(serviceInstance);
     }
@@ -374,6 +380,8 @@ public class TelemetryDataDispatcher {
         serviceRelation.getSideCar().setInternalErrorCode(metrics.getInternalErrorCode());
         serviceRelation.getSideCar().setInternalRequestLatencyNanos(metrics.getInternalRequestLatencyNanos());
         serviceRelation.getSideCar().setInternalResponseLatencyNanos(metrics.getInternalResponseLatencyNanos());
+        serviceRelation.setReceivedBytes(metrics.getReceivedBytes());
+        serviceRelation.setSentBytes(metrics.getSentBytes());
 
         SOURCE_RECEIVER.receive(serviceRelation);
     }