You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@eventmesh.apache.org by ch...@apache.org on 2021/09/14 09:11:02 UTC

[incubator-eventmesh] branch develop updated: [ISSUE #435] Initial Creation of eventMesh-admin module in EventMesh (#513)

This is an automated email from the ASF dual-hosted git repository.

chenguangsheng pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git


The following commit(s) were added to refs/heads/develop by this push:
     new bd8d736  [ISSUE #435] Initial Creation of eventMesh-admin module in EventMesh (#513)
bd8d736 is described below

commit bd8d73640c9d8b00ad6a097d5883634addfc13f6
Author: yuri <yu...@huawei.com>
AuthorDate: Tue Sep 14 05:10:55 2021 -0400

    [ISSUE #435] Initial Creation of eventMesh-admin module in EventMesh (#513)
    
    * initial checkin of eventmesh-schema-plugin
    
    * add file header
    
    * rework pr to add eventmesh-admin module
    
    * typo in readme
    
    * add topic rest apis in readme
    
    * add topic rest apis in readme
    
    * move schema registry out of this pr
    
    * move schema registry out of this pr
---
 build.gradle                                       |  1 +
 eventmesh-admin/README.md                          | 53 ++++++++++++++++++++++
 settings.gradle => eventmesh-admin/build.gradle    | 17 +------
 eventmesh-admin/gradle.properties                  | 16 +++++++
 eventmesh-runtime/build.gradle                     |  1 -
 .../admin/controller/ClientManageController.java   |  2 +-
 settings.gradle                                    |  1 +
 7 files changed, 74 insertions(+), 17 deletions(-)

diff --git a/build.gradle b/build.gradle
index 5cd021d..c24692a 100644
--- a/build.gradle
+++ b/build.gradle
@@ -202,6 +202,7 @@ subprojects {
                 exclude 'eventmesh-common*.jar'
                 exclude 'eventmesh-connector-api*.jar'
                 exclude 'eventmesh-connector-plugin*.jar'
+                exclude 'eventmesh-admin*.jar'
                 exclude 'eventmesh-starter*.jar'
                 exclude 'eventmesh-test*.jar'
                 exclude 'eventmesh-sdk*.jar'
diff --git a/eventmesh-admin/README.md b/eventmesh-admin/README.md
new file mode 100644
index 0000000..84f8047
--- /dev/null
+++ b/eventmesh-admin/README.md
@@ -0,0 +1,53 @@
+# EventMesh Administration Module
+
+EventMesh Administration Module for EventMesh. It manages Admin Service, Configurations such as topics/subscriptions management.It works as a control plane and provide some interface to manage the eventmesh-runtime module and other configurations.
+
+## Administration Client Manager APIs
+
+### POST /clientmanage/topics/
+- Create a new topic if does not exist
+- Exposed POST endpoint to create a new topic if it does not exist.
+    * Url - http://localhost:8081/clientmanage/topics/
+    * sample request payload 
+     ```json
+        {
+            "name":  "mytopic1"
+        }
+     ```
+
+   Sample response 
+
+   ```json
+   {
+        "topic": "mytopic1",
+        "created_time": "2021-09-03",
+   }
+   ```
+### DELETE /clientmanage/topics/(string: topic)/
+- Delete a specific topic.
+- Exposed DELETE endpoint to remove a specific topic
+    * URL -     
+    ```url 
+    http://localhost:8081/clientmanage/topics/mytopic1
+    ```
+    
+    * Response - 
+    
+   ```json
+   {
+        "topic": "mytopic1",        
+   }
+   ```
+
+### GET /clientmanage/topics 
+- Retrieve a list of topics
+- Exposed GET endpoint to retrieve all topics
+    * URL - 
+    ```url 
+    http://localhost:8081/clientmanage/topics
+    ```
+    * Response 
+    
+   ```json
+   ["mytopic1", "mytopic2"]
+   ```
diff --git a/settings.gradle b/eventmesh-admin/build.gradle
similarity index 57%
copy from settings.gradle
copy to eventmesh-admin/build.gradle
index e5b8965..2bbbee2 100644
--- a/settings.gradle
+++ b/eventmesh-admin/build.gradle
@@ -15,18 +15,5 @@
  * limitations under the License.
  */
 
-rootProject.name = 'EventMesh'
-String jdkVersion = "${jdk}"
-include 'eventmesh-runtime'
-include 'eventmesh-sdk-java'
-include 'eventmesh-common'
-include 'eventmesh-starter'
-include 'eventmesh-examples'
-include 'eventmesh-spi'
-include 'eventmesh-connector-plugin:eventmesh-connector-api'
-include 'eventmesh-connector-plugin:eventmesh-connector-rocketmq'
-include 'eventmesh-security-plugin:eventmesh-security-api'
-include 'eventmesh-security-plugin:eventmesh-security-acl'
-include 'eventmesh-registry-plugin:eventmesh-registry-api'
-include 'eventmesh-registry-plugin:eventmesh-registry-rocketmq-namesrv'
-
+dependencies {
+}
\ No newline at end of file
diff --git a/eventmesh-admin/gradle.properties b/eventmesh-admin/gradle.properties
new file mode 100644
index 0000000..a9fd83f
--- /dev/null
+++ b/eventmesh-admin/gradle.properties
@@ -0,0 +1,16 @@
+#
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements.  See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License.  You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
\ No newline at end of file
diff --git a/eventmesh-runtime/build.gradle b/eventmesh-runtime/build.gradle
index ffa13cc..0f5ca14 100644
--- a/eventmesh-runtime/build.gradle
+++ b/eventmesh-runtime/build.gradle
@@ -29,7 +29,6 @@ dependencies {
     implementation project(":eventmesh-registry-plugin:eventmesh-registry-api")
     implementation project(":eventmesh-registry-plugin:eventmesh-registry-rocketmq-namesrv")
 
-
     testImplementation project(":eventmesh-connector-plugin:eventmesh-connector-api")
     testImplementation project(":eventmesh-security-plugin:eventmesh-security-api")
     testImplementation project(":eventmesh-security-plugin:eventmesh-security-acl")
diff --git a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/controller/ClientManageController.java b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/controller/ClientManageController.java
index e2cb042..cd6d094 100644
--- a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/controller/ClientManageController.java
+++ b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/controller/ClientManageController.java
@@ -53,4 +53,4 @@ public class ClientManageController {
         server.start();
         logger.info("ClientManageController start success, port:{}", port);
     }
-}
+}
\ No newline at end of file
diff --git a/settings.gradle b/settings.gradle
index e5b8965..92c8c5b 100644
--- a/settings.gradle
+++ b/settings.gradle
@@ -29,4 +29,5 @@ include 'eventmesh-security-plugin:eventmesh-security-api'
 include 'eventmesh-security-plugin:eventmesh-security-acl'
 include 'eventmesh-registry-plugin:eventmesh-registry-api'
 include 'eventmesh-registry-plugin:eventmesh-registry-rocketmq-namesrv'
+include 'eventmesh-admin'
 

---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org