diff --git a/skywalking-registry/pom.xml b/skywalking-registry/pom.xml new file mode 100644 index 000000000..ed3d24bcb --- /dev/null +++ b/skywalking-registry/pom.xml @@ -0,0 +1,22 @@ + + + skywalking + com.a.eye + 2.0-2016 + + 4.0.0 + + skywalking-registry + jar + + skywalking-registry + http://maven.apache.org + + + UTF-8 + + + + + 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 new file mode 100644 index 000000000..d858e9895 --- /dev/null +++ b/skywalking-registry/src/main/java/com/a/eye/skywalking/registry/api/NotifyListener.java @@ -0,0 +1,7 @@ +package com.a.eye.skywalking.registry.api; + +import java.util.List; + +public interface NotifyListener { + void notify(List data); +} 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 new file mode 100644 index 000000000..55d2cb31c --- /dev/null +++ b/skywalking-registry/src/main/java/com/a/eye/skywalking/registry/api/Register.java @@ -0,0 +1,12 @@ +package com.a.eye.skywalking.registry.api; + +/** + * Created by xin on 2016/11/9. + */ +public interface Register { + + void subscribe(NotifyListener listener); + + void unSubscribe(); + +} 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 new file mode 100644 index 000000000..7ff311a07 --- /dev/null +++ b/skywalking-registry/src/main/java/com/a/eye/skywalking/registry/api/RegisterFactory.java @@ -0,0 +1,5 @@ +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 new file mode 100644 index 000000000..f201e019d --- /dev/null +++ b/skywalking-registry/src/main/java/com/a/eye/skywalking/registry/api/RegistryData.java @@ -0,0 +1,15 @@ +package com.a.eye.skywalking.registry.api; + +/** + * Created by xin on 2016/11/9. + */ +public class RegistryData { + + public String key() { + return null; + } + + public String data() { + return null; + } +} 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 new file mode 100644 index 000000000..05f05d371 --- /dev/null +++ b/skywalking-registry/src/main/java/com/a/eye/skywalking/registry/impl/DefaultRegistry.java @@ -0,0 +1,19 @@ +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 new file mode 100644 index 000000000..0a1cb162c --- /dev/null +++ b/skywalking-registry/src/main/java/com/a/eye/skywalking/registry/impl/DefaultRegistryFactory.java @@ -0,0 +1,14 @@ +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; + } +}