support sofa registry kubernetes

Author: 呈铭

registry/registry-kubernetes/src/main/java/com/alipay/sofa/rpc/registry/kubernetes/KubernetesRegistry.java

@@ -32,7 +32,6 @@
 import com.alipay.sofa.rpc.registry.Registry;
 import com.alipay.sofa.rpc.registry.kubernetes.utils.KubernetesClientUtils;
 import com.alipay.sofa.rpc.registry.kubernetes.utils.KubernetesConfigUtils;
-import com.alipay.sofa.rpc.registry.utils.RegistryUtils;
 import io.fabric8.kubernetes.api.model.Pod;
 import io.fabric8.kubernetes.api.model.PodBuilder;
 import io.fabric8.kubernetes.api.model.PodList;
@@ -217,9 +216,7 @@ public void onDelete(Pod pod, boolean b) {
 
             List<Pod> pods = podPodListPodResourceFilterWatchListDeletable.list().getItems();
             List<ProviderInfo> providerInfos = KubernetesRegistryHelper.convertPodsToProviders(pods, config);
-            List<ProviderInfo> matchProviders = RegistryUtils.matchProviderInfos(config, providerInfos);
-
-            return Collections.singletonList(new ProviderGroup().addAll(matchProviders));
+            return Collections.singletonList(new ProviderGroup().addAll(providerInfos));
         }
 
         return null;

registry/registry-kubernetes/src/main/java/com/alipay/sofa/rpc/registry/kubernetes/KubernetesRegistryProviderWatcher.java

@@ -67,10 +67,9 @@ public void updateProviders(ConsumerConfig config, List<Pod> podList) {
         List<ProviderInfoListener> providerInfoListeners = providerListenerMap.get(config);
         if (CommonUtils.isNotEmpty(providerInfoListeners)) {
             List<ProviderInfo> providerInfos = KubernetesRegistryHelper.convertPodsToProviders(podList, config);
-            List<ProviderInfo> matchProviders = RegistryUtils.matchProviderInfos(config, providerInfos);
 
             for (ProviderInfoListener providerInfoListener : providerInfoListeners) {
-                providerInfoListener.updateAllProviders(Collections.singletonList(new ProviderGroup().addAll(matchProviders)));
+                providerInfoListener.updateAllProviders(Collections.singletonList(new ProviderGroup().addAll(providerInfos)));
             }
         }
     }