Merge branch 'eventmesh-function' of https://github.com/xwm1992/Event…

…Mesh into eventmesh-function

build.gradle

@@ -577,7 +577,7 @@ subprojects {
             dependency "org.mybatis.spring.boot:mybatis-spring-boot-starter:2.3.1"
             dependency "com.alibaba:druid-spring-boot-starter:1.2.22"
             dependency "org.springframework.boot:spring-boot-starter-jetty:2.7.10"
-
+            dependency "com.baomidou:mybatis-plus:3.5.6"
             dependency "com.mysql:mysql-connector-j:8.0.33"
 
         }

eventmesh-admin-server/build.gradle

@@ -14,7 +14,9 @@ dependencies {
 	implementation "io.grpc:grpc-netty-shaded"
 
 
-	implementation "org.mybatis.spring.boot:mybatis-spring-boot-starter"
+	// https://mvnrepository.com/artifact/com.baomidou/mybatis-plus
+	implementation "com.baomidou:mybatis-plus"
+
 	// https://mvnrepository.com/artifact/com.alibaba/druid-spring-boot-starter
 	implementation "com.alibaba:druid-spring-boot-starter"
 	runtimeOnly 'com.mysql:mysql-connector-j'

eventmesh-admin-server/src/main/java/com/apache/eventmesh/admin/server/AdminException.java

@@ -1,11 +1,12 @@
 package com.apache.eventmesh.admin.server;
 
+import lombok.Getter;
+
 public class AdminException extends RuntimeException {
-    public AdminException(String message) {
+    @Getter
+    private final int code;
+    public AdminException(int code, String message) {
         super(message);
-    }
-
-    public AdminException(String message, Throwable cause) {
-        super(message, cause);
+        this.code = code;
     }
 }

eventmesh-admin-server/src/main/java/com/apache/eventmesh/admin/server/AdminServer.java

@@ -1,8 +1,8 @@
 package com.apache.eventmesh.admin.server;
 
-import org.apache.eventmesh.common.remote.Task;
 import org.apache.eventmesh.common.Constants;
 import org.apache.eventmesh.common.remote.HeartBeat;
+import org.apache.eventmesh.common.remote.Task;
 import org.apache.eventmesh.common.utils.IPUtils;
 import org.apache.eventmesh.common.utils.PagedList;
 import org.apache.eventmesh.registry.RegisterServerInfo;

eventmesh-admin-server/src/main/java/com/apache/eventmesh/admin/server/ExampleAdminServer.java

@@ -0,0 +1,11 @@
+package com.apache.eventmesh.admin.server;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication(scanBasePackages = "com.apache.eventmesh.admin.server")
+public class ExampleAdminServer {
+    public static void main(String[] args) {
+        SpringApplication.run(ExampleAdminServer.class);
+    }
+}

eventmesh-admin-server/src/main/java/com/apache/eventmesh/admin/server/web/AdminGrpcServer.java

@@ -6,6 +6,7 @@
 import io.grpc.stub.StreamObserver;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
+import org.apache.eventmesh.common.remote.exception.ErrorCode;
 import org.apache.eventmesh.common.remote.payload.PayloadUtil;
 import org.apache.eventmesh.common.remote.request.BaseGrpcRequest;
 import org.apache.eventmesh.common.remote.response.BaseGrpcResponse;
@@ -23,16 +24,20 @@ public class AdminGrpcServer extends AdminServiceGrpc.AdminServiceImplBase {
 
     private Payload process(Payload value) {
         if (value == null || StringUtils.isBlank(value.getMetadata().getType())) {
-
-            return PayloadUtil.from(FailResponse.build(BaseGrpcResponse.UNKNOWN, "bad request"));
+            return PayloadUtil.from(FailResponse.build(ErrorCode.BAD_REQUEST, "bad request: type not " +
+                    "exists"));
         }
-        BaseRequestHandler<BaseGrpcRequest, BaseGrpcResponse> handler =
-                handlerFactory.getHandler(value.getMetadata().getType());
-        if (handler == null) {
-            return PayloadUtil.from(FailResponse.build(BaseGrpcResponse.UNKNOWN,
-                    "not match any request handler"));
+        try {
+            BaseRequestHandler<BaseGrpcRequest, BaseGrpcResponse> handler =
+                    handlerFactory.getHandler(value.getMetadata().getType());
+            if (handler == null) {
+                return PayloadUtil.from(FailResponse.build(BaseGrpcResponse.UNKNOWN,
+                        "not match any request handler"));
+            }
+            return PayloadUtil.from(handler.handlerRequest(PayloadUtil.parse(value), value.getMetadata()));
+        } catch (Exception e) {
+            return null;
         }
-        return PayloadUtil.from(handler.handlerRequest(PayloadUtil.parse(value), value.getMetadata()));
     }
 
     public StreamObserver<Payload> invokeBiStream(StreamObserver<Payload> responseObserver) {

eventmesh-admin-server/src/main/java/com/apache/eventmesh/admin/server/web/db/entity/EventMeshDataSource.java

@@ -0,0 +1,25 @@
+package com.apache.eventmesh.admin.server.web.db.entity;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @TableName event_mesh_data_source
+ */
+@TableName(value ="event_mesh_data_source")
+@Data
+public class EventMeshDataSource implements Serializable {
+    private Integer id;
+
+    private Integer type;
+
+    private String address;
+
+    private String desc;
+
+    private String configuration;
+
+    private static final long serialVersionUID = 1L;
+}

eventmesh-admin-server/src/main/java/com/apache/eventmesh/admin/server/web/db/entity/EventMeshHeartbeat.java

@@ -0,0 +1,30 @@
+package com.apache.eventmesh.admin.server.web.db.entity;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * @TableName event_mesh_heartbeat
+ */
+@TableName(value ="event_mesh_heartbeat")
+@Data
+public class EventMeshHeartbeat implements Serializable {
+    private Integer id;
+
+    private String adminAddr;
+
+    private String runtimeAddr;
+
+    private Integer jobID;
+
+    private Integer positionID;
+
+    private Date reportTime;
+
+    private Date updateTime;
+
+    private static final long serialVersionUID = 1L;
+}

eventmesh-admin-server/src/main/java/com/apache/eventmesh/admin/server/web/db/entity/EventMeshJobInfo.java

@@ -0,0 +1,38 @@
+package com.apache.eventmesh.admin.server.web.db.entity;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * @TableName event_mesh_job_info
+ */
+@TableName(value ="event_mesh_job_info")
+@Data
+public class EventMeshJobInfo implements Serializable {
+    private Integer jobID;
+
+    private Integer transportType;
+
+    private Integer sourceData;
+
+    private Integer targetData;
+
+    private Integer state;
+
+    private Integer type;
+
+    private Integer position;
+
+    private Integer createUid;
+
+    private Integer updateUid;
+
+    private Date createTime;
+
+    private Date updateTime;
+
+    private static final long serialVersionUID = 1L;
+}

eventmesh-admin-server/src/main/java/com/apache/eventmesh/admin/server/web/db/entity/EventMeshJobPosition.java

@@ -0,0 +1,28 @@
+package com.apache.eventmesh.admin.server.web.db.entity;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * @TableName event_mesh_job_position
+ */
+@TableName(value ="event_mesh_job_position")
+@Data
+public class EventMeshJobPosition implements Serializable {
+    private Integer id;
+
+    private Integer jobID;
+
+    private String address;
+
+    private Long position;
+
+    private Date createTime;
+
+    private Date updateTime;
+
+    private static final long serialVersionUID = 1L;
+}

eventmesh-admin-server/src/main/java/com/apache/eventmesh/admin/server/web/db/mapper/EventMeshDataSourceMapper.java

@@ -0,0 +1,18 @@
+package com.apache.eventmesh.admin.server.web.db.mapper;
+
+import com.apache.eventmesh.admin.server.web.db.entity.EventMeshDataSource;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+* @author sodafang
+* @description 针对表【event_mesh_data_source】的数据库操作Mapper
+* @createDate 2024-05-06 10:57:45
+* @Entity generator.entity.EventMeshDataSource
+*/
+public interface EventMeshDataSourceMapper extends BaseMapper<EventMeshDataSource> {
+
+}
+
+
+
+

eventmesh-admin-server/src/main/java/com/apache/eventmesh/admin/server/web/db/mapper/EventMeshHeartbeatMapper.java

@@ -0,0 +1,18 @@
+package com.apache.eventmesh.admin.server.web.db.mapper;
+
+import com.apache.eventmesh.admin.server.web.db.entity.EventMeshHeartbeat;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+* @author sodafang
+* @description 针对表【event_mesh_heartbeat】的数据库操作Mapper
+* @createDate 2024-05-06 10:57:45
+* @Entity generator.entity.EventMeshHeartbeat
+*/
+public interface EventMeshHeartbeatMapper extends BaseMapper<EventMeshHeartbeat> {
+
+}
+
+
+
+

eventmesh-admin-server/src/main/java/com/apache/eventmesh/admin/server/web/db/mapper/EventMeshJobInfoMapper.java

@@ -0,0 +1,18 @@
+package com.apache.eventmesh.admin.server.web.db.mapper;
+
+import com.apache.eventmesh.admin.server.web.db.entity.EventMeshJobInfo;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+* @author sodafang
+* @description 针对表【event_mesh_job_info】的数据库操作Mapper
+* @createDate 2024-05-06 10:57:45
+* @Entity generator.entity.EventMeshJobInfo
+*/
+public interface EventMeshJobInfoMapper extends BaseMapper<EventMeshJobInfo> {
+
+}
+
+
+
+

eventmesh-admin-server/src/main/java/com/apache/eventmesh/admin/server/web/db/mapper/EventMeshJobPositionMapper.java

@@ -0,0 +1,18 @@
+package com.apache.eventmesh.admin.server.web.db.mapper;
+
+import com.apache.eventmesh.admin.server.web.db.entity.EventMeshJobPosition;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+* @author sodafang
+* @description 针对表【event_mesh_job_position】的数据库操作Mapper
+* @createDate 2024-05-06 10:57:45
+* @Entity generator.entity.EventMeshJobPosition
+*/
+public interface EventMeshJobPositionMapper extends BaseMapper<EventMeshJobPosition> {
+
+}
+
+
+
+

eventmesh-admin-server/src/main/java/com/apache/eventmesh/admin/server/web/db/service/EventMeshDataSourceService.java

@@ -0,0 +1,13 @@
+package com.apache.eventmesh.admin.server.web.db.service;
+
+import com.apache.eventmesh.admin.server.web.db.entity.EventMeshDataSource;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+* @author sodafang
+* @description 针对表【event_mesh_data_source】的数据库操作Service
+* @createDate 2024-05-06 10:57:45
+*/
+public interface EventMeshDataSourceService extends IService<EventMeshDataSource> {
+
+}

eventmesh-admin-server/src/main/java/com/apache/eventmesh/admin/server/web/db/service/EventMeshHeartbeatService.java

@@ -0,0 +1,13 @@
+package com.apache.eventmesh.admin.server.web.db.service;
+
+import com.apache.eventmesh.admin.server.web.db.entity.EventMeshHeartbeat;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+* @author sodafang
+* @description 针对表【event_mesh_heartbeat】的数据库操作Service
+* @createDate 2024-05-06 10:57:45
+*/
+public interface EventMeshHeartbeatService extends IService<EventMeshHeartbeat> {
+
+}

eventmesh-admin-server/src/main/java/com/apache/eventmesh/admin/server/web/db/service/EventMeshJobInfoService.java

@@ -0,0 +1,13 @@
+package com.apache.eventmesh.admin.server.web.db.service;
+
+import com.apache.eventmesh.admin.server.web.db.entity.EventMeshJobInfo;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+* @author sodafang
+* @description 针对表【event_mesh_job_info】的数据库操作Service
+* @createDate 2024-05-06 10:57:45
+*/
+public interface EventMeshJobInfoService extends IService<EventMeshJobInfo> {
+
+}

eventmesh-admin-server/src/main/java/com/apache/eventmesh/admin/server/web/db/service/EventMeshJobPositionService.java

@@ -0,0 +1,13 @@
+package com.apache.eventmesh.admin.server.web.db.service;
+
+import com.apache.eventmesh.admin.server.web.db.entity.EventMeshJobPosition;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+* @author sodafang
+* @description 针对表【event_mesh_job_position】的数据库操作Service
+* @createDate 2024-05-06 10:57:45
+*/
+public interface EventMeshJobPositionService extends IService<EventMeshJobPosition> {
+
+}

eventmesh-admin-server/src/main/java/com/apache/eventmesh/admin/server/web/db/service/impl/EventMeshDataSourceServiceImpl.java

@@ -0,0 +1,22 @@
+package com.apache.eventmesh.admin.server.web.db.service.impl;
+
+import com.apache.eventmesh.admin.server.web.db.entity.EventMeshDataSource;
+import com.apache.eventmesh.admin.server.web.db.mapper.EventMeshDataSourceMapper;
+import com.apache.eventmesh.admin.server.web.db.service.EventMeshDataSourceService;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.stereotype.Service;
+
+/**
+* @author sodafang
+* @description 针对表【event_mesh_data_source】的数据库操作Service实现
+* @createDate 2024-05-06 10:57:45
+*/
+@Service
+public class EventMeshDataSourceServiceImpl extends ServiceImpl<EventMeshDataSourceMapper, EventMeshDataSource>
+    implements EventMeshDataSourceService {
+
+}
+
+
+
+