增加getMetaData适配接口

discovery-plugin-framework-consul/src/main/java/com/nepxion/discovery/plugin/framework/adapter/ConsulAdapter.java

@@ -9,6 +9,8 @@ package com.nepxion.discovery.plugin.framework.adapter;
  * @version 1.0
  */
 
+import java.util.Map;
+
 import javax.annotation.PostConstruct;
 
 import org.apache.commons.lang3.ArrayUtils;
@@ -76,17 +78,22 @@ public class ConsulAdapter extends AbstractPluginAdapter {
     }
 
     @Override
-    public String getServerVersion(Server server) {
+    public Map<String, String> getMetaData(Server server) {
         if (server instanceof ConsulServer) {
             ConsulServer consulServer = (ConsulServer) server;
 
-            return consulServer.getMetadata().get(PluginConstant.VERSION);
+            return consulServer.getMetadata();
         }
 
         throw new PluginException("Server instance isn't the type of ConsulServer");
     }
 
     @Override
+    public String getServerVersion(Server server) {
+        return getMetaData(server).get(PluginConstant.VERSION);
+    }
+
+    @Override
     public String getLocalVersion() {
         return version;
     }

discovery-plugin-framework-eureka/src/main/java/com/nepxion/discovery/plugin/framework/adapter/EurekaAdapter.java

@@ -9,6 +9,8 @@ package com.nepxion.discovery.plugin.framework.adapter;
  * @version 1.0
  */
 
+import java.util.Map;
+
 import org.springframework.cloud.client.serviceregistry.Registration;
 
 import com.nepxion.discovery.plugin.framework.constant.EurekaConstant;
@@ -49,17 +51,22 @@ public class EurekaAdapter extends AbstractPluginAdapter {
     }
 
     @Override
-    public String getServerVersion(Server server) {
+    public Map<String, String> getMetaData(Server server) {
         if (server instanceof DiscoveryEnabledServer) {
             DiscoveryEnabledServer discoveryEnabledServer = (DiscoveryEnabledServer) server;
 
-            return discoveryEnabledServer.getInstanceInfo().getMetadata().get(PluginConstant.VERSION);
+            return discoveryEnabledServer.getInstanceInfo().getMetadata();
         }
 
         throw new PluginException("Server instance isn't the type of DiscoveryEnabledServer");
     }
 
     @Override
+    public String getServerVersion(Server server) {
+        return getMetaData(server).get(PluginConstant.VERSION);
+    }
+
+    @Override
     public String getLocalVersion() {
         return pluginContextAware.getEnvironment().getProperty(EurekaConstant.METADATA_VERSION);
     }

discovery-plugin-framework-zookeeper/src/main/java/com/nepxion/discovery/plugin/framework/adapter/ZookeeperAdapter.java

@@ -9,6 +9,8 @@ package com.nepxion.discovery.plugin.framework.adapter;
  * @version 1.0
  */
 
+import java.util.Map;
+
 import org.springframework.cloud.client.serviceregistry.Registration;
 import org.springframework.cloud.zookeeper.discovery.ZookeeperServer;
 
@@ -45,17 +47,22 @@ public class ZookeeperAdapter extends AbstractPluginAdapter {
     }
 
     @Override
-    public String getServerVersion(Server server) {
+    public Map<String, String> getMetaData(Server server) {
         if (server instanceof ZookeeperServer) {
             ZookeeperServer zookeeperServer = (ZookeeperServer) server;
 
-            return zookeeperServer.getInstance().getPayload().getMetadata().get(PluginConstant.VERSION);
+            return zookeeperServer.getInstance().getPayload().getMetadata();
         }
 
         throw new PluginException("Server instance isn't the type of ZookeeperServer");
     }
 
     @Override
+    public String getServerVersion(Server server) {
+        return getMetaData(server).get(PluginConstant.VERSION);
+    }
+
+    @Override
     public String getLocalVersion() {
         return pluginContextAware.getEnvironment().getProperty(ZookeeperConstant.METADATA_VERSION);
     }

discovery-plugin-framework/src/main/java/com/nepxion/discovery/plugin/framework/adapter/PluginAdapter.java

@@ -9,6 +9,8 @@ package com.nepxion.discovery.plugin.framework.adapter;
  * @version 1.0
  */
 
+import java.util.Map;
+
 import org.springframework.cloud.client.serviceregistry.Registration;
 
 import com.netflix.loadbalancer.Server;
@@ -20,6 +22,8 @@ public interface PluginAdapter {
 
     int getPort(Registration registration);
 
+    Map<String, String> getMetaData(Server server);
+
     String getServerVersion(Server server);
 
     String getVersion();