kazusa
/
skywalking-java
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Miss copy response code in mesh analysis. (#2684)

This commit is contained in:
吴晟 Wu Sheng 2019-05-16 00:20:18 +08:00 committed by GitHub
parent 63fb961c0d
commit 3c52a326cb
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
oap-server/server-receiver-plugin/skywalking-mesh-receiver-plugin/src/main/java/org/apache/skywalking/aop/server/receiver/mesh/TelemetryDataDispatcher.java
View File

@ -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);