diff --git a/docs/en/changes/changes.md b/docs/en/changes/changes.md index d138685d9b11edfb40732a428efa90520e13eae9..4762334a207f7cc257b92651c822239a98b4b0cd 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 9059622ab3102d126e085aaad03c088f291fcb93..11cdf191acbc1b3cbe79be99ff67dd7454c81b71 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); }