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

Add missing property set for new field `httpResponseStatusCode` (#7486) 

Follow up https://github.com/apache/skywalking/pull/7271
This commit is contained in:
kezhenxu94 2021-08-19 06:12:05 +08:00 committed by GitHub
parent c04b4e0e51
commit ad0042f6f5
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

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