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 <kezhenx...@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); }