[skywalking] branch master updated: chore: remove unused lagecy codes (#5998)

[wu...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

wusheng pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/skywalking.git


The following commit(s) were added to refs/heads/master by this push:
     new 4a0a933  chore: remove unused lagecy codes (#5998)
4a0a933 is described below

commit 4a0a933d954175d7d077508bd1e831c5abc138d0
Author: Zhenxu Ke <ke...@apache.org>
AuthorDate: Sat Dec 12 19:26:12 2020 +0800

    chore: remove unused lagecy codes (#5998)
---
 .../receiver/mesh/TelemetryDataDispatcher.java     | 30 ----------------------
 1 file changed, 30 deletions(-)

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 0635655..70bb41c 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
@@ -24,7 +24,6 @@ import org.apache.skywalking.apm.network.servicemesh.v3.ServiceMeshMetric;
 import org.apache.skywalking.apm.util.StringUtil;
 import org.apache.skywalking.oap.server.core.Const;
 import org.apache.skywalking.oap.server.core.CoreModule;
-import org.apache.skywalking.oap.server.core.analysis.IDManager;
 import org.apache.skywalking.oap.server.core.analysis.NodeType;
 import org.apache.skywalking.oap.server.core.analysis.TimeBucket;
 import org.apache.skywalking.oap.server.core.config.NamingControl;
@@ -35,7 +34,6 @@ import org.apache.skywalking.oap.server.core.source.RequestType;
 import org.apache.skywalking.oap.server.core.source.Service;
 import org.apache.skywalking.oap.server.core.source.ServiceInstance;
 import org.apache.skywalking.oap.server.core.source.ServiceInstanceRelation;
-import org.apache.skywalking.oap.server.core.source.ServiceInstanceUpdate;
 import org.apache.skywalking.oap.server.core.source.ServiceRelation;
 import org.apache.skywalking.oap.server.core.source.SourceReceiver;
 import org.apache.skywalking.oap.server.library.module.ModuleManager;
@@ -103,7 +101,6 @@ public class TelemetryDataDispatcher {
     static void doDispatch(ServiceMeshMetric.Builder metrics) {
         long minuteTimeBucket = TimeBucket.getMinuteTimeBucket(metrics.getStartTime());
 
-        heartbeat(metrics, minuteTimeBucket);
         if (org.apache.skywalking.apm.network.common.v3.DetectPoint.server.equals(metrics.getDetectPoint())) {
             toAll(metrics, minuteTimeBucket);
             toService(metrics, minuteTimeBucket);
@@ -119,33 +116,6 @@ public class TelemetryDataDispatcher {
         }
     }
 
-    private static void heartbeat(ServiceMeshMetric.Builder metrics, long minuteTimeBucket) {
-        // source
-        final String sourceServiceName = metrics.getSourceServiceName();
-        final String sourceServiceInstance = metrics.getSourceServiceInstance();
-        // Don't generate source heartbeat, if no source.
-        if (StringUtil.isNotEmpty(sourceServiceName) && StringUtil.isNotEmpty(sourceServiceInstance)) {
-            final ServiceInstanceUpdate serviceInstanceUpdate = new ServiceInstanceUpdate();
-            serviceInstanceUpdate.setServiceId(
-                IDManager.ServiceID.buildId(sourceServiceName, NodeType.Normal)
-            );
-            serviceInstanceUpdate.setName(sourceServiceInstance);
-            serviceInstanceUpdate.setTimeBucket(minuteTimeBucket);
-        }
-
-        // dest
-        final String destServiceName = metrics.getDestServiceName();
-        final String destServiceInstance = metrics.getDestServiceInstance();
-        if (StringUtil.isNotEmpty(destServiceName) && StringUtil.isNotEmpty(destServiceInstance)) {
-            final ServiceInstanceUpdate serviceInstanceUpdate = new ServiceInstanceUpdate();
-            serviceInstanceUpdate.setServiceId(
-                IDManager.ServiceID.buildId(destServiceName, NodeType.Normal)
-            );
-            serviceInstanceUpdate.setName(destServiceInstance);
-            serviceInstanceUpdate.setTimeBucket(minuteTimeBucket);
-        }
-    }
-
     private static void toAll(ServiceMeshMetric.Builder metrics, long minuteTimeBucket) {
         All all = new All();
         all.setTimeBucket(minuteTimeBucket);