fetch task

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

@@ -1,4 +1,13 @@
 package com.apache.eventmesh.admin.server.web.handler;
 
-public abstract class BaseHandler {
+import org.apache.eventmesh.common.adminserver.request.BaseRequest;
+import org.apache.eventmesh.common.adminserver.response.BaseResponse;
+import org.apache.eventmesh.common.protocol.grpc.adminserver.Metadata;
+
+public abstract class BaseHandler<T extends BaseRequest, S extends BaseResponse> {
+    public BaseResponse handlerRequest(T request, Metadata metadata) {
+        return handler(request, metadata);
+    }
+
+    public abstract S handler(T request, Metadata metadata);
 }

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

@@ -1,4 +1,14 @@
 package com.apache.eventmesh.admin.server.web.handler;
 
-public class FetchJobByPrimaryKeyReqHandler extends BaseHandler {
+import org.apache.eventmesh.common.adminserver.request.FetchJobByPrimaryKeyReq;
+import org.apache.eventmesh.common.adminserver.response.JobDetailsResponse;
+import org.apache.eventmesh.common.protocol.grpc.adminserver.Metadata;
+
+public class FetchJobByPrimaryKeyReqHandler extends BaseHandler<FetchJobByPrimaryKeyReq, JobDetailsResponse> {
+
+    @Override
+    public JobDetailsResponse handler(FetchJobByPrimaryKeyReq request, Metadata metadata) {
+        JobDetailsResponse response = new JobDetailsResponse();
+        return response;
+    }
 }

eventmesh-common/src/main/java/org/apache/eventmesh/common/adminserver/job/DataSourceClassify.java

@@ -0,0 +1,8 @@
+package org.apache.eventmesh.common.adminserver.job;
+
+public enum DataSourceClassify {
+    // relationship db
+    RDB,
+    MQ,
+    CACHE;
+}

eventmesh-common/src/main/java/org/apache/eventmesh/common/adminserver/job/DataSourceDriverType.java

@@ -0,0 +1,7 @@
+package org.apache.eventmesh.common.adminserver.job;
+
+public enum DataSourceDriverType {
+    MYSQL,
+    REDIS,
+    ROCKETMQ;
+}

eventmesh-common/src/main/java/org/apache/eventmesh/common/adminserver/job/DataSourceType.java

@@ -0,0 +1,16 @@
+package org.apache.eventmesh.common.adminserver.job;
+
+public enum DataSourceType {
+    MYSQL("MySQL", DataSourceDriverType.MYSQL, DataSourceClassify.RDB),
+    REDIS("Redis", DataSourceDriverType.REDIS, DataSourceClassify.CACHE),
+    ROCKETMQ("RocketMQ", DataSourceDriverType.ROCKETMQ, DataSourceClassify.MQ);
+    private String name;
+    private DataSourceDriverType driverType;
+    private DataSourceClassify classify;
+
+    DataSourceType(String name, DataSourceDriverType driverType, DataSourceClassify classify) {
+        this.name = name;
+        this.driverType = driverType;
+        this.classify = classify;
+    }
+}

eventmesh-common/src/main/java/org/apache/eventmesh/common/adminserver/job/JobTransportType.java

@@ -0,0 +1,12 @@
+package org.apache.eventmesh.common.adminserver.job;
+
+public enum JobTransportType {
+    MYSQL_MYSQL(DataSourceType.MYSQL, DataSourceType.MYSQL),
+    REDIS_REDIS(DataSourceType.REDIS, DataSourceType.REDIS),
+    ROCKETMQ_ROCKETMQ(DataSourceType.ROCKETMQ,DataSourceType.ROCKETMQ);
+
+
+    JobTransportType(DataSourceType src, DataSourceType dst) {
+
+    }
+}

eventmesh-common/src/main/java/org/apache/eventmesh/common/adminserver/response/BaseResponse.java

@@ -0,0 +1,4 @@
+package org.apache.eventmesh.common.adminserver.response;
+
+public abstract class BaseResponse {
+}

eventmesh-common/src/main/java/org/apache/eventmesh/common/adminserver/response/JobDetailsResponse.java

@@ -0,0 +1,14 @@
+package org.apache.eventmesh.common.adminserver.response;
+
+import org.apache.eventmesh.common.adminserver.job.JobTransportType;
+
+public class JobDetailsResponse extends BaseResponse{
+    private long id;
+    private String name;
+    private String desc;
+    private String sourceUser;
+    private String sourcePasswd;
+    private String targetUser;
+    private String targetPasswd;
+    private JobTransportType transportType;
+}