You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@skywalking.apache.org by wu...@apache.org on 2019/05/15 14:16:04 UTC
[skywalking] 01/01: Miss copy response code in mesh analysis.
This is an automated email from the ASF dual-hosted git repository.
wusheng pushed a commit to branch mesh-response-code
in repository https://gitbox.apache.org/repos/asf/skywalking.git
commit 470b44e79cf75a7aa2b25e1923cc191437933f5a
Author: Wu Sheng <wu...@foxmail.com>
AuthorDate: Wed May 15 22:15:48 2019 +0800
Miss copy response code in mesh analysis.
---
.../skywalking/aop/server/receiver/mesh/TelemetryDataDispatcher.java | 4 ++++
1 file changed, 4 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 5bcf54b..dbe069b 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
@@ -142,6 +142,7 @@ public class TelemetryDataDispatcher {
all.setEndpointName(metrics.getEndpoint());
all.setLatency(metrics.getLatency());
all.setStatus(metrics.getStatus());
+ all.setResponseCode(metrics.getResponseCode());
all.setType(protocol2Type(metrics.getProtocol()));
SOURCE_RECEIVER.receive(all);
@@ -157,6 +158,7 @@ public class TelemetryDataDispatcher {
service.setEndpointName(metrics.getEndpoint());
service.setLatency(metrics.getLatency());
service.setStatus(metrics.getStatus());
+ service.setResponseCode(metrics.getResponseCode());
service.setType(protocol2Type(metrics.getProtocol()));
SOURCE_RECEIVER.receive(service);
@@ -196,6 +198,7 @@ public class TelemetryDataDispatcher {
serviceInstance.setEndpointName(metrics.getEndpoint());
serviceInstance.setLatency(metrics.getLatency());
serviceInstance.setStatus(metrics.getStatus());
+ serviceInstance.setResponseCode(metrics.getResponseCode());
serviceInstance.setType(protocol2Type(metrics.getProtocol()));
SOURCE_RECEIVER.receive(serviceInstance);
@@ -239,6 +242,7 @@ public class TelemetryDataDispatcher {
endpoint.setLatency(metrics.getLatency());
endpoint.setStatus(metrics.getStatus());
+ endpoint.setResponseCode(metrics.getResponseCode());
endpoint.setType(protocol2Type(metrics.getProtocol()));
SOURCE_RECEIVER.receive(endpoint);