From c887abeb8c56df32f584335b15c1fad114c46a8c Mon Sep 17 00:00:00 2001 From: ascrutae Date: Wed, 9 Nov 2016 10:25:10 +0800 Subject: [PATCH] =?UTF-8?q?=E6=8F=90=E4=BA=A4registry=E5=B7=A5=E7=A8=8B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- skywalking-registry/pom.xml | 22 +++++++++++++++++++ .../registry/api/NotifyListener.java | 7 ++++++ .../eye/skywalking/registry/api/Register.java | 12 ++++++++++ .../registry/api/RegisterFactory.java | 5 +++++ .../skywalking/registry/api/RegistryData.java | 15 +++++++++++++ .../registry/impl/DefaultRegistry.java | 19 ++++++++++++++++ .../registry/impl/DefaultRegistryFactory.java | 14 ++++++++++++ 7 files changed, 94 insertions(+) create mode 100644 skywalking-registry/pom.xml create mode 100644 skywalking-registry/src/main/java/com/a/eye/skywalking/registry/api/NotifyListener.java create mode 100644 skywalking-registry/src/main/java/com/a/eye/skywalking/registry/api/Register.java create mode 100644 skywalking-registry/src/main/java/com/a/eye/skywalking/registry/api/RegisterFactory.java create mode 100644 skywalking-registry/src/main/java/com/a/eye/skywalking/registry/api/RegistryData.java create mode 100644 skywalking-registry/src/main/java/com/a/eye/skywalking/registry/impl/DefaultRegistry.java create mode 100644 skywalking-registry/src/main/java/com/a/eye/skywalking/registry/impl/DefaultRegistryFactory.java 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; + } +}