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 9af5fac86ef5..77e1bd7e3e24 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 @@ private static void toAll(ServiceMeshMetric.Builder metrics, long minuteTimeBuck 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 @@ private static void toService(ServiceMeshMetric.Builder metrics, long minuteTime 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 @@ private static void toServiceRelation(ServiceMeshMetric.Builder metrics, long mi 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 @@ private static void toServiceInstance(ServiceMeshMetric.Builder metrics, long mi 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 @@ private static void toServiceInstanceRelation(ServiceMeshMetric.Builder metrics, 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 @@ private static void toEndpoint(ServiceMeshMetric.Builder metrics, long minuteTim 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());