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

Remove client side endpoint register of service mesh (#4054)

This commit is contained in:
Gao Hongtao 2019-12-13 16:11:33 +08:00 committed by GitHub
parent daabc1f5b6
commit 16d7782a5c
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -95,24 +95,15 @@ public class ServiceMeshMetricDataDecorator {
}
String endpoint = origin.getEndpoint();
// Service mesh doesn't register client side endpoint.
DetectPoint point = origin.getDetectPoint();
if (DetectPoint.client.equals(point)) {
if (sourceServiceId != Const.NONE) {
endpointId = CoreRegisterLinker.getEndpointInventoryRegister().getOrCreate(sourceServiceId, endpoint,
org.apache.skywalking.oap.server.core.source.DetectPoint.fromNetworkProtocolDetectPoint(point));
}
} else {
if (DetectPoint.server.equals(point)) {
if (destServiceId != Const.NONE) {
endpointId = CoreRegisterLinker.getEndpointInventoryRegister().getOrCreate(destServiceId, endpoint,
org.apache.skywalking.oap.server.core.source.DetectPoint.fromNetworkProtocolDetectPoint(point));
}
}
if (endpointId != Const.NONE) {
} else {
isRegistered = false;
}
return isRegistered;
}