移除无用的接口

skywalking-registry/src/main/java/com/a/eye/skywalking/registry/api/NotifyListener.java

@@ -3,5 +3,5 @@ package com.a.eye.skywalking.registry.api;
 import java.util.List;
 
 public interface NotifyListener {
-    void notify(List<RegistryData> data);
+    void notify(List<RegistryData> urls);
 }

skywalking-registry/src/main/java/com/a/eye/skywalking/registry/api/Register.java

@@ -1,13 +0,0 @@
-package com.a.eye.skywalking.registry.api;
-
-/**
- * Created by xin on 2016/11/9.
- */
-public interface Register {
-
-    void subscribe(NotifyListener listener);
-
-    void unSubscribe();
-
-    void registry();
-}

skywalking-registry/src/main/java/com/a/eye/skywalking/registry/api/RegisterFactory.java

@@ -1,5 +0,0 @@
-package com.a.eye.skywalking.registry.api;
-
-public interface RegisterFactory {
-    Register getRegister(String key);
-}

skywalking-registry/src/main/java/com/a/eye/skywalking/registry/api/RegistryData.java

@@ -1,15 +1,12 @@
 package com.a.eye.skywalking.registry.api;
 
 /**
- * Created by xin on 2016/11/9.
+ * 存储注册项的数据
+ * 注册项包括：注册的目录（支持多级，以"/"分割）以及注册值
  */
-public class RegistryData {
+public interface RegistryData {
 
-    public String key() {
-        return null;
-    }
+    String getPath();
 
-    public String data() {
-        return null;
-    }
+    String getValue();
 }

skywalking-registry/src/main/java/com/a/eye/skywalking/registry/api/RegistryManager.java

@@ -0,0 +1,40 @@
+package com.a.eye.skywalking.registry.api;
+
+/**
+ * 主要用于注册中心的维护
+ */
+public interface RegistryManager {
+
+    /**
+     * 主要用于storage启动注册使用，将自身IP和端口注册到注册中心
+     * 格式为:
+     * /storage_list/192.168.0.1:3400 NULL
+     *
+     * @param data
+     */
+    void register(RegistryData data);
+
+    /**
+     * 从注册中心移除storage宕机节点
+     *
+     * @param data
+     */
+    void unregister(RegistryData data);
+
+    /**
+     * 主要用于routing节点在启动完成之后，读取和监听stroage节点列表
+     * 格式
+     *
+     * @param data
+     * @param listener
+     */
+    void subscribe(RegistryData data, NotifyListener listener);
+
+    /**
+     * 移除storage节点之后
+     *
+     * @param data
+     */
+    void unsubscribe(RegistryData data);
+
+}

skywalking-registry/src/main/java/com/a/eye/skywalking/registry/impl/DefaultRegistry.java

@@ -1,19 +0,0 @@
-package com.a.eye.skywalking.registry.impl;
-
-import com.a.eye.skywalking.registry.api.NotifyListener;
-import com.a.eye.skywalking.registry.api.Register;
-
-/**
- * Created by xin on 2016/11/9.
- */
-public class DefaultRegistry implements Register {
-    @Override
-    public void subscribe(NotifyListener listener) {
-
-    }
-
-    @Override
-    public void unSubscribe() {
-
-    }
-}

skywalking-registry/src/main/java/com/a/eye/skywalking/registry/impl/DefaultRegistryFactory.java

@@ -1,14 +0,0 @@
-package com.a.eye.skywalking.registry.impl;
-
-import com.a.eye.skywalking.registry.api.Register;
-import com.a.eye.skywalking.registry.api.RegisterFactory;
-
-/**
- * Created by xin on 2016/11/9.
- */
-public class DefaultRegistryFactory implements RegisterFactory {
-    @Override
-    public Register getRegister(String key) {
-        return null;
-    }
-}