You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@skywalking.apache.org by ke...@apache.org on 2021/08/18 15:29:34 UTC
[skywalking] 01/01: Add missing property set for new field
`httpResponseStatusCode`
This is an automated email from the ASF dual-hosted git repository.
kezhenxu94 pushed a commit to branch bugfix/missing-httpResponseStatusCode
in repository https://gitbox.apache.org/repos/asf/skywalking.git
commit 5abfc1bdf23d0dcbdb5e32402e582571f317df3c
Author: kezhenxu94 <ke...@apache.org>
AuthorDate: Wed Aug 18 23:28:48 2021 +0800
Add missing property set for new field `httpResponseStatusCode`
Follow up https://github.com/apache/skywalking/pull/7271
---
.../aop/server/receiver/mesh/TelemetryDataDispatcher.java | 6 ++++++
1 file changed, 6 insertions(+)
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 9af5fac..77e1bd7 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
@@ -131,6 +131,7 @@ public class TelemetryDataDispatcher {
all.setLatency(metrics.getLatency());
all.setStatus(metrics.getStatus());
all.setResponseCode(metrics.getResponseCode());
+ all.setHttpResponseStatusCode(metrics.getResponseCode());
all.setType(protocol2Type(metrics.getProtocol()));
SOURCE_RECEIVER.receive(all);
@@ -146,6 +147,7 @@ public class TelemetryDataDispatcher {
service.setLatency(metrics.getLatency());
service.setStatus(metrics.getStatus());
service.setResponseCode(metrics.getResponseCode());
+ service.setHttpResponseStatusCode(metrics.getResponseCode());
service.setType(protocol2Type(metrics.getProtocol()));
service.getSideCar().setInternalErrorCode(metrics.getInternalErrorCode());
service.getTcpInfo().setReceivedBytes(metrics.getTcp().getReceivedBytes());
@@ -168,6 +170,7 @@ public class TelemetryDataDispatcher {
serviceRelation.setStatus(metrics.getStatus());
serviceRelation.setType(protocol2Type(metrics.getProtocol()));
serviceRelation.setResponseCode(metrics.getResponseCode());
+ serviceRelation.setHttpResponseStatusCode(metrics.getResponseCode());
serviceRelation.setDetectPoint(detectPointMapping(metrics.getDetectPoint()));
serviceRelation.setComponentId(protocol2Component(metrics.getProtocol()));
serviceRelation.setTlsMode(metrics.getTlsMode());
@@ -188,6 +191,7 @@ public class TelemetryDataDispatcher {
serviceInstance.setLatency(metrics.getLatency());
serviceInstance.setStatus(metrics.getStatus());
serviceInstance.setResponseCode(metrics.getResponseCode());
+ serviceInstance.setHttpResponseStatusCode(metrics.getResponseCode());
serviceInstance.setType(protocol2Type(metrics.getProtocol()));
serviceInstance.getSideCar().setInternalErrorCode(metrics.getInternalErrorCode());
serviceInstance.getTcpInfo().setReceivedBytes(metrics.getTcp().getReceivedBytes());
@@ -210,6 +214,7 @@ public class TelemetryDataDispatcher {
serviceRelation.setStatus(metrics.getStatus());
serviceRelation.setType(protocol2Type(metrics.getProtocol()));
serviceRelation.setResponseCode(metrics.getResponseCode());
+ serviceRelation.setHttpResponseStatusCode(metrics.getResponseCode());
serviceRelation.setDetectPoint(detectPointMapping(metrics.getDetectPoint()));
serviceRelation.setComponentId(protocol2Component(metrics.getProtocol()));
serviceRelation.setTlsMode(metrics.getTlsMode());
@@ -230,6 +235,7 @@ public class TelemetryDataDispatcher {
endpoint.setLatency(metrics.getLatency());
endpoint.setStatus(metrics.getStatus());
endpoint.setResponseCode(metrics.getResponseCode());
+ endpoint.setHttpResponseStatusCode(metrics.getResponseCode());
endpoint.setType(protocol2Type(metrics.getProtocol()));
endpoint.getSideCar().setInternalErrorCode(metrics.getInternalErrorCode());