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 <[email protected]> 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);
