style: just rename SDK

apache · Mar 15, 2024 · 559da54 · 559da54
1 parent a2a67e9
commit 559da54
Show file tree

Hide file tree

Showing 20 changed files with 94 additions and 94 deletions.
diff --git a/...function/client/AbstractSDKOperation.java → ...le/function/SDK/AbstractSDKOperation.java b/...function/client/AbstractSDKOperation.java → ...le/function/SDK/AbstractSDKOperation.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.eventmesh.dashboard.console.function.client;
+package org.apache.eventmesh.dashboard.console.function.SDK;
 
 public abstract class AbstractSDKOperation<T> implements SDKOperation<T> {
 

diff --git a/...d/console/function/client/SDKManager.java → ...oard/console/function/SDK/SDKManager.java b/...d/console/function/client/SDKManager.java → ...oard/console/function/SDK/SDKManager.java
@@ -15,16 +15,16 @@
  * limitations under the License.
  */
 
-package org.apache.eventmesh.dashboard.console.function.client;
+package org.apache.eventmesh.dashboard.console.function.SDK;
 
-import org.apache.eventmesh.dashboard.console.function.client.config.CreateClientConfig;
-import org.apache.eventmesh.dashboard.console.function.client.operation.NacosConfigSDKOperation;
-import org.apache.eventmesh.dashboard.console.function.client.operation.NacosNamingSDKOperation;
-import org.apache.eventmesh.dashboard.console.function.client.operation.NacosSDKOperation;
-import org.apache.eventmesh.dashboard.console.function.client.operation.RedisSDKOperation;
-import org.apache.eventmesh.dashboard.console.function.client.operation.RocketMQProduceSDKOperation;
-import org.apache.eventmesh.dashboard.console.function.client.operation.RocketMQPushConsumerSDKOperation;
-import org.apache.eventmesh.dashboard.console.function.client.operation.RocketMQRemotingSDKOperation;
+import org.apache.eventmesh.dashboard.console.function.SDK.config.CreateSDKConfig;
+import org.apache.eventmesh.dashboard.console.function.SDK.operation.NacosConfigSDKOperation;
+import org.apache.eventmesh.dashboard.console.function.SDK.operation.NacosNamingSDKOperation;
+import org.apache.eventmesh.dashboard.console.function.SDK.operation.NacosSDKOperation;
+import org.apache.eventmesh.dashboard.console.function.SDK.operation.RedisSDKOperation;
+import org.apache.eventmesh.dashboard.console.function.SDK.operation.RocketMQProduceSDKOperation;
+import org.apache.eventmesh.dashboard.console.function.SDK.operation.RocketMQPushConsumerSDKOperation;
+import org.apache.eventmesh.dashboard.console.function.SDK.operation.RocketMQRemotingSDKOperation;
 
 import java.util.AbstractMap.SimpleEntry;
 import java.util.Map;
@@ -49,39 +49,39 @@ public static SDKManager getInstance() {
     /**
      * inner key is the unique key of a client, such as (ip + port) they are defined in CreateClientConfig
      *
-     * @see CreateClientConfig#getUniqueKey()
+     * @see CreateSDKConfig#getUniqueKey()
      */
 
-    private final Map<ClientTypeEnum, Map<String, Object>> clientMap = new ConcurrentHashMap<>();
+    private final Map<SDKTypeEnum, Map<String, Object>> clientMap = new ConcurrentHashMap<>();
 
-    private final Map<ClientTypeEnum, SDKOperation<?>> clientCreateOperationMap = new ConcurrentHashMap<>();
+    private final Map<SDKTypeEnum, SDKOperation<?>> clientCreateOperationMap = new ConcurrentHashMap<>();
 
     // register all client create operation
     {
-        for (ClientTypeEnum clientTypeEnum : ClientTypeEnum.values()) {
+        for (SDKTypeEnum clientTypeEnum : SDKTypeEnum.values()) {
             clientMap.put(clientTypeEnum, new ConcurrentHashMap<>());
         }
 
-        clientCreateOperationMap.put(ClientTypeEnum.STORAGE_REDIS, new RedisSDKOperation());
+        clientCreateOperationMap.put(SDKTypeEnum.STORAGE_REDIS, new RedisSDKOperation());
 
-        clientCreateOperationMap.put(ClientTypeEnum.STORAGE_ROCKETMQ_REMOTING, new RocketMQRemotingSDKOperation());
-        clientCreateOperationMap.put(ClientTypeEnum.STORAGE_ROCKETMQ_PRODUCER, new RocketMQProduceSDKOperation());
-        clientCreateOperationMap.put(ClientTypeEnum.STORAGE_ROCKETMQ_CONSUMER, new RocketMQPushConsumerSDKOperation());
+        clientCreateOperationMap.put(SDKTypeEnum.STORAGE_ROCKETMQ_REMOTING, new RocketMQRemotingSDKOperation());
+        clientCreateOperationMap.put(SDKTypeEnum.STORAGE_ROCKETMQ_PRODUCER, new RocketMQProduceSDKOperation());
+        clientCreateOperationMap.put(SDKTypeEnum.STORAGE_ROCKETMQ_CONSUMER, new RocketMQPushConsumerSDKOperation());
 
-        clientCreateOperationMap.put(ClientTypeEnum.CENTER_NACOS, new NacosSDKOperation());
-        clientCreateOperationMap.put(ClientTypeEnum.CENTER_NACOS_CONFIG, new NacosConfigSDKOperation());
-        clientCreateOperationMap.put(ClientTypeEnum.CENTER_NACOS_NAMING, new NacosNamingSDKOperation());
+        clientCreateOperationMap.put(SDKTypeEnum.META_NACOS, new NacosSDKOperation());
+        clientCreateOperationMap.put(SDKTypeEnum.META_NACOS_CONFIG, new NacosConfigSDKOperation());
+        clientCreateOperationMap.put(SDKTypeEnum.META_NACOS_NAMING, new NacosNamingSDKOperation());
 
     }
 
     private SDKManager() {
     }
 
-    public <T> SimpleEntry<String, T> createClient(ClientTypeEnum clientTypeEnum, CreateClientConfig config) {
+    public <T> SimpleEntry<String, T> createClient(SDKTypeEnum clientTypeEnum, CreateSDKConfig config) {
         return createClient(clientTypeEnum, config.getUniqueKey(), config);
     }
 
-    public <T> SimpleEntry<String, T> createClient(ClientTypeEnum clientTypeEnum, String uniqueKey, CreateClientConfig config) {
+    public <T> SimpleEntry<String, T> createClient(SDKTypeEnum clientTypeEnum, String uniqueKey, CreateSDKConfig config) {
 
         Map<String, Object> clients = this.clientMap.get(clientTypeEnum);
 
@@ -99,7 +99,7 @@ public <T> SimpleEntry<String, T> createClient(ClientTypeEnum clientTypeEnum, St
         }
     }
 
-    public void deleteClient(ClientTypeEnum clientTypeEnum, String uniqueKey) {
+    public void deleteClient(SDKTypeEnum clientTypeEnum, String uniqueKey) {
         Map<String, Object> clients = this.clientMap.get(clientTypeEnum);
         SDKOperation<?> operation = this.clientCreateOperationMap.get(clientTypeEnum);
         try {
@@ -110,7 +110,7 @@ public void deleteClient(ClientTypeEnum clientTypeEnum, String uniqueKey) {
         clients.remove(uniqueKey);
     }
 
-    public Object getClient(ClientTypeEnum clientTypeEnum, String uniqueKey) {
+    public Object getClient(SDKTypeEnum clientTypeEnum, String uniqueKey) {
         return this.clientMap.get(clientTypeEnum).get(uniqueKey);
     }
 }
diff --git a/...console/function/client/SDKOperation.java → ...rd/console/function/SDK/SDKOperation.java b/...console/function/client/SDKOperation.java → ...rd/console/function/SDK/SDKOperation.java
@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package org.apache.eventmesh.dashboard.console.function.client;
+package org.apache.eventmesh.dashboard.console.function.SDK;
 
-import org.apache.eventmesh.dashboard.console.function.client.config.CreateClientConfig;
+import org.apache.eventmesh.dashboard.console.function.SDK.config.CreateSDKConfig;
 
 import java.util.AbstractMap.SimpleEntry;
 
@@ -28,7 +28,7 @@
  */
 public interface SDKOperation<T> {
 
-    public SimpleEntry<String, T> createClient(CreateClientConfig clientConfig);
+    public SimpleEntry<String, T> createClient(CreateSDKConfig clientConfig);
 
 
     public void close(Object client);

diff --git a/...nsole/function/client/ClientTypeEnum.java → ...ard/console/function/SDK/SDKTypeEnum.java b/...nsole/function/client/ClientTypeEnum.java → ...ard/console/function/SDK/SDKTypeEnum.java
@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package org.apache.eventmesh.dashboard.console.function.client;
+package org.apache.eventmesh.dashboard.console.function.SDK;
 
-public enum ClientTypeEnum {
+public enum SDKTypeEnum {
 
     RUNTIME,
 
@@ -29,10 +29,10 @@ public enum ClientTypeEnum {
 
     STORAGE_REDIS,
 
-    CENTER_NACOS,
-    CENTER_NACOS_CONFIG,
+    META_NACOS,
+    META_NACOS_CONFIG,
 
-    CENTER_NACOS_NAMING,
+    META_NACOS_NAMING,
 
 
 }
diff --git a/...tion/client/config/CreateNacosConfig.java → ...unction/SDK/config/CreateNacosConfig.java b/...tion/client/config/CreateNacosConfig.java → ...unction/SDK/config/CreateNacosConfig.java
@@ -15,12 +15,12 @@
  * limitations under the License.
  */
 
-package org.apache.eventmesh.dashboard.console.function.client.config;
+package org.apache.eventmesh.dashboard.console.function.SDK.config;
 
 import lombok.Data;
 
 @Data
-public class CreateNacosConfig implements CreateClientConfig {
+public class CreateNacosConfig implements CreateSDKConfig {
 
     private String serverAddress;
 

diff --git a/...tion/client/config/CreateRedisConfig.java → ...unction/SDK/config/CreateRedisConfig.java b/...tion/client/config/CreateRedisConfig.java → ...unction/SDK/config/CreateRedisConfig.java
@@ -15,12 +15,12 @@
  * limitations under the License.
  */
 
-package org.apache.eventmesh.dashboard.console.function.client.config;
+package org.apache.eventmesh.dashboard.console.function.SDK.config;
 
 import lombok.Data;
 
 @Data
-public class CreateRedisConfig implements CreateClientConfig {
+public class CreateRedisConfig implements CreateSDKConfig {
 
     private String redisUrl;
 

diff --git a/...n/client/config/CreateRocketmqConfig.java → ...tion/SDK/config/CreateRocketmqConfig.java b/...n/client/config/CreateRocketmqConfig.java → ...tion/SDK/config/CreateRocketmqConfig.java
@@ -15,15 +15,15 @@
  * limitations under the License.
  */
 
-package org.apache.eventmesh.dashboard.console.function.client.config;
+package org.apache.eventmesh.dashboard.console.function.SDK.config;
 
 import org.apache.rocketmq.client.consumer.listener.MessageListener;
 import org.apache.rocketmq.common.protocol.heartbeat.MessageModel;
 
 import lombok.Data;
 
 @Data
-public class CreateRocketmqConfig implements CreateClientConfig {
+public class CreateRocketmqConfig implements CreateSDKConfig {
 
     // common
     private String nameServerUrl;

diff --git a/...ion/client/config/CreateClientConfig.java → .../function/SDK/config/CreateSDKConfig.java b/...ion/client/config/CreateClientConfig.java → .../function/SDK/config/CreateSDKConfig.java
@@ -15,12 +15,12 @@
  * limitations under the License.
  */
 
-package org.apache.eventmesh.dashboard.console.function.client.config;
+package org.apache.eventmesh.dashboard.console.function.SDK.config;
 
 /**
  * Config to create an SDK client, usually contains an address url.
  */
-public interface CreateClientConfig {
+public interface CreateSDKConfig {
 
     String getUniqueKey();
 }
diff --git a/...on/client/operation/EtcdSDKOperation.java → ...ction/SDK/operation/EtcdSDKOperation.java b/...on/client/operation/EtcdSDKOperation.java → ...ction/SDK/operation/EtcdSDKOperation.java
@@ -15,16 +15,16 @@
  * limitations under the License.
  */
 
-package org.apache.eventmesh.dashboard.console.function.client.operation;
+package org.apache.eventmesh.dashboard.console.function.SDK.operation;
 
-import org.apache.eventmesh.dashboard.console.function.client.AbstractSDKOperation;
-import org.apache.eventmesh.dashboard.console.function.client.config.CreateClientConfig;
+import org.apache.eventmesh.dashboard.console.function.SDK.AbstractSDKOperation;
+import org.apache.eventmesh.dashboard.console.function.SDK.config.CreateSDKConfig;
 
 import java.util.AbstractMap.SimpleEntry;
 
 public class EtcdSDKOperation extends AbstractSDKOperation {
     @Override
-    public SimpleEntry createClient(CreateClientConfig clientConfig) {
+    public SimpleEntry createClient(CreateSDKConfig clientConfig) {
         return null;
     }
 

diff --git a/...nt/operation/NacosConfigSDKOperation.java → ...DK/operation/NacosConfigSDKOperation.java b/...nt/operation/NacosConfigSDKOperation.java → ...DK/operation/NacosConfigSDKOperation.java
@@ -15,11 +15,11 @@
  * limitations under the License.
  */
 
-package org.apache.eventmesh.dashboard.console.function.client.operation;
+package org.apache.eventmesh.dashboard.console.function.SDK.operation;
 
-import org.apache.eventmesh.dashboard.console.function.client.AbstractSDKOperation;
-import org.apache.eventmesh.dashboard.console.function.client.config.CreateClientConfig;
-import org.apache.eventmesh.dashboard.console.function.client.config.CreateNacosConfig;
+import org.apache.eventmesh.dashboard.console.function.SDK.AbstractSDKOperation;
+import org.apache.eventmesh.dashboard.console.function.SDK.config.CreateSDKConfig;
+import org.apache.eventmesh.dashboard.console.function.SDK.config.CreateNacosConfig;
 
 import java.util.AbstractMap.SimpleEntry;
 import java.util.Properties;
@@ -34,7 +34,7 @@
 public class NacosConfigSDKOperation extends AbstractSDKOperation<ConfigService> {
 
     @Override
-    public SimpleEntry<String, ConfigService> createClient(CreateClientConfig clientConfig) {
+    public SimpleEntry<String, ConfigService> createClient(CreateSDKConfig clientConfig) {
         ConfigService configService = null;
         CreateNacosConfig config = (CreateNacosConfig) clientConfig;
         try {

diff --git a/...nt/operation/NacosNamingSDKOperation.java → ...DK/operation/NacosNamingSDKOperation.java b/...nt/operation/NacosNamingSDKOperation.java → ...DK/operation/NacosNamingSDKOperation.java
@@ -15,11 +15,11 @@
  * limitations under the License.
  */
 
-package org.apache.eventmesh.dashboard.console.function.client.operation;
+package org.apache.eventmesh.dashboard.console.function.SDK.operation;
 
-import org.apache.eventmesh.dashboard.console.function.client.AbstractSDKOperation;
-import org.apache.eventmesh.dashboard.console.function.client.config.CreateClientConfig;
-import org.apache.eventmesh.dashboard.console.function.client.config.CreateNacosConfig;
+import org.apache.eventmesh.dashboard.console.function.SDK.AbstractSDKOperation;
+import org.apache.eventmesh.dashboard.console.function.SDK.config.CreateSDKConfig;
+import org.apache.eventmesh.dashboard.console.function.SDK.config.CreateNacosConfig;
 
 import java.util.AbstractMap.SimpleEntry;
 import java.util.Properties;
@@ -35,7 +35,7 @@
 public class NacosNamingSDKOperation extends AbstractSDKOperation<NamingService> {
 
     @Override
-    public SimpleEntry<String, NamingService> createClient(CreateClientConfig clientConfig) {
+    public SimpleEntry<String, NamingService> createClient(CreateSDKConfig clientConfig) {
         NamingService namingService = null;
         CreateNacosConfig config = (CreateNacosConfig) clientConfig;
         try {

diff --git a/...n/client/operation/NacosSDKOperation.java → ...tion/SDK/operation/NacosSDKOperation.java b/...n/client/operation/NacosSDKOperation.java → ...tion/SDK/operation/NacosSDKOperation.java
@@ -15,30 +15,30 @@
  * limitations under the License.
  */
 
-package org.apache.eventmesh.dashboard.console.function.client.operation;
+package org.apache.eventmesh.dashboard.console.function.SDK.operation;
 
-import org.apache.eventmesh.dashboard.console.function.client.AbstractSDKOperation;
-import org.apache.eventmesh.dashboard.console.function.client.config.CreateClientConfig;
-import org.apache.eventmesh.dashboard.console.function.client.wrapper.NacosClientWrapper;
+import org.apache.eventmesh.dashboard.console.function.SDK.AbstractSDKOperation;
+import org.apache.eventmesh.dashboard.console.function.SDK.config.CreateSDKConfig;
+import org.apache.eventmesh.dashboard.console.function.SDK.wrapper.NacosSDKWrapper;
 
 import java.util.AbstractMap.SimpleEntry;
 
 import com.alibaba.nacos.api.config.ConfigService;
 import com.alibaba.nacos.api.naming.NamingService;
 
-public class NacosSDKOperation extends AbstractSDKOperation<NacosClientWrapper> {
+public class NacosSDKOperation extends AbstractSDKOperation<NacosSDKWrapper> {
 
     private final NacosConfigSDKOperation nacosConfigClientCreateOperation = new NacosConfigSDKOperation();
     private final NacosNamingSDKOperation nacosNamingClientCreateOperation = new NacosNamingSDKOperation();
 
     @Override
-    public SimpleEntry<String, NacosClientWrapper> createClient(CreateClientConfig createClientConfig) {
+    public SimpleEntry<String, NacosSDKWrapper> createClient(CreateSDKConfig createClientConfig) {
         SimpleEntry<String, ConfigService> configSimpleEntry = nacosConfigClientCreateOperation.createClient(createClientConfig);
         SimpleEntry namingSimpleEntry = nacosNamingClientCreateOperation.createClient(createClientConfig);
         if (configSimpleEntry.getKey() != namingSimpleEntry.getKey()) {
             throw new RuntimeException("Nacos config and naming server address not match");
         }
-        NacosClientWrapper nacosClient = new NacosClientWrapper(
+        NacosSDKWrapper nacosClient = new NacosSDKWrapper(
             (ConfigService) configSimpleEntry.getValue(), (NamingService) namingSimpleEntry.getValue()
         );
         return new SimpleEntry<>(configSimpleEntry.getKey(), nacosClient);

diff --git a/...n/client/operation/RedisSDKOperation.java → ...tion/SDK/operation/RedisSDKOperation.java b/...n/client/operation/RedisSDKOperation.java → ...tion/SDK/operation/RedisSDKOperation.java
@@ -15,11 +15,11 @@
  * limitations under the License.
  */
 
-package org.apache.eventmesh.dashboard.console.function.client.operation;
+package org.apache.eventmesh.dashboard.console.function.SDK.operation;
 
-import org.apache.eventmesh.dashboard.console.function.client.AbstractSDKOperation;
-import org.apache.eventmesh.dashboard.console.function.client.config.CreateClientConfig;
-import org.apache.eventmesh.dashboard.console.function.client.config.CreateRedisConfig;
+import org.apache.eventmesh.dashboard.console.function.SDK.AbstractSDKOperation;
+import org.apache.eventmesh.dashboard.console.function.SDK.config.CreateSDKConfig;
+import org.apache.eventmesh.dashboard.console.function.SDK.config.CreateRedisConfig;
 
 import java.util.AbstractMap.SimpleEntry;
 
@@ -29,7 +29,7 @@
 public class RedisSDKOperation extends AbstractSDKOperation<StatefulRedisConnection<String, String>> {
 
     @Override
-    public SimpleEntry<String, StatefulRedisConnection<String, String>> createClient(CreateClientConfig clientConfig) {
+    public SimpleEntry<String, StatefulRedisConnection<String, String>> createClient(CreateSDKConfig clientConfig) {
         String redisUrl = ((CreateRedisConfig) clientConfig).getRedisUrl();
         RedisClient redisClient = RedisClient.create(redisUrl);
         return new SimpleEntry<>(clientConfig.getUniqueKey(), redisClient.connect());

diff --git a/...peration/RocketMQProduceSDKOperation.java → ...peration/RocketMQProduceSDKOperation.java b/...peration/RocketMQProduceSDKOperation.java → ...peration/RocketMQProduceSDKOperation.java
@@ -15,11 +15,11 @@
  * limitations under the License.
  */
 
-package org.apache.eventmesh.dashboard.console.function.client.operation;
+package org.apache.eventmesh.dashboard.console.function.SDK.operation;
 
-import org.apache.eventmesh.dashboard.console.function.client.AbstractSDKOperation;
-import org.apache.eventmesh.dashboard.console.function.client.config.CreateClientConfig;
-import org.apache.eventmesh.dashboard.console.function.client.config.CreateRocketmqConfig;
+import org.apache.eventmesh.dashboard.console.function.SDK.AbstractSDKOperation;
+import org.apache.eventmesh.dashboard.console.function.SDK.config.CreateSDKConfig;
+import org.apache.eventmesh.dashboard.console.function.SDK.config.CreateRocketmqConfig;
 
 import org.apache.rocketmq.client.exception.MQClientException;
 import org.apache.rocketmq.client.producer.DefaultMQProducer;
@@ -32,7 +32,7 @@
 public class RocketMQProduceSDKOperation extends AbstractSDKOperation<DefaultMQProducer> {
 
     @Override
-    public SimpleEntry<String, DefaultMQProducer> createClient(CreateClientConfig clientConfig) {
+    public SimpleEntry<String, DefaultMQProducer> createClient(CreateSDKConfig clientConfig) {
         DefaultMQProducer producer = null;
         try {
             CreateRocketmqConfig config = (CreateRocketmqConfig) clientConfig;

diff --git a/...ion/RocketMQPushConsumerSDKOperation.java → ...ion/RocketMQPushConsumerSDKOperation.java b/...ion/RocketMQPushConsumerSDKOperation.java → ...ion/RocketMQPushConsumerSDKOperation.java
@@ -15,11 +15,11 @@
  * limitations under the License.
  */
 
-package org.apache.eventmesh.dashboard.console.function.client.operation;
+package org.apache.eventmesh.dashboard.console.function.SDK.operation;
 
-import org.apache.eventmesh.dashboard.console.function.client.AbstractSDKOperation;
-import org.apache.eventmesh.dashboard.console.function.client.config.CreateClientConfig;
-import org.apache.eventmesh.dashboard.console.function.client.config.CreateRocketmqConfig;
+import org.apache.eventmesh.dashboard.console.function.SDK.AbstractSDKOperation;
+import org.apache.eventmesh.dashboard.console.function.SDK.config.CreateSDKConfig;
+import org.apache.eventmesh.dashboard.console.function.SDK.config.CreateRocketmqConfig;
 
 import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
 import org.apache.rocketmq.client.exception.MQClientException;
@@ -32,7 +32,7 @@
 public class RocketMQPushConsumerSDKOperation extends AbstractSDKOperation<DefaultMQPushConsumer> {
 
     @Override
-    public SimpleEntry<String, DefaultMQPushConsumer> createClient(CreateClientConfig clientConfig) {
+    public SimpleEntry<String, DefaultMQPushConsumer> createClient(CreateSDKConfig clientConfig) {
         DefaultMQPushConsumer consumer = null;
         try {
             CreateRocketmqConfig config = (CreateRocketmqConfig) clientConfig;