diff --git a/skywalking-registry/src/main/java/com/a/eye/skywalking/registry/api/NotifyListener.java b/skywalking-registry/src/main/java/com/a/eye/skywalking/registry/api/NotifyListener.java index d858e9895..da71eb959 100644 --- a/skywalking-registry/src/main/java/com/a/eye/skywalking/registry/api/NotifyListener.java +++ b/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 data); + void notify(List urls); } diff --git a/skywalking-registry/src/main/java/com/a/eye/skywalking/registry/api/Register.java b/skywalking-registry/src/main/java/com/a/eye/skywalking/registry/api/Register.java deleted file mode 100644 index 86814b2a9..000000000 --- a/skywalking-registry/src/main/java/com/a/eye/skywalking/registry/api/Register.java +++ /dev/null @@ -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(); -} diff --git a/skywalking-registry/src/main/java/com/a/eye/skywalking/registry/api/RegisterFactory.java b/skywalking-registry/src/main/java/com/a/eye/skywalking/registry/api/RegisterFactory.java deleted file mode 100644 index 7ff311a07..000000000 --- a/skywalking-registry/src/main/java/com/a/eye/skywalking/registry/api/RegisterFactory.java +++ /dev/null @@ -1,5 +0,0 @@ -package com.a.eye.skywalking.registry.api; - -public interface RegisterFactory { - Register getRegister(String key); -} diff --git a/skywalking-registry/src/main/java/com/a/eye/skywalking/registry/api/RegistryData.java b/skywalking-registry/src/main/java/com/a/eye/skywalking/registry/api/RegistryData.java index f201e019d..597728440 100644 --- a/skywalking-registry/src/main/java/com/a/eye/skywalking/registry/api/RegistryData.java +++ b/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(); } diff --git a/skywalking-registry/src/main/java/com/a/eye/skywalking/registry/api/RegistryManager.java b/skywalking-registry/src/main/java/com/a/eye/skywalking/registry/api/RegistryManager.java new file mode 100644 index 000000000..6f060c9f3 --- /dev/null +++ b/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); + +} diff --git a/skywalking-registry/src/main/java/com/a/eye/skywalking/registry/impl/DefaultRegistry.java b/skywalking-registry/src/main/java/com/a/eye/skywalking/registry/impl/DefaultRegistry.java deleted file mode 100644 index 05f05d371..000000000 --- a/skywalking-registry/src/main/java/com/a/eye/skywalking/registry/impl/DefaultRegistry.java +++ /dev/null @@ -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() { - - } -} diff --git a/skywalking-registry/src/main/java/com/a/eye/skywalking/registry/impl/DefaultRegistryFactory.java b/skywalking-registry/src/main/java/com/a/eye/skywalking/registry/impl/DefaultRegistryFactory.java deleted file mode 100644 index 0a1cb162c..000000000 --- a/skywalking-registry/src/main/java/com/a/eye/skywalking/registry/impl/DefaultRegistryFactory.java +++ /dev/null @@ -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; - } -}