This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch dependabot/gradle/jwtVersion-0.12.5
in repository https://gitbox.apache.org/repos/asf/eventmesh.git
discard ad4527cda Bump jwtVersion from 0.11.1 to 0.12.5
add a02f59049 Bump org.mongodb:mongodb-driver from 3.12.11 to 3.12.14
(#4117)
add 2ca048f53 Bump io.cloudevents:cloudevents-kafka from 2.2.1 to 2.5.0
(#3998)
add 8ac64bd00 Bump com.github.jk1.dependency-license-report from 2.6 to
2.7 (#4903)
add 5ce7b4e8c Bump org.springframework.boot:spring-boot-starter-web (#4908)
add b40407ad4 Bump org.apache.commons:commons-collections4 from 4.1 to 4.3
(#4905)
add 97c6d5bbc Bump com.google.code.gson:gson from 2.8.2 to 2.11.0 (#4900)
add 503139a6a Bump org.apache.zookeeper:zookeeper from 3.7.1 to 3.9.2
(#4909)
add 0aedb885e Bump software.amazon.awssdk:s3 from 2.20.29 to 2.25.55
(#4907)
add 86299019c Bump com.slack.api:bolt from 1.1.+ to 1.39.2 (#4901)
add f9e178482 Bump com.jayway.jsonpath:json-path from 2.7.0 to 2.9.0
(#4906)
add 9e4e87fa3 [ISSUE #4052] Implement the functionality of
EventMeshVersion class. (#4055)
add 8fad9dbf4 Bump com.google.protobuf from 0.8.17 to 0.9.4 (#4899)
add 152e48f49 [ISSUE #4866] Add unified deps version identifier & Upgrade
Gradle from 8.2.1 to 8.7 (#4867)
add 8d3d796e5 Bump dropwizardMetricsVersion from 4.1.0 to 4.2.25 (#4911)
add 1c22c16b5 Bump curatorVersion from 5.4.0 to 5.6.0 (#4910)
add ff1ccd7d4 Bump mockitoVersion from 3.8.0 to 3.12.4 (#4912)
add 6e741bf78 Bump com.alibaba.nacos:nacos-client from 2.2.3 to 2.3.2
(#4922)
add 29153722f Bump org.antlr:antlr4-runtime from 4.13.0 to 4.13.1 (#4923)
add 7c70e95f9 Bump com.github.spotbugs.snom:spotbugs-gradle-plugin (#4914)
add 1f35151ff Bump com.rabbitmq:amqp-client from 5.16.0 to 5.21.0 (#4917)
add ed425922f Bump org.projectlombok:lombok from 1.18.22 to 1.18.32 (#4920)
add a7ea4044c Bump com.google.guava:guava from 31.0.1-jre to 31.1-jre
(#4927)
add 7e53cde49 Bump cloudeventsVersion from 2.4.2 to 2.5.0 (#4925)
add 865186ca3 Bump com.zendesk:mysql-binlog-connector-java from 0.28.0 to
0.29.2 (#4918)
add a6310073b Bump io.vertx:vertx-web-client from 4.4.6 to 4.5.8 (#4915)
add d10656b7c Bump io.vertx:vertx-web from 4.4.6 to 4.5.8 (#4928)
add 06999b47f Bump grpcVersion from 1.43.2 to 1.64.0 (#4904)
add a1bee1f01 update readme file (#4942)
add f2161d41a Add files via upload (#4943)
add 75bb578bd Bump com.gradle.enterprise from 3.16.1 to 3.17.4 (#4926)
add 267250a8b Bump org.apache.httpcomponents:httpclient from 4.5.13 to
4.5.14 (#4919)
add 761366c86 update eventmesh architecture (#4944)
add 5a409fdd9 [ISSUE #4852] Support Jraft algorithm as meta storage
(#4862)
add f7a9517bf Merge EventMesh function branch to master (#4941)
add fdac21763 update eventmesh architecture (#4946)
add 498c35042 [ISSUE #3515] Do some code optimization[AuthTokenUtils]
(#3644)
add 6a158adf3 [ISSUE #4847] HTTPS/(m)TLSv1.3 support for HTTP Admin Server
(#4848)
add eebbde30d Bump protobufVersion from 3.21.5 to 3.25.3 (#4948)
add dd9d64aaf Bump org.antlr:antlr4 from 4.13.0 to 4.13.1 (#4952)
add 97068bc56 Bump com.baomidou:mybatis-plus-boot-starter from 3.5.5 to
3.5.6 (#4954)
add d0b61ed6a Bump io.spring.gradle:dependency-management-plugin (#4960)
add 48676ee02 Bump org.assertj:assertj-core from 2.6.0 to 2.8.0 (#4959)
add 6730bd5fc Bump com.aliyun:dingtalk from 2.0.61 to 2.1.25 (#4947)
add 027614fe7 Bump org.apache.commons:commons-lang3 from 3.6 to 3.14.0
(#4951)
add 7486a370e Bump com.mebigfatguy.fb-contrib:fb-contrib from 7.6.0 to
7.6.4 (#4950)
add 7140930ff Bump jacksonVersion from 2.0.1 to 2.17.1 (#4955)
add 1fcf5705f Bump io.cloudevents:cloudevents-http-vertx from 2.3.0 to
2.5.0 (#4956)
add b64d1e0d6 Bump com.github.seancfoley:ipaddress from 5.3.3 to 5.5.0
(#4953)
add e52084873 [ISSUE #4929] Auto approve when dependabot's branch is
changed by committers (#4930)
add 499aa7acf Bump org.redisson:redisson from 3.17.3 to 3.30.0 (#4924)
add 15fcd08c4 Bump com.alibaba.fastjson2:fastjson2 from 2.0.48 to 2.0.51
(#4975)
add 20b31c45e Bump mysql:mysql-connector-java from 8.0.32 to 8.0.33 (#4976)
add 10accdb91 Bump org.mybatis.spring.boot:mybatis-spring-boot-starter
(#4971)
add 2ef82c4c4 Bump com.h3xstream.findsecbugs:findsecbugs-plugin from
1.11.0 to 1.13.0 (#4974)
add 35e6bc445 Bump org.asynchttpclient:async-http-client from 2.12.0 to
2.12.3 (#4970)
add f0060a94c Bump commons-io:commons-io from 2.11.0 to 2.16.1 (#4968)
add 707f2614b Bump com.alibaba:druid-spring-boot-starter from 1.2.22 to
1.2.23 (#4972)
add 886bffe95 Bump software.amazon.awssdk:s3 from 2.25.55 to 2.25.64
(#4969)
add df8a973e5 Bump org.apache.commons:commons-text from 1.9 to 1.12.0
(#4967)
add e3e390b15 Bump org.junit.jupiter:junit-jupiter from 5.6.0 to 5.10.2
(#4966)
add a6014cdf7 Bump com.alibaba:druid from 1.2.6 to 1.2.23 (#4977)
add b809cea9c Bump commons-validator:commons-validator from 1.7 to 1.9.0
(#4978)
add ae238eb57 Bump org.springframework.boot:spring-boot-starter-jetty
(#4965)
add a66864a76 Bump com.google.protobuf from 0.8.17 to 0.9.4 (#4973)
add a89dbe131 Bump com.github.jk1.dependency-license-report from 2.7 to
2.8 (#4986)
add 2c39d7998 Bump software.amazon.awssdk:s3 from 2.25.64 to 2.25.69
(#4981)
add b7272e3c2 Bump com.aliyun:dingtalk from 2.1.25 to 2.1.26 (#4982)
add 342caf237 Bump org.redisson:redisson from 3.30.0 to 3.31.0 (#4980)
add 53f3a47ab Bump com.mysql:mysql-connector-j from 8.0.33 to 8.4.0 (#4983)
add 30384eac6 Bump dropwizardMetricsVersion from 4.2.25 to 4.2.26 (#4985)
add 7543ee270 Bump com.baomidou:mybatis-plus-boot-starter from 3.5.6 to
3.5.7 (#5000)
add 5bcb63b0e Bump com.baomidou:mybatis-plus from 3.5.6 to 3.5.7 (#5001)
add 2d0f0d3b1 Bump software.amazon.awssdk:s3 from 2.25.69 to 2.26.3 (#4998)
add 419d4395a Bump com.slack.api:bolt from 1.39.+ to 1.40.0 (#5004)
add 565ec1adc Bump com.gradle.common-custom-user-data-gradle-plugin (#4997)
add a7f23f881 Bump curatorVersion from 5.6.0 to 5.7.0 (#5002)
add 00ad5a5ac Bump com.aliyun:dingtalk from 2.1.26 to 2.1.27 (#4999)
add dd64f8f43 Bump jwtVersion from 0.11.1 to 0.12.5
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (ad4527cda)
\
N -- N -- N refs/heads/dependabot/gradle/jwtVersion-0.12.5
(dd64f8f43)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.github/dependabot.yml | 9 +-
.github/workflows/auto-dependabot.yml | 2 +-
.github/workflows/ci.yml | 14 +-
.github/workflows/code-scanning.yml | 4 +-
.github/workflows/docker.yml | 2 +-
.github/workflows/license.yml | 2 -
.idea/icon.png | Bin 14821 -> 0 bytes
README.md | 6 +-
README.zh-CN.md | 6 +-
build.gradle | 216 ++---
eventmesh-admin-server/.gitignore | 42 +
eventmesh-admin-server/build.gradle | 48 +
.../gradle.properties | 0
.../org/apache/eventmesh/admin/server/Admin.java | 34 +-
.../apache/eventmesh/admin/server/AdminServer.java | 125 +++
.../admin/server/AdminServerProperties.java | 21 +-
.../admin/server/AdminServerRuntimeException.java | 15 +-
.../eventmesh/admin/server/ComponentLifeCycle.java | 13 +-
.../eventmesh/admin/server/ExampleAdminServer.java | 17 +-
.../server/constatns/AdminServerConstants.java | 20 +-
.../admin/server/web/AdminGrpcServer.java | 103 +++
.../eventmesh/admin/server/web/BaseServer.java | 50 ++
.../eventmesh/admin/server/web/GrpcServer.java | 73 ++
.../eventmesh/admin/server/web/HttpServer.java | 15 +-
.../apache/eventmesh/admin/server/web/Request.java | 26 +-
.../eventmesh/admin/server/web/Response.java | 39 +-
.../admin/server/web/ServerController.java | 13 +-
.../admin/server/web/db/DBThreadPool.java | 60 ++
.../server/web/db/entity/EventMeshDataSource.java | 35 +-
.../server/web/db/entity/EventMeshJobDetail.java | 26 +-
.../server/web/db/entity/EventMeshJobInfo.java | 41 +-
.../web/db/entity/EventMeshMysqlPosition.java | 32 +-
.../entity/EventMeshPositionReporterHistory.java | 32 +-
.../web/db/entity/EventMeshRuntimeHeartbeat.java | 33 +-
.../web/db/entity/EventMeshRuntimeHistory.java | 30 +-
.../web/db/mapper/EventMeshDataSourceMapper.java | 23 +-
.../web/db/mapper/EventMeshJobInfoMapper.java | 23 +-
.../db/mapper/EventMeshMysqlPositionMapper.java | 22 +-
.../EventMeshPositionReporterHistoryMapper.java | 23 +-
.../db/mapper/EventMeshRuntimeHeartbeatMapper.java | 23 +-
.../db/mapper/EventMeshRuntimeHistoryMapper.java | 23 +-
.../web/db/service/EventMeshDataSourceService.java | 17 +-
.../web/db/service/EventMeshJobInfoService.java | 17 +-
.../db/service/EventMeshMysqlPositionService.java | 17 +-
.../EventMeshPositionReporterHistoryService.java | 16 +-
.../service/EventMeshRuntimeHeartbeatService.java | 14 +-
.../db/service/EventMeshRuntimeHistoryService.java | 14 +-
.../impl/EventMeshDataSourceServiceImpl.java | 25 +-
.../service/impl/EventMeshJobInfoServiceImpl.java | 28 +-
.../impl/EventMeshMysqlPositionServiceImpl.java | 27 +-
...ventMeshPositionReporterHistoryServiceImpl.java | 24 +-
.../impl/EventMeshRuntimeHeartbeatServiceImpl.java | 27 +-
.../impl/EventMeshRuntimeHistoryServiceImpl.java | 25 +-
.../server/web/handler/BaseRequestHandler.java | 17 +-
.../server/web/handler/RequestHandlerFactory.java | 65 ++
.../web/handler/impl/FetchJobRequestHandler.java | 71 ++
.../web/handler/impl/FetchPositionHandler.java | 56 ++
.../web/handler/impl/ReportHeartBeatHandler.java | 70 ++
.../web/handler/impl/ReportPositionHandler.java | 102 +++
.../EventMeshRuntimeHeartbeatBizService.java | 81 ++
.../service/job/EventMeshJobInfoBizService.java | 133 +++
.../position/EventMeshPositionBizService.java | 81 ++
.../service/position/IFetchPositionHandler.java | 16 +-
.../service/position/IReportPositionHandler.java | 15 +-
.../web/service/position/PositionHandler.java | 11 +-
.../service/position/PositionHandlerFactory.java | 56 ++
.../position/impl/MysqlPositionHandler.java | 161 ++++
.../src/main/resources/META-INF/spring.factories | 4 +-
.../src/main/resources/application.yaml | 22 +-
.../src/main/resources/eventmesh-admin.properties | 4 +-
.../src/main/resources/eventmesh.sql | 131 +++
.../resources/mapper/EventMeshDataSourceMapper.xml | 39 +
.../resources/mapper/EventMeshJobInfoMapper.xml | 43 +
.../mapper/EventMeshMysqlPositionMapper.xml | 39 +
.../EventMeshPositionReporterHistoryMapper.xml | 35 +
.../mapper/EventMeshRuntimeHeartbeatMapper.xml | 38 +
.../mapper/EventMeshRuntimeHistoryMapper.xml | 34 +
eventmesh-common/build.gradle | 4 +-
.../org/apache/eventmesh/common/Constants.java | 4 +
.../common/config/CommonConfiguration.java | 15 +
.../apache/eventmesh/common/config/ConfigInfo.java | 4 +-
.../eventmesh/common/config/ConfigService.java | 3 +
.../apache/eventmesh/common/config/FileLoad.java | 11 +-
.../eventmesh/common/config/connector}/Config.java | 2 +-
.../common/config/connector}/Constants.java | 2 +-
.../common/config/connector}/PubSubConfig.java | 2 +-
.../common/config/connector}/SinkConfig.java | 2 +-
.../common/config/connector}/SourceConfig.java | 4 +-
.../connector/dingtalk}/DingDingSinkConfig.java | 4 +-
.../connector/dingtalk}/SinkConnectorConfig.java | 2 +-
.../config/connector/file}/FileSinkConfig.java | 4 +-
.../config/connector/file}/FileSourceConfig.java | 4 +-
.../connector/file}/SinkConnectorConfig.java | 2 +-
.../connector/file}/SourceConnectorConfig.java | 2 +-
.../config/connector/http}/HttpSourceConfig.java | 4 +-
.../connector/http}/SourceConnectorConfig.java | 2 +-
.../connector/knative}/KnativeSinkConfig.java | 4 +-
.../connector/knative}/KnativeSourceConfig.java | 4 +-
.../connector/knative}/SinkConnectorConfig.java | 2 +-
.../connector/knative}/SourceConnectorConfig.java | 2 +-
.../config/connector/lark}/LarkSinkConfig.java | 4 +-
.../connector/lark}/SinkConnectorConfig.java | 26 +-
.../config/connector/mq/kafka/KafkaSinkConfig.java | 8 +-
.../connector/mq/kafka/KafkaSourceConfig.java | 8 +-
.../connector/mq/kafka}/SinkConnectorConfig.java | 2 +-
.../connector/mq/kafka}/SourceConnectorConfig.java | 2 +-
.../connector/mq/pulsar/PulsarSinkConfig.java | 8 +-
.../connector/mq/pulsar/PulsarSourceConfig.java | 8 +-
.../connector/mq/pulsar}/SinkConnectorConfig.java | 2 +-
.../mq/pulsar}/SourceConnectorConfig.java | 2 +-
.../connector/mq/rabbitmq}/RabbitMQSinkConfig.java | 4 +-
.../mq/rabbitmq}/RabbitMQSourceConfig.java | 4 +-
.../mq/rabbitmq}/SinkConnectorConfig.java | 6 +-
.../mq/rabbitmq}/SourceConnectorConfig.java | 6 +-
.../connector/mq/rocketmq}/RocketMQSinkConfig.java | 4 +-
.../mq/rocketmq}/RocketMQSourceConfig.java | 4 +-
.../mq/rocketmq}/SinkConnectorConfig.java | 2 +-
.../mq/rocketmq}/SourceConnectorConfig.java | 2 +-
.../connector/offset}/OffsetStorageConfig.java | 8 +-
.../openfunction}/OpenFunctionSinkConfig.java | 4 +-
.../openfunction}/OpenFunctionSourceConfig.java | 4 +-
.../openfunction}/SinkConnectorConfig.java | 2 +-
.../openfunction}/SourceConnectorConfig.java | 2 +-
.../connector/pravega}/PravegaSinkConfig.java | 4 +-
.../connector/pravega}/PravegaSourceConfig.java | 4 +-
.../connector/pravega}/SinkConnectorConfig.java | 2 +-
.../connector/pravega}/SourceConnectorConfig.java | 2 +-
.../prometheus}/PrometheusSourceConfig.java | 4 +-
.../prometheus}/SourceConnectorConfig.java | 2 +-
.../connector/rdb/canal/CanalSinkConfig.java | 17 +-
.../connector/rdb/canal/CanalSourceConfig.java | 80 ++
.../connector/rdb/canal}/SinkConnectorConfig.java | 19 +-
.../rdb/canal}/SourceConnectorConfig.java | 19 +-
.../config/connector/rdb/jdbc}/JdbcConfig.java | 2 +-
.../config/connector/rdb/jdbc}/JdbcSinkConfig.java | 4 +-
.../connector/rdb/jdbc}/JdbcSourceConfig.java | 4 +-
.../config/connector/rdb/jdbc}/MysqlConfig.java | 2 +-
.../connector/rdb/jdbc}/SinkConnectorConfig.java | 4 +-
.../connector/rdb/jdbc}/SourceConnectorConfig.java | 4 +-
.../connector/rdb/mongodb/MongodbSinkConfig.java | 8 +-
.../connector/rdb/mongodb/MongodbSourceConfig.java | 8 +-
.../rdb/mongodb}/SinkConnectorConfig.java | 2 +-
.../rdb/mongodb}/SourceConnectorConfig.java | 2 +-
.../config/connector/redis/RedisSinkConfig.java | 8 +-
.../config/connector/redis/RedisSourceConfig.java | 9 +-
.../connector/redis}/SinkConnectorConfig.java | 2 +-
.../connector/redis}/SourceConnectorConfig.java | 2 +-
.../config/connector/s3}/S3SourceConfig.java | 6 +-
.../connector/s3}/SourceConnectorConfig.java | 2 +-
.../connector/slack}/SinkConnectorConfig.java | 2 +-
.../config/connector/slack}/SlackSinkConfig.java | 4 +-
.../connector/spring}/SinkConnectorConfig.java | 2 +-
.../connector/spring}/SourceConnectorConfig.java | 2 +-
.../config/connector/spring/SpringSinkConfig.java | 6 +-
.../connector/spring}/SpringSourceConfig.java | 5 +-
.../connector/wechat}/SinkConnectorConfig.java | 2 +-
.../config/connector/wechat}/WeChatSinkConfig.java | 4 +-
.../connector/wecom}/SinkConnectorConfig.java | 2 +-
.../config/connector/wecom}/WeComSinkConfig.java | 4 +-
.../eventmesh/common/enums/ComponentType.java | 18 +-
.../grpc/adminserver/AdminServiceGrpc.java | 373 ++++++++
.../grpc/adminserver/EventMeshAdminService.java | 99 +++
.../common/protocol/grpc/adminserver/Metadata.java | 962 +++++++++++++++++++++
.../grpc/adminserver/MetadataOrBuilder.java | 78 ++
.../common/protocol/grpc/adminserver/Payload.java | 893 +++++++++++++++++++
.../grpc/adminserver/PayloadOrBuilder.java | 62 ++
.../grpc/proto/event_mesh_admin_service.proto | 25 +-
.../org/apache/eventmesh/common/remote/Job.java | 14 +-
.../apache/eventmesh/common/remote/JobState.java | 17 +-
.../apache/eventmesh/common/remote/JobType.java | 7 +-
.../org/apache/eventmesh/common/remote/Task.java | 22 +-
.../common/remote/exception/ErrorCode.java | 22 +-
.../remote/exception/PayloadFormatException.java | 13 +-
.../remote/exception/RemoteRuntimeException.java | 15 +-
.../common/remote/job/DataSourceClassify.java | 8 +-
.../common/remote/job/DataSourceDriverType.java | 7 +-
.../common/remote/job/DataSourceType.java | 54 ++
.../common/remote/job/JobTransportType.java | 68 ++
.../common/remote/job/SyncConsistency.java | 69 ++
.../eventmesh/common/remote/job/SyncMode.java | 54 +-
.../common/remote/offset/RecordOffset.java | 11 +-
.../common/remote/offset/RecordPartition.java | 11 +-
.../common/remote/offset/RecordPosition.java | 128 +++
.../common/remote/offset/S3/S3RecordOffset.java | 20 +-
.../common/remote/offset/S3/S3RecordPartition.java | 43 +-
.../remote/offset/canal/CanalRecordOffset.java | 20 +-
.../remote/offset/canal/CanalRecordPartition.java | 37 +-
.../remote/offset/file/FileRecordOffset.java | 20 +-
.../remote/offset/file/FileRecordPartition.java | 38 +-
.../remote/offset/http/HttpRecordOffset.java | 22 +-
.../remote/offset/http/HttpRecordPartition.java | 26 +-
.../remote/offset/jdbc/JdbcRecordOffset.java | 20 +-
.../remote/offset/jdbc/JdbcRecordPartition.java | 38 +-
.../remote/offset/kafka/KafkaRecordOffset.java | 20 +-
.../remote/offset/kafka/KafkaRecordPartition.java | 40 +-
.../offset/prometheus/PrometheusRecordOffset.java | 20 +-
.../prometheus/PrometheusRecordPartition.java | 23 +-
.../remote/offset/pulsar/PulsarRecordOffset.java | 25 +-
.../offset/pulsar/PulsarRecordPartition.java | 42 +-
.../offset/rocketmq/RocketMQRecordOffset.java | 25 +-
.../offset/rocketmq/RocketMQRecordPartition.java | 48 +-
.../remote/offset/spring/SpringRecordOffset.java | 20 +-
.../offset/spring/SpringRecordPartition.java | 26 +-
.../eventmesh/common/remote/payload/IPayload.java | 8 +-
.../common/remote/payload/PayloadFactory.java | 71 ++
.../common/remote/payload/PayloadUtil.java | 46 +
.../common/remote/request/BaseRemoteRequest.java | 48 +-
.../common/remote/request/FetchJobRequest.java | 8 +-
.../remote/request/FetchPositionRequest.java | 17 +-
.../remote/request/ReportHeartBeatRequest.java | 11 +-
.../remote/request/ReportPositionRequest.java | 21 +-
.../common/remote/response/BaseRemoteResponse.java | 60 +-
.../common/remote/response/EmptyAckResponse.java | 12 +-
.../common/remote/response/FailResponse.java | 34 +-
.../common/remote/response/FetchJobResponse.java | 67 ++
.../remote/response/FetchPositionResponse.java | 53 ++
.../common/utils/ConfigurationContextUtil.java | 3 +-
.../org/apache/eventmesh/common/utils/IPUtils.java | 6 +-
.../apache/eventmesh/common/utils/JsonUtils.java | 19 +-
.../apache/eventmesh/common/utils/PagedList.java} | 54 +-
...apache.eventmesh.common.remote.payload.IPayload | 15 +-
.../loadbalance/RandomLoadBalanceSelectorTest.java | 2 +-
.../apache/eventmesh/common/utils/IPUtilsTest.java | 7 -
.../eventmesh-connector-canal}/build.gradle | 20 +-
.../eventmesh-connector-canal}/gradle.properties | 7 +-
.../connector/canal/ByteArrayConverter.java | 69 ++
.../connector/canal/CanalConnectRecord.java | 275 ++++++
.../connector/canal/DatabaseConnection.java | 85 ++
.../connector/canal/SqlTimestampConverter.java | 155 ++++
.../apache/eventmesh/connector/canal/SqlUtils.java | 296 +++++++
.../connector/canal/config/CanalServerConfig.java} | 6 +-
.../connector/canal/dialect/AbstractDbDialect.java | 110 +++
.../connector/canal/dialect/DbDialect.java | 64 ++
.../connector/canal/dialect/MysqlDialect.java | 81 ++
.../interceptor/SqlBuilderLoadInterceptor.java | 139 +++
.../connector/canal/model/EventColumn.java | 163 ++++
.../canal/model/EventColumnIndexComparable.java} | 12 +-
.../eventmesh/connector/canal/model/EventType.java | 156 ++++
.../connector/canal/server/CanalConnectServer.java | 45 +
.../connector/canal/sink/DbLoadContext.java} | 43 +-
.../eventmesh/connector/canal/sink/DbLoadData.java | 135 +++
.../connector/canal/sink/DbLoadMerger.java | 280 ++++++
.../canal/sink/connector/CanalSinkConnector.java | 616 +++++++++++++
.../connector/canal/source/EntryParser.java | 278 ++++++
.../source/connector/CanalSourceConnector.java | 313 +++++++
.../canal/template/AbstractSqlTemplate.java | 117 +++
.../connector/canal/template/MysqlSqlTemplate.java | 80 ++
.../connector/canal/template/SqlTemplate.java | 25 +-
...ventmesh.openconnect.api.ConnectorCreateService | 4 +-
.../src/main/resources/server-config.yml | 0
.../src/main/resources/sink-config.yml | 0
.../src/main/resources/source-config.yml | 0
.../src/test}/resources/sink-config.yml | 0
.../src/test}/resources/source-config.yml | 0
.../eventmesh-connector-chatgpt/build.gradle | 6 +-
.../chatgpt/config/ChatGPTServerConfig.java | 2 +-
.../chatgpt/source/config/ChatGPTSourceConfig.java | 2 +-
.../source/connector/ChatGPTSourceConnector.java | 2 +-
.../eventmesh-connector-dingtalk/build.gradle | 2 +-
.../config/DingDingConnectServerConfig.java | 2 +-
.../sink/connector/DingDingSinkConnector.java | 4 +-
.../sink/connector/DingDingSinkConnectorTest.java | 8 +-
.../eventmesh-connector-file/build.gradle | 5 +-
.../connector/file/config/FileServerConfig.java | 2 +-
.../file/sink/connector/FileSinkConnector.java | 4 +-
.../file/source/connector/FileSourceConnector.java | 15 +-
.../connector/file/FileSourceConnectorTest.java | 4 +-
.../eventmesh-connector-http/build.gradle | 6 +-
.../connector/http/config/HttpServerConfig.java | 2 +-
.../connector/http/sink/HttpSinkConnector.java | 2 +-
.../connector/http/sink/config/HttpSinkConfig.java | 2 +-
.../http/sink/data/HttpConnectRecord.java | 7 +-
.../http/sink/handle/CommonHttpSinkHandler.java | 3 +-
.../http/source/connector/HttpSourceConnector.java | 4 +-
.../source/connector/HttpSinkConnectorTest.java | 12 +-
.../source/connector/HttpSourceConnectorTest.java | 4 +-
.../eventmesh-connector-jdbc/build.gradle | 10 +-
.../connector/jdbc/config/JdbcServerConfig.java | 3 +-
.../connector/jdbc/connection/JdbcConnection.java | 2 +-
.../jdbc/connection/mysql/MysqlJdbcConnection.java | 2 +-
.../dialect/AbstractGeneralDatabaseDialect.java | 2 +-
.../jdbc/dialect/DatabaseDialectFactory.java | 2 +-
.../jdbc/dialect/mysql/MysqlDatabaseDialect.java | 2 +-
.../dialect/mysql/MysqlDatabaseDialectFactory.java | 2 +-
.../connector/jdbc/sink/JdbcSinkConnector.java | 6 +-
.../jdbc/sink/handle/DefaultSinkRecordHandler.java | 2 +-
.../connector/jdbc/source/AbstractEngine.java | 4 +-
.../jdbc/source/AbstractJdbcTaskManager.java | 2 +-
.../connector/jdbc/source/JdbcSourceConnector.java | 6 +-
.../jdbc/source/SourceJdbcTaskManager.java | 12 +-
.../dialect/antlr4/mysql/MysqlAntlr4DdlParser.java | 4 +-
.../listener/CreateDatabaseParserListener.java | 2 +-
.../mysql/listener/CreateTableParserListener.java | 2 +-
.../mysql/listener/DropDatabaseParserListener.java | 2 +-
.../jdbc/source/dialect/cdc/AbstractCdcEngine.java | 6 +-
.../jdbc/source/dialect/cdc/CdcEngineFactory.java | 2 +-
.../source/dialect/cdc/mysql/MysqlCdcEngine.java | 8 +-
.../dialect/cdc/mysql/MysqlCdcEngineFactory.java | 2 +-
.../source/dialect/mysql/MysqlJdbcContext.java | 4 +-
.../dialect/snapshot/AbstractSnapshotEngine.java | 2 +-
.../dialect/snapshot/SnapshotEngineFactory.java | 2 +-
.../snapshot/mysql/MysqlSnapshotEngine.java | 4 +-
.../snapshot/mysql/MysqlSnapshotEngineFactory.java | 2 +-
.../eventmesh-connector-kafka/build.gradle | 3 +-
.../connector/kafka/config/KafkaServerConfig.java | 2 +-
.../kafka/sink/connector/KafkaSinkConnector.java | 4 +-
.../source/connector/KafkaSourceConnector.java | 26 +-
.../knative/config/KnativeServerConfig.java | 2 +-
.../sink/connector/KnativeSinkConnector.java | 4 +-
.../source/connector/KnativeSourceConnector.java | 4 +-
.../SinkConnectorConfig.java => ConfigUtils.java} | 51 +-
.../lark/config/LarkConnectServerConfig.java | 2 +-
.../connector/lark/sink/ImServiceHandler.java | 2 +-
.../lark/sink/connector/LarkSinkConnector.java | 9 +-
.../connector/lark/sink/ImServiceHandlerTest.java | 16 +-
.../connector/lark/sink/LarkSinkConnectorTest.java | 8 +-
.../eventmesh-connector-mongodb/build.gradle | 2 +-
.../mongodb/config/MongodbServerConfig.java | 4 +-
.../sink/client/MongodbReplicaSetSinkClient.java | 2 +-
.../sink/client/MongodbStandaloneSinkClient.java | 2 +-
.../mongodb/sink/config/MongodbSinkConfig.java | 28 -
.../sink/connector/MongodbSinkConnector.java | 4 +-
.../client/MongodbReplicaSetSourceClient.java | 2 +-
.../client/MongodbStandaloneSourceClient.java | 2 +-
.../mongodb/source/config/MongodbSourceConfig.java | 28 -
.../source/connector/MongodbSourceConnector.java | 4 +-
.../config/OpenFunctionServerConfig.java | 2 +-
.../sink/connector/OpenFunctionSinkConnector.java | 4 +-
.../connector/OpenFunctionSourceConnector.java | 4 +-
.../connector/OpenFunctionSinkConnectorTest.java | 8 +-
.../connector/OpenFunctionSourceConnectorTest.java | 8 +-
.../pravega/config/PravegaServerConfig.java | 2 +-
.../sink/connector/PravegaSinkConnector.java | 4 +-
.../source/connector/PravegaSourceConnector.java | 4 +-
.../eventmesh-connector-prometheus/build.gradle | 1 +
.../prometheus/config/PrometheusServerConfig.java | 2 +-
.../connector/PrometheusSourceConnector.java | 14 +-
.../eventmesh-connector-pulsar/build.gradle | 1 +
.../pulsar/config/PulsarServerConfig.java | 2 +-
.../pulsar/sink/config/PulsarSinkConfig.java | 29 -
.../pulsar/sink/connector/PulsarSinkConnector.java | 4 +-
.../pulsar/source/config/PulsarSourceConfig.java | 28 -
.../source/connector/PulsarSourceConnector.java | 15 +-
.../eventmesh-connector-rabbitmq/build.gradle | 2 +-
.../rabbitmq/config/RabbitMQServerConfig.java | 6 +-
.../sink/connector/RabbitMQSinkConnector.java | 8 +-
.../source/connector/RabbitMQSourceConnector.java | 10 +-
.../eventmesh-connector-redis/build.gradle | 3 +-
.../connector/redis/config/RedisServerConfig.java | 2 +-
.../redis/sink/config/RedisSinkConfig.java | 29 -
.../redis/sink/connector/RedisSinkConnector.java | 4 +-
.../redis/source/config/RedisSourceConfig.java | 29 -
.../source/connector/RedisSourceConnector.java | 4 +-
.../sink/connector/RedisSinkConnectorTest.java | 8 +-
.../source/connector/RedisSourceConnectorTest.java | 8 +-
.../rocketmq/config/RocketMQServerConfig.java | 2 +-
.../sink/connector/RocketMQSinkConnector.java | 12 +-
.../source/connector/RocketMQSourceConnector.java | 60 +-
.../sink/connector/RocketMQSinkConnectorTest.java | 8 +-
.../connector/RocketMQSourceConnectorTest.java | 2 +-
.../eventmesh-connector-s3/build.gradle | 1 +
.../connector/s3/config/S3ServerConfig.java | 2 +-
.../s3/source/connector/S3SourceConnector.java | 30 +-
.../connector/s3/source/S3SourceConnectorTest.java | 4 +-
.../eventmesh-connector-slack/build.gradle | 2 +-
.../slack/config/SlackConnectServerConfig.java | 2 +-
.../slack/sink/connector/SlackSinkConnector.java | 4 +-
.../sink/connector/SlackSinkConnectorTest.java | 8 +-
.../spring/config/SpringConnectServerConfig.java | 2 +-
.../spring/sink/config/SpringSinkConfig.java | 31 -
.../spring/sink/connector/SpringSinkConnector.java | 4 +-
.../source/connector/SpringSourceConnector.java | 18 +-
.../sink/connector/SpringSinkConnectorTest.java | 8 +-
.../connector/SpringSourceConnectorTest.java | 2 +-
.../wechat/config/WeChatConnectServerConfig.java | 2 +-
.../wechat/sink/connector/WeChatSinkConnector.java | 4 +-
.../sink/connector/WeChatSinkConnectorTest.java | 12 +-
.../wecom/config/WeComConnectServerConfig.java | 2 +-
.../wecom/sink/connector/WeComSinkConnector.java | 4 +-
.../wecom/connector/MockRecordOffset.java} | 14 +-
.../wecom/connector/MockRecordPartition.java} | 17 +-
.../wecom/connector/WeComSinkConnectorTest.java | 19 +-
eventmesh-examples/build.gradle | 2 +-
eventmesh-meta/eventmesh-meta-consul/build.gradle | 2 +-
.../eventmesh-meta-raft}/build.gradle | 22 +-
.../eventmesh-meta-raft}/gradle.properties | 5 +-
.../apache/eventmesh/meta/raft/EventClosure.java | 83 ++
.../apache/eventmesh/meta/raft/EventOperation.java | 68 ++
.../eventmesh/meta/raft/JraftMetaService.java | 13 +-
.../eventmesh/meta/raft/JraftMetaServiceImpl.java | 78 ++
.../apache/eventmesh/meta/raft/JraftServer.java | 95 ++
.../eventmesh/meta/raft/MetaStateMachine.java | 193 +++++
.../eventmesh/meta/raft/RaftMetaService.java | 398 +++++++++
.../raft/config/RaftMetaStorageConfiguration.java | 43 +-
.../meta/raft/consts/MetaRaftConstants.java | 34 +-
.../eventmesh/meta/raft/rpc/MetaServerHelper.java | 97 +++
.../eventmesh/meta/raft/rpc/RequestProcessor.java | 52 ++
.../meta/raft/snapshot/MetaSnapshotFile.java | 63 ++
.../src/main/proto/request.proto | 18 +-
.../org.apache.eventmesh.api.meta.MetaService | 4 +-
.../apache/eventmesh/openconnect/Application.java | 6 +-
.../apache/eventmesh/openconnect/SinkWorker.java | 2 +-
.../apache/eventmesh/openconnect/SourceWorker.java | 8 +-
.../openconnect/api/connector/Connector.java | 2 +-
.../openconnect/api/connector/SinkConnector.java | 2 +-
.../api/connector/SinkConnectorContext.java | 2 +-
.../openconnect/api/connector/SourceConnector.java | 2 +-
.../api/connector/SourceConnectorContext.java | 2 +-
.../api/factory/ConnectorPluginFactory.java | 25 +-
.../eventmesh/openconnect/util/ConfigUtil.java | 14 +-
.../build.gradle | 16 +-
.../gradle.properties | 6 +-
.../offsetmgmt/admin/AdminOffsetService.java | 270 ++++++
....offsetmgmt.api.storage.OffsetManagementService | 4 +-
.../build.gradle | 1 +
.../offsetmgmt/api/data/ConnectRecord.java | 14 +-
.../api/data/RecordOffsetManagement.java | 19 +-
.../DefaultOffsetManagementServiceImpl.java | 15 +-
.../api/storage/OffsetManagementService.java | 21 +-
.../api/storage/OffsetStorageReader.java | 4 +-
.../api/storage/OffsetStorageReaderImpl.java | 19 +-
.../api/storage/OffsetStorageWriter.java | 4 +-
.../api/storage/OffsetStorageWriterImpl.java | 18 +-
.../offsetmgmt/nacos/NacosConfigService.java | 55 +-
.../config/samples/eventmesh_v1_runtime.yaml | 1 -
.../eventmesh-protocol-cloudevents/build.gradle | 4 +-
.../eventmesh-protocol-grpc/build.gradle | 8 +-
.../eventmesh-protocol-http/build.gradle | 4 +-
.../eventmesh-protocol-meshmessage/build.gradle | 4 +-
eventmesh-registry/.gitignore | 42 +
.../build.gradle | 0
.../eventmesh-registry-api}/build.gradle | 6 +-
.../org/apache/eventmesh/registry/NotifyEvent.java | 35 +-
.../apache/eventmesh/registry/QueryInstances.java | 13 +-
.../eventmesh/registry/RegisterServerInfo.java | 72 ++
.../apache/eventmesh/registry/RegistryFactory.java | 47 +
.../eventmesh/registry/RegistryListener.java | 13 +-
.../apache/eventmesh/registry/RegistryService.java | 31 +-
.../registry/exception/RegistryException.java | 16 +-
.../eventmesh-registry-nacos}/build.gradle | 6 +-
.../registry/nacos/NacosDiscoveryService.java | 312 +++++++
.../registry/nacos/NacosRegistryConfiguration.java | 62 ++
.../org.apache.eventmesh.registry.RegistryService | 4 +-
.../build.gradle | 46 +-
.../java/org/apache/eventmesh/runtime/Runtime.java | 59 +-
.../apache/eventmesh/runtime/RuntimeFactory.java | 57 +-
.../eventmesh/runtime/RuntimeInstanceConfig.java | 108 +--
.../eventmesh/runtime/boot/RuntimeInstance.java | 146 ++++
.../runtime/boot/RuntimeInstanceStarter.java | 55 ++
.../runtime/connector/ConnectorRuntime.java | 426 +++++++++
.../runtime/connector/ConnectorRuntimeConfig.java | 80 +-
.../runtime/connector/ConnectorRuntimeFactory.java | 71 +-
.../runtime/function/FunctionRuntime.java | 68 +-
.../runtime/function/FunctionRuntimeConfig.java | 42 +-
.../runtime/function/FunctionRuntimeFactory.java | 72 +-
.../runtime/manager/ConnectorManager.java | 42 +-
.../eventmesh/runtime/manager/FunctionManager.java | 42 +-
.../eventmesh/runtime/manager/MeshManager.java | 42 +-
.../apache/eventmesh/runtime/mesh/MeshRuntime.java | 74 +-
.../eventmesh/runtime/mesh/MeshRuntimeConfig.java | 42 +-
.../eventmesh/runtime/mesh/MeshRuntimeFactory.java | 72 +-
.../apache/eventmesh/runtime/meta/MetaStorage.java | 0
.../apache/eventmesh/runtime/util/BannerUtil.java | 0
.../eventmesh/runtime/util/RuntimeUtils.java | 4 +-
.../src/main/resources/connector.yaml | 4 +-
.../src/main/resources/runtime.yaml | 7 +-
eventmesh-runtime/conf/admin-server.jks | Bin 0 -> 2808 bytes
eventmesh-runtime/conf/eventmesh.properties | 38 +-
eventmesh-runtime/conf/log4j2.xml | 9 +
.../runtime/admin/handler/AdminHandlerManager.java | 2 -
.../runtime/admin/handler/v1/MetricsHandler.java | 113 ---
.../admin/handler/v2/ConfigurationHandler.java | 3 +-
.../eventmesh/runtime/boot/AbstractHTTPServer.java | 41 +-
.../runtime/boot/AbstractRemotingServer.java | 51 +-
.../runtime/boot/EventMeshAdminBootstrap.java | 22 +-
.../runtime/boot/EventMeshAdminServer.java | 88 +-
.../runtime/boot/EventMeshGrpcBootstrap.java | 11 +-
.../runtime/boot/EventMeshHTTPServer.java | 66 +-
.../runtime/boot/EventMeshHttpBootstrap.java | 15 +-
.../eventmesh/runtime/boot/EventMeshServer.java | 81 +-
.../runtime/boot/EventMeshTcpBootstrap.java | 12 +-
.../runtime/boot/HTTPThreadPoolGroup.java | 51 +-
.../eventmesh/runtime/boot/SSLContextFactory.java | 25 +-
.../configuration/EventMeshAdminConfiguration.java | 61 ++
.../configuration/EventMeshGrpcConfiguration.java | 3 -
.../configuration/EventMeshHTTPConfiguration.java | 4 -
.../configuration/EventMeshTCPConfiguration.java | 3 -
.../runtime/constants/EventMeshVersion.java | 136 ++-
.../http/processor/AdminMetricsProcessor.java | 6 +-
.../apache/eventmesh/runtime/util/BannerUtil.java | 15 +-
.../runtime/boot/EventMeshServerTest.java | 1 -
.../EventMeshGrpcConfigurationTest.java | 1 -
.../EventMeshHTTPConfigurationTest.java | 1 -
.../EventMeshTCPConfigurationTest.java | 1 -
.../src/test/resources/configuration.properties | 2 -
eventmesh-sdks/eventmesh-sdk-java/build.gradle | 4 +-
.../auth/token/impl/auth/AuthTokenUtils.java | 114 +--
.../eventmesh/spi/EventMeshExtensionType.java | 1 +
.../eventmesh-storage-kafka/build.gradle | 4 +-
.../eventmesh-storage-rabbitmq/build.gradle | 4 +-
.../eventmesh-storage-redis/build.gradle | 14 +-
.../eventmesh-storage-redis/gradle.properties | 1 +
.../storage/redis/client/RedissonClient.java | 13 +-
.../storage/redis/config/RedisProperties.java | 11 +-
.../src/main/resources/redis-client.properties | 6 +-
.../storage/redis/AbstractRedisServer.java | 22 +-
.../storage/redis/config/RedisPropertiesTest.java | 10 +-
gradle/wrapper/gradle-wrapper.properties | 2 +-
resources/eventmesh-architecture-5.png | Bin 0 -> 169892 bytes
resources/eventmesh-operator.png | Bin 0 -> 184473 bytes
settings.gradle | 22 +-
511 files changed, 14106 insertions(+), 3076 deletions(-)
delete mode 100644 .idea/icon.png
create mode 100644 eventmesh-admin-server/.gitignore
create mode 100644 eventmesh-admin-server/build.gradle
copy {eventmesh-connectors => eventmesh-admin-server}/gradle.properties (100%)
copy
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/sink/config/SinkConnectorConfig.java
=>
eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/Admin.java
(59%)
create mode 100644
eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/AdminServer.java
copy
eventmesh-connectors/eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/source/config/SourceConnectorConfig.java
=>
eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/AdminServerProperties.java
(67%)
copy
eventmesh-connectors/eventmesh-connector-file/src/main/java/org/apache/eventmesh/connector/file/source/config/SourceConnectorConfig.java
=>
eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/AdminServerRuntimeException.java
(73%)
copy
eventmesh-connectors/eventmesh-connector-spring/src/main/java/org/apache/eventmesh/connector/spring/sink/connector/SinkConnectorConfig.java
=>
eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/ComponentLifeCycle.java
(81%)
copy
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/connector/SourceConnector.java
=>
eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/ExampleAdminServer.java
(56%)
copy
eventmesh-connectors/eventmesh-connector-dingtalk/src/main/java/org/apache/eventmesh/connector/dingtalk/sink/config/SinkConnectorConfig.java
=>
eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/constatns/AdminServerConstants.java
(70%)
create mode 100644
eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/AdminGrpcServer.java
create mode 100644
eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/BaseServer.java
create mode 100644
eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/GrpcServer.java
rename
eventmesh-connectors/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/sink/config/KafkaSinkConfig.java
=>
eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/HttpServer.java
(76%)
copy
eventmesh-connectors/eventmesh-connector-file/src/main/java/org/apache/eventmesh/connector/file/config/FileServerConfig.java
=>
eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/Request.java
(69%)
copy
eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/build.gradle
=>
eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/Response.java
(61%)
copy
eventmesh-connectors/eventmesh-connector-file/src/main/java/org/apache/eventmesh/connector/file/source/config/SourceConnectorConfig.java
=>
eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/ServerController.java
(75%)
create mode 100644
eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/db/DBThreadPool.java
copy
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/connector/SourceConnectorContext.java
=>
eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/db/entity/EventMeshDataSource.java
(53%)
copy
eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt/api/config/OffsetStorageConfig.java
=>
eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/db/entity/EventMeshJobDetail.java
(57%)
copy
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/connector/SourceConnectorContext.java
=>
eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/db/entity/EventMeshJobInfo.java
(51%)
copy
eventmesh-connectors/eventmesh-connector-prometheus/src/main/java/org/apache/eventmesh/connector/prometheus/source/config/SourceConnectorConfig.java
=>
eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/db/entity/EventMeshMysqlPosition.java
(55%)
copy
eventmesh-connectors/eventmesh-connector-prometheus/src/main/java/org/apache/eventmesh/connector/prometheus/source/config/SourceConnectorConfig.java
=>
eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/db/entity/EventMeshPositionReporterHistory.java
(57%)
copy
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/connector/SourceConnectorContext.java
=>
eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/db/entity/EventMeshRuntimeHeartbeat.java
(54%)
copy
eventmesh-connectors/eventmesh-connector-prometheus/src/main/java/org/apache/eventmesh/connector/prometheus/source/config/SourceConnectorConfig.java
=>
eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/db/entity/EventMeshRuntimeHistory.java
(59%)
copy
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/connector/SourceConnectorContext.java
=>
eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/db/mapper/EventMeshDataSourceMapper.java
(63%)
copy
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/connector/SourceConnectorContext.java
=>
eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/db/mapper/EventMeshJobInfoMapper.java
(64%)
copy
eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt/api/storage/OffsetStorageWriter.java
=>
eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/db/mapper/EventMeshMysqlPositionMapper.java
(62%)
copy
eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt/api/storage/OffsetStorageReader.java
=>
eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/db/mapper/EventMeshPositionReporterHistoryMapper.java
(60%)
copy
eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt/api/storage/OffsetStorageReader.java
=>
eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/db/mapper/EventMeshRuntimeHeartbeatMapper.java
(61%)
copy
eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt/api/storage/OffsetStorageReader.java
=>
eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/db/mapper/EventMeshRuntimeHistoryMapper.java
(62%)
copy
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/connector/SinkConnectorContext.java
=>
eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/db/service/EventMeshDataSourceService.java
(69%)
copy
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/connector/SinkConnectorContext.java
=>
eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/db/service/EventMeshJobInfoService.java
(70%)
copy
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/connector/SinkConnectorContext.java
=>
eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/db/service/EventMeshMysqlPositionService.java
(68%)
copy
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/connector/SinkConnectorContext.java
=>
eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/db/service/EventMeshPositionReporterHistoryService.java
(66%)
copy
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/connector/SinkConnectorContext.java
=>
eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/db/service/EventMeshRuntimeHeartbeatService.java
(68%)
copy
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/connector/SinkConnectorContext.java
=>
eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/db/service/EventMeshRuntimeHistoryService.java
(68%)
copy
eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt/api/storage/OffsetStorageReader.java
=>
eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/db/service/impl/EventMeshDataSourceServiceImpl.java
(55%)
copy
eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt/api/storage/OffsetStorageReader.java
=>
eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/db/service/impl/EventMeshJobInfoServiceImpl.java
(54%)
copy
eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt/api/storage/OffsetStorageWriter.java
=>
eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/db/service/impl/EventMeshMysqlPositionServiceImpl.java
(53%)
copy
eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt/api/storage/OffsetStorageWriter.java
=>
eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/db/service/impl/EventMeshPositionReporterHistoryServiceImpl.java
(51%)
copy
eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt/api/storage/OffsetStorageWriter.java
=>
eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/db/service/impl/EventMeshRuntimeHeartbeatServiceImpl.java
(52%)
copy
eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt/api/storage/OffsetStorageReader.java
=>
eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/db/service/impl/EventMeshRuntimeHistoryServiceImpl.java
(54%)
copy
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/connector/SourceConnector.java
=>
eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/handler/BaseRequestHandler.java
(59%)
create mode 100644
eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/handler/RequestHandlerFactory.java
create mode 100644
eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/handler/impl/FetchJobRequestHandler.java
create mode 100644
eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/handler/impl/FetchPositionHandler.java
create mode 100644
eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/handler/impl/ReportHeartBeatHandler.java
create mode 100644
eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/handler/impl/ReportPositionHandler.java
create mode 100644
eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/service/heatbeat/EventMeshRuntimeHeartbeatBizService.java
create mode 100644
eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/service/job/EventMeshJobInfoBizService.java
create mode 100644
eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/service/position/EventMeshPositionBizService.java
copy
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/connector/SinkConnectorContext.java
=>
eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/service/position/IFetchPositionHandler.java
(66%)
copy
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/connector/SinkConnectorContext.java
=>
eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/service/position/IReportPositionHandler.java
(70%)
copy
eventmesh-connectors/eventmesh-connector-file/src/main/java/org/apache/eventmesh/connector/file/source/config/SourceConnectorConfig.java
=>
eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/service/position/PositionHandler.java
(74%)
create mode 100644
eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/service/position/PositionHandlerFactory.java
create mode 100644
eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/service/position/impl/MysqlPositionHandler.java
copy
eventmesh-storage-plugin/eventmesh-storage-redis/src/main/resources/redis-client.properties
=> eventmesh-admin-server/src/main/resources/META-INF/spring.factories (86%)
copy gradle/wrapper/gradle-wrapper.properties =>
eventmesh-admin-server/src/main/resources/application.yaml (60%)
copy
eventmesh-storage-plugin/eventmesh-storage-redis/src/main/resources/redis-client.properties
=> eventmesh-admin-server/src/main/resources/eventmesh-admin.properties (89%)
create mode 100644 eventmesh-admin-server/src/main/resources/eventmesh.sql
create mode 100644
eventmesh-admin-server/src/main/resources/mapper/EventMeshDataSourceMapper.xml
create mode 100644
eventmesh-admin-server/src/main/resources/mapper/EventMeshJobInfoMapper.xml
create mode 100644
eventmesh-admin-server/src/main/resources/mapper/EventMeshMysqlPositionMapper.xml
create mode 100644
eventmesh-admin-server/src/main/resources/mapper/EventMeshPositionReporterHistoryMapper.xml
create mode 100644
eventmesh-admin-server/src/main/resources/mapper/EventMeshRuntimeHeartbeatMapper.xml
create mode 100644
eventmesh-admin-server/src/main/resources/mapper/EventMeshRuntimeHistoryMapper.xml
copy
{eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector}/Config.java
(93%)
rename
{eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector}/Constants.java
(95%)
rename
{eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector}/PubSubConfig.java
(95%)
copy
{eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector}/SinkConfig.java
(94%)
rename
{eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector}/SourceConfig.java
(88%)
rename
{eventmesh-connectors/eventmesh-connector-dingtalk/src/main/java/org/apache/eventmesh/connector/dingtalk/sink/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/dingtalk}/DingDingSinkConfig.java
(88%)
copy
{eventmesh-connectors/eventmesh-connector-dingtalk/src/main/java/org/apache/eventmesh/connector/dingtalk/sink/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/dingtalk}/SinkConnectorConfig.java
(94%)
rename
{eventmesh-connectors/eventmesh-connector-file/src/main/java/org/apache/eventmesh/connector/file/sink/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/file}/FileSinkConfig.java
(89%)
copy
{eventmesh-connectors/eventmesh-connector-file/src/main/java/org/apache/eventmesh/connector/file/source/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/file}/FileSourceConfig.java
(88%)
rename
{eventmesh-connectors/eventmesh-connector-file/src/main/java/org/apache/eventmesh/connector/file/sink/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/file}/SinkConnectorConfig.java
(94%)
copy
{eventmesh-connectors/eventmesh-connector-file/src/main/java/org/apache/eventmesh/connector/file/source/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/file}/SourceConnectorConfig.java
(94%)
copy
{eventmesh-connectors/eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/source/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/http}/HttpSourceConfig.java
(88%)
rename
{eventmesh-connectors/eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/source/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/http}/SourceConnectorConfig.java
(94%)
copy
{eventmesh-connectors/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/sink/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/knative}/KnativeSinkConfig.java
(88%)
rename
{eventmesh-connectors/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/source/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/knative}/KnativeSourceConfig.java
(88%)
rename
{eventmesh-connectors/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/sink/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/knative}/SinkConnectorConfig.java
(93%)
rename
{eventmesh-connectors/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/source/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/knative}/SourceConnectorConfig.java
(93%)
rename
{eventmesh-connectors/eventmesh-connector-lark/src/main/java/org/apache/eventmesh/connector/lark/sink/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/lark}/LarkSinkConfig.java
(89%)
copy
{eventmesh-connectors/eventmesh-connector-lark/src/main/java/org/apache/eventmesh/connector/lark/sink/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/lark}/SinkConnectorConfig.java
(56%)
copy
eventmesh-connectors/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/sink/config/KnativeSinkConfig.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/mq/kafka/KafkaSinkConfig.java
(84%)
copy
eventmesh-connectors/eventmesh-connector-file/src/main/java/org/apache/eventmesh/connector/file/source/config/FileSourceConfig.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/mq/kafka/KafkaSourceConfig.java
(83%)
rename
{eventmesh-connectors/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/sink/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/mq/kafka}/SinkConnectorConfig.java
(96%)
rename
{eventmesh-connectors/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/source/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/mq/kafka}/SourceConnectorConfig.java
(95%)
copy
eventmesh-connectors/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/sink/config/KnativeSinkConfig.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/mq/pulsar/PulsarSinkConfig.java
(84%)
copy
eventmesh-connectors/eventmesh-connector-file/src/main/java/org/apache/eventmesh/connector/file/source/config/FileSourceConfig.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/mq/pulsar/PulsarSourceConfig.java
(83%)
rename
{eventmesh-connectors/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/sink/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/mq/pulsar}/SinkConnectorConfig.java
(93%)
rename
{eventmesh-connectors/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/source/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/mq/pulsar}/SourceConnectorConfig.java
(93%)
rename
{eventmesh-connectors/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/sink/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/mq/rabbitmq}/RabbitMQSinkConfig.java
(88%)
rename
{eventmesh-connectors/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/source/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/mq/rabbitmq}/RabbitMQSourceConfig.java
(88%)
rename
{eventmesh-connectors/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/sink/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/mq/rabbitmq}/SinkConnectorConfig.java
(88%)
rename
{eventmesh-connectors/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/source/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/mq/rabbitmq}/SourceConnectorConfig.java
(88%)
rename
{eventmesh-connectors/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/sink/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/mq/rocketmq}/RocketMQSinkConfig.java
(88%)
rename
{eventmesh-connectors/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/source/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/mq/rocketmq}/RocketMQSourceConfig.java
(88%)
rename
{eventmesh-connectors/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/sink/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/mq/rocketmq}/SinkConnectorConfig.java
(93%)
rename
{eventmesh-connectors/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/source/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/mq/rocketmq}/SourceConnectorConfig.java
(93%)
copy
{eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt/api/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/offset}/OffsetStorageConfig.java
(82%)
rename
{eventmesh-connectors/eventmesh-connector-openfunction/src/main/java/org/apache/eventmesh/connector/openfunction/sink/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/openfunction}/OpenFunctionSinkConfig.java
(88%)
rename
{eventmesh-connectors/eventmesh-connector-openfunction/src/main/java/org/apache/eventmesh/connector/openfunction/source/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/openfunction}/OpenFunctionSourceConfig.java
(88%)
copy
{eventmesh-connectors/eventmesh-connector-openfunction/src/main/java/org/apache/eventmesh/connector/openfunction/sink/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/openfunction}/SinkConnectorConfig.java
(93%)
rename
{eventmesh-connectors/eventmesh-connector-openfunction/src/main/java/org/apache/eventmesh/connector/openfunction/source/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/openfunction}/SourceConnectorConfig.java
(93%)
rename
{eventmesh-connectors/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/sink/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/pravega}/PravegaSinkConfig.java
(88%)
rename
{eventmesh-connectors/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/source/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/pravega}/PravegaSourceConfig.java
(88%)
rename
{eventmesh-connectors/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/sink/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/pravega}/SinkConnectorConfig.java
(95%)
rename
{eventmesh-connectors/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/source/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/pravega}/SourceConnectorConfig.java
(95%)
rename
{eventmesh-connectors/eventmesh-connector-prometheus/src/main/java/org/apache/eventmesh/connector/prometheus/source/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/prometheus}/PrometheusSourceConfig.java
(88%)
rename
{eventmesh-connectors/eventmesh-connector-prometheus/src/main/java/org/apache/eventmesh/connector/prometheus/source/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/prometheus}/SourceConnectorConfig.java
(94%)
copy
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/sink/config/JdbcSinkConfig.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/rdb/canal/CanalSinkConfig.java
(59%)
create mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/rdb/canal/CanalSourceConfig.java
copy
{eventmesh-connectors/eventmesh-connector-mongodb/src/main/java/org/apache/eventmesh/connector/mongodb/sink/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/rdb/canal}/SinkConnectorConfig.java
(75%)
copy
{eventmesh-connectors/eventmesh-connector-mongodb/src/main/java/org/apache/eventmesh/connector/mongodb/source/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/rdb/canal}/SourceConnectorConfig.java
(75%)
rename
{eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/rdb/jdbc}/JdbcConfig.java
(96%)
copy
{eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/sink/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/rdb/jdbc}/JdbcSinkConfig.java
(89%)
rename
{eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/rdb/jdbc}/JdbcSourceConfig.java
(88%)
copy
{eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/rdb/jdbc}/MysqlConfig.java
(95%)
copy
{eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/sink/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/rdb/jdbc}/SinkConnectorConfig.java
(90%)
rename
{eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/rdb/jdbc}/SourceConnectorConfig.java
(95%)
copy
eventmesh-connectors/eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/sink/config/HttpSinkConfig.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/rdb/mongodb/MongodbSinkConfig.java
(83%)
rename
eventmesh-connectors/eventmesh-connector-file/src/main/java/org/apache/eventmesh/connector/file/source/config/FileSourceConfig.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/rdb/mongodb/MongodbSourceConfig.java
(83%)
copy
{eventmesh-connectors/eventmesh-connector-mongodb/src/main/java/org/apache/eventmesh/connector/mongodb/sink/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/rdb/mongodb}/SinkConnectorConfig.java
(93%)
rename
{eventmesh-connectors/eventmesh-connector-mongodb/src/main/java/org/apache/eventmesh/connector/mongodb/source/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/rdb/mongodb}/SourceConnectorConfig.java
(93%)
rename
eventmesh-connectors/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/sink/config/KnativeSinkConfig.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/redis/RedisSinkConfig.java
(84%)
rename
eventmesh-connectors/eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/source/config/HttpSourceConfig.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/redis/RedisSourceConfig.java
(84%)
rename
{eventmesh-connectors/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/sink/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/redis}/SinkConnectorConfig.java
(94%)
rename
{eventmesh-connectors/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/source/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/redis}/SourceConnectorConfig.java
(94%)
rename
{eventmesh-connectors/eventmesh-connector-s3/src/main/java/org/apache/eventmesh/connector/s3/source/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/s3}/S3SourceConfig.java
(83%)
rename
{eventmesh-connectors/eventmesh-connector-s3/src/main/java/org/apache/eventmesh/connector/s3/source/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/s3}/SourceConnectorConfig.java
(96%)
rename
{eventmesh-connectors/eventmesh-connector-slack/src/main/java/org/apache/eventmesh/connector/slack/sink/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/slack}/SinkConnectorConfig.java
(94%)
copy
{eventmesh-connectors/eventmesh-connector-slack/src/main/java/org/apache/eventmesh/connector/slack/sink/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/slack}/SlackSinkConfig.java
(89%)
copy
{eventmesh-connectors/eventmesh-connector-spring/src/main/java/org/apache/eventmesh/connector/spring/sink/connector
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/spring}/SinkConnectorConfig.java
(93%)
copy
{eventmesh-connectors/eventmesh-connector-spring/src/main/java/org/apache/eventmesh/connector/spring/source/connector
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/spring}/SourceConnectorConfig.java
(93%)
rename
eventmesh-connectors/eventmesh-connector-slack/src/main/java/org/apache/eventmesh/connector/slack/sink/config/SlackSinkConfig.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/spring/SpringSinkConfig.java
(84%)
rename
{eventmesh-connectors/eventmesh-connector-spring/src/main/java/org/apache/eventmesh/connector/spring/source/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/spring}/SpringSourceConfig.java
(82%)
rename
{eventmesh-connectors/eventmesh-connector-wechat/src/main/java/org/apache/eventmesh/connector/wechat/sink/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/wechat}/SinkConnectorConfig.java
(94%)
rename
{eventmesh-connectors/eventmesh-connector-wechat/src/main/java/org/apache/eventmesh/connector/wechat/sink/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/wechat}/WeChatSinkConfig.java
(88%)
rename
{eventmesh-connectors/eventmesh-connector-wecom/src/main/java/org/apache/eventmesh/connector/wecom/sink/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/wecom}/SinkConnectorConfig.java
(94%)
rename
{eventmesh-connectors/eventmesh-connector-wecom/src/main/java/org/apache/eventmesh/connector/wecom/sink/config
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/wecom}/WeComSinkConfig.java
(89%)
copy
eventmesh-connectors/eventmesh-connector-file/src/main/java/org/apache/eventmesh/connector/file/source/config/SourceConnectorConfig.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/enums/ComponentType.java
(72%)
create mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/adminserver/AdminServiceGrpc.java
create mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/adminserver/EventMeshAdminService.java
create mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/adminserver/Metadata.java
create mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/adminserver/MetadataOrBuilder.java
create mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/adminserver/Payload.java
create mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/adminserver/PayloadOrBuilder.java
rename
eventmesh-connectors/eventmesh-connector-mongodb/src/main/java/org/apache/eventmesh/connector/mongodb/sink/config/SinkConnectorConfig.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/proto/event_mesh_admin_service.proto
(69%)
copy
eventmesh-connectors/eventmesh-connector-spring/src/main/java/org/apache/eventmesh/connector/spring/sink/connector/SinkConnectorConfig.java
=> eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/Job.java
(83%)
copy
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/connector/SinkConnector.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/JobState.java
(68%)
copy
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/config/Config.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/JobType.java
(88%)
copy
eventmesh-connectors/eventmesh-connector-dingtalk/src/main/java/org/apache/eventmesh/connector/dingtalk/config/DingDingConnectServerConfig.java
=> eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/Task.java
(68%)
copy
eventmesh-connectors/eventmesh-connector-dingtalk/src/main/java/org/apache/eventmesh/connector/dingtalk/sink/config/SinkConnectorConfig.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/exception/ErrorCode.java
(71%)
copy
eventmesh-connectors/eventmesh-connector-file/src/main/java/org/apache/eventmesh/connector/file/source/config/SourceConnectorConfig.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/exception/PayloadFormatException.java
(78%)
copy
eventmesh-connectors/eventmesh-connector-file/src/main/java/org/apache/eventmesh/connector/file/source/config/SourceConnectorConfig.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/exception/RemoteRuntimeException.java
(72%)
copy
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/config/Config.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/job/DataSourceClassify.java
(85%)
copy
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/config/Config.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/job/DataSourceDriverType.java
(87%)
create mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/job/DataSourceType.java
create mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/job/JobTransportType.java
create mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/job/SyncConsistency.java
copy
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/sink/config/SinkConnectorConfig.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/job/SyncMode.java
(52%)
copy
eventmesh-connectors/eventmesh-connector-file/src/main/java/org/apache/eventmesh/connector/file/source/config/SourceConnectorConfig.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/offset/RecordOffset.java
(80%)
copy
eventmesh-connectors/eventmesh-connector-file/src/main/java/org/apache/eventmesh/connector/file/source/config/SourceConnectorConfig.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/offset/RecordPartition.java
(79%)
create mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/offset/RecordPosition.java
copy
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/sink/config/JdbcSinkConfig.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/offset/S3/S3RecordOffset.java
(70%)
rename
eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt/api/data/RecordPartition.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/offset/S3/S3RecordPartition.java
(58%)
copy
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/sink/config/JdbcSinkConfig.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/offset/canal/CanalRecordOffset.java
(69%)
rename
eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt/api/data/RecordPosition.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/offset/canal/CanalRecordPartition.java
(57%)
copy
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/sink/config/JdbcSinkConfig.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/offset/file/FileRecordOffset.java
(69%)
copy
eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt/api/data/RecordOffset.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/offset/file/FileRecordPartition.java
(61%)
copy
eventmesh-connectors/eventmesh-connector-chatgpt/src/main/java/org/apache/eventmesh/connector/chatgpt/source/config/ChatGPTSourceConfig.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/offset/http/HttpRecordOffset.java
(67%)
copy
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/config/JdbcServerConfig.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/offset/http/HttpRecordPartition.java
(69%)
copy
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/sink/config/JdbcSinkConfig.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/offset/jdbc/JdbcRecordOffset.java
(69%)
copy
eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt/api/data/RecordOffset.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/offset/jdbc/JdbcRecordPartition.java
(61%)
copy
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/sink/config/JdbcSinkConfig.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/offset/kafka/KafkaRecordOffset.java
(69%)
copy
eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt/api/data/RecordOffset.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/offset/kafka/KafkaRecordPartition.java
(58%)
copy
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/sink/config/JdbcSinkConfig.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/offset/prometheus/PrometheusRecordOffset.java
(68%)
copy
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/sink/config/JdbcSinkConfig.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/offset/prometheus/PrometheusRecordPartition.java
(67%)
copy
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/sink/config/JdbcSinkConfig.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/offset/pulsar/PulsarRecordOffset.java
(64%)
copy
eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt/api/data/RecordOffset.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/offset/pulsar/PulsarRecordPartition.java
(58%)
copy
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/sink/config/JdbcSinkConfig.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/offset/rocketmq/RocketMQRecordOffset.java
(63%)
rename
eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt/api/storage/ConnectorRecordPartition.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/offset/rocketmq/RocketMQRecordPartition.java
(53%)
rename
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/sink/config/JdbcSinkConfig.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/offset/spring/SpringRecordOffset.java
(69%)
copy
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/config/JdbcServerConfig.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/offset/spring/SpringRecordPartition.java
(68%)
copy
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/config/Config.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/payload/IPayload.java
(88%)
create mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/payload/PayloadFactory.java
create mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/payload/PayloadUtil.java
copy
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/config/MysqlConfig.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/request/BaseRemoteRequest.java
(53%)
rename
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/config/SinkConfig.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/request/FetchJobRequest.java
(86%)
copy
eventmesh-connectors/eventmesh-connector-openfunction/src/main/java/org/apache/eventmesh/connector/openfunction/config/OpenFunctionServerConfig.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/request/FetchPositionRequest.java
(70%)
copy
eventmesh-connectors/eventmesh-connector-lark/src/main/java/org/apache/eventmesh/connector/lark/config/LarkConnectServerConfig.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/request/ReportHeartBeatRequest.java
(81%)
copy
eventmesh-connectors/eventmesh-connector-openfunction/src/main/java/org/apache/eventmesh/connector/openfunction/config/OpenFunctionServerConfig.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/request/ReportPositionRequest.java
(64%)
rename
eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt/api/data/RecordOffset.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/response/BaseRemoteResponse.java
(50%)
copy
eventmesh-connectors/eventmesh-connector-spring/src/main/java/org/apache/eventmesh/connector/spring/sink/connector/SinkConnectorConfig.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/response/EmptyAckResponse.java
(83%)
rename
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/sink/config/SinkConnectorConfig.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/response/FailResponse.java
(58%)
create mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/response/FetchJobResponse.java
create mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/response/FetchPositionResponse.java
copy
eventmesh-common/src/{test/java/org/apache/eventmesh/common/utils/IPUtilsTest.java
=> main/java/org/apache/eventmesh/common/utils/PagedList.java} (50%)
copy gradle/wrapper/gradle-wrapper.properties =>
eventmesh-common/src/main/resources/META-INF/services/org.apache.eventmesh.common.remote.payload.IPayload
(67%)
copy {eventmesh-meta/eventmesh-meta-consul =>
eventmesh-connectors/eventmesh-connector-canal}/build.gradle (73%)
copy {eventmesh-storage-plugin/eventmesh-storage-redis =>
eventmesh-connectors/eventmesh-connector-canal}/gradle.properties (92%)
create mode 100644
eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/ByteArrayConverter.java
create mode 100644
eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/CanalConnectRecord.java
create mode 100644
eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/DatabaseConnection.java
create mode 100644
eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/SqlTimestampConverter.java
create mode 100644
eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/SqlUtils.java
copy
eventmesh-connectors/{eventmesh-connector-file/src/main/java/org/apache/eventmesh/connector/file/config/FileServerConfig.java
=>
eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/config/CanalServerConfig.java}
(85%)
create mode 100644
eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/dialect/AbstractDbDialect.java
create mode 100644
eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/dialect/DbDialect.java
create mode 100644
eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/dialect/MysqlDialect.java
create mode 100644
eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/interceptor/SqlBuilderLoadInterceptor.java
create mode 100644
eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/model/EventColumn.java
copy
eventmesh-connectors/{eventmesh-connector-file/src/main/java/org/apache/eventmesh/connector/file/source/config/SourceConnectorConfig.java
=>
eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/model/EventColumnIndexComparable.java}
(74%)
create mode 100644
eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/model/EventType.java
create mode 100644
eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/server/CanalConnectServer.java
rename
eventmesh-connectors/{eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/config/MysqlConfig.java
=>
eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/sink/DbLoadContext.java}
(52%)
create mode 100644
eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/sink/DbLoadData.java
create mode 100644
eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/sink/DbLoadMerger.java
create mode 100644
eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/sink/connector/CanalSinkConnector.java
create mode 100644
eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/source/EntryParser.java
create mode 100644
eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/source/connector/CanalSourceConnector.java
create mode 100644
eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/template/AbstractSqlTemplate.java
create mode 100644
eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/template/MysqlSqlTemplate.java
copy eventmesh-meta/eventmesh-meta-consul/build.gradle =>
eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/template/SqlTemplate.java
(56%)
copy
eventmesh-storage-plugin/eventmesh-storage-redis/src/main/resources/redis-client.properties
=>
eventmesh-connectors/eventmesh-connector-canal/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.openconnect.api.ConnectorCreateService
(82%)
copy eventmesh-connectors/{eventmesh-connector-knative =>
eventmesh-connector-canal}/src/main/resources/server-config.yml (100%)
copy eventmesh-connectors/{eventmesh-connector-rocketmq =>
eventmesh-connector-canal}/src/main/resources/sink-config.yml (100%)
copy eventmesh-connectors/{eventmesh-connector-rocketmq =>
eventmesh-connector-canal}/src/main/resources/source-config.yml (100%)
copy eventmesh-connectors/{eventmesh-connector-rocketmq/src/main =>
eventmesh-connector-canal/src/test}/resources/sink-config.yml (100%)
copy eventmesh-connectors/{eventmesh-connector-rocketmq/src/main =>
eventmesh-connector-canal/src/test}/resources/source-config.yml (100%)
rename
eventmesh-connectors/eventmesh-connector-lark/src/main/java/org/apache/eventmesh/connector/lark/{sink/config/SinkConnectorConfig.java
=> ConfigUtils.java} (52%)
delete mode 100644
eventmesh-connectors/eventmesh-connector-mongodb/src/main/java/org/apache/eventmesh/connector/mongodb/sink/config/MongodbSinkConfig.java
delete mode 100644
eventmesh-connectors/eventmesh-connector-mongodb/src/main/java/org/apache/eventmesh/connector/mongodb/source/config/MongodbSourceConfig.java
delete mode 100644
eventmesh-connectors/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/sink/config/PulsarSinkConfig.java
delete mode 100644
eventmesh-connectors/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/source/config/PulsarSourceConfig.java
delete mode 100644
eventmesh-connectors/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/sink/config/RedisSinkConfig.java
delete mode 100644
eventmesh-connectors/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/source/config/RedisSourceConfig.java
delete mode 100644
eventmesh-connectors/eventmesh-connector-spring/src/main/java/org/apache/eventmesh/connector/spring/sink/config/SpringSinkConfig.java
rename
eventmesh-connectors/{eventmesh-connector-spring/src/main/java/org/apache/eventmesh/connector/spring/source/connector/SourceConnectorConfig.java
=>
eventmesh-connector-wecom/src/test/java/org/apache/eventmesh/connector/wecom/connector/MockRecordOffset.java}
(73%)
copy
eventmesh-connectors/{eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/sink/config/HttpSinkConfig.java
=>
eventmesh-connector-wecom/src/test/java/org/apache/eventmesh/connector/wecom/connector/MockRecordPartition.java}
(71%)
copy {eventmesh-protocol-plugin/eventmesh-protocol-grpc =>
eventmesh-meta/eventmesh-meta-raft}/build.gradle (74%)
copy {eventmesh-storage-plugin/eventmesh-storage-redis =>
eventmesh-meta/eventmesh-meta-raft}/gradle.properties (95%)
create mode 100644
eventmesh-meta/eventmesh-meta-raft/src/main/java/org/apache/eventmesh/meta/raft/EventClosure.java
create mode 100644
eventmesh-meta/eventmesh-meta-raft/src/main/java/org/apache/eventmesh/meta/raft/EventOperation.java
copy
eventmesh-connectors/eventmesh-connector-file/src/main/java/org/apache/eventmesh/connector/file/source/config/SourceConnectorConfig.java
=>
eventmesh-meta/eventmesh-meta-raft/src/main/java/org/apache/eventmesh/meta/raft/JraftMetaService.java
(78%)
create mode 100644
eventmesh-meta/eventmesh-meta-raft/src/main/java/org/apache/eventmesh/meta/raft/JraftMetaServiceImpl.java
create mode 100644
eventmesh-meta/eventmesh-meta-raft/src/main/java/org/apache/eventmesh/meta/raft/JraftServer.java
create mode 100644
eventmesh-meta/eventmesh-meta-raft/src/main/java/org/apache/eventmesh/meta/raft/MetaStateMachine.java
create mode 100644
eventmesh-meta/eventmesh-meta-raft/src/main/java/org/apache/eventmesh/meta/raft/RaftMetaService.java
copy
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/ConfigInfo.java
=>
eventmesh-meta/eventmesh-meta-raft/src/main/java/org/apache/eventmesh/meta/raft/config/RaftMetaStorageConfiguration.java
(50%)
copy
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/connector/SourceConnectorContext.java
=>
eventmesh-meta/eventmesh-meta-raft/src/main/java/org/apache/eventmesh/meta/raft/consts/MetaRaftConstants.java
(63%)
create mode 100644
eventmesh-meta/eventmesh-meta-raft/src/main/java/org/apache/eventmesh/meta/raft/rpc/MetaServerHelper.java
create mode 100644
eventmesh-meta/eventmesh-meta-raft/src/main/java/org/apache/eventmesh/meta/raft/rpc/RequestProcessor.java
create mode 100644
eventmesh-meta/eventmesh-meta-raft/src/main/java/org/apache/eventmesh/meta/raft/snapshot/MetaSnapshotFile.java
rename
eventmesh-connectors/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/source/config/KafkaSourceConfig.java
=> eventmesh-meta/eventmesh-meta-raft/src/main/proto/request.proto (75%)
copy eventmesh-storage-plugin/eventmesh-storage-redis/gradle.properties =>
eventmesh-meta/eventmesh-meta-raft/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.meta.MetaService
(93%)
copy
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/dialect/DatabaseDialectFactory.java
=>
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/factory/ConnectorPluginFactory.java
(51%)
copy {eventmesh-connectors/eventmesh-connector-slack =>
eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-admin}/build.gradle
(79%)
copy {eventmesh-storage-plugin/eventmesh-storage-redis =>
eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-admin}/gradle.properties
(95%)
create mode 100644
eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-admin/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt/admin/AdminOffsetService.java
copy eventmesh-storage-plugin/eventmesh-storage-redis/gradle.properties =>
eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-admin/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.openconnect.offsetmgmt.api.storage.OffsetManagementService
(91%)
create mode 100644 eventmesh-registry/.gitignore
copy {eventmesh-connectors => eventmesh-registry}/build.gradle (100%)
copy {eventmesh-connectors/eventmesh-connector-s3 =>
eventmesh-registry/eventmesh-registry-api}/build.gradle (86%)
copy
eventmesh-storage-plugin/eventmesh-storage-redis/src/test/java/org/apache/eventmesh/storage/redis/AbstractRedisServer.java
=>
eventmesh-registry/eventmesh-registry-api/src/main/java/org/apache/eventmesh/registry/NotifyEvent.java
(59%)
copy
eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt/api/config/OffsetStorageConfig.java
=>
eventmesh-registry/eventmesh-registry-api/src/main/java/org/apache/eventmesh/registry/QueryInstances.java
(79%)
create mode 100644
eventmesh-registry/eventmesh-registry-api/src/main/java/org/apache/eventmesh/registry/RegisterServerInfo.java
create mode 100644
eventmesh-registry/eventmesh-registry-api/src/main/java/org/apache/eventmesh/registry/RegistryFactory.java
rename
eventmesh-connectors/eventmesh-connector-spring/src/main/java/org/apache/eventmesh/connector/spring/sink/connector/SinkConnectorConfig.java
=>
eventmesh-registry/eventmesh-registry-api/src/main/java/org/apache/eventmesh/registry/RegistryListener.java
(83%)
copy
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/dialect/DatabaseDialectFactory.java
=>
eventmesh-registry/eventmesh-registry-api/src/main/java/org/apache/eventmesh/registry/RegistryService.java
(55%)
copy
eventmesh-connectors/eventmesh-connector-file/src/main/java/org/apache/eventmesh/connector/file/source/config/SourceConnectorConfig.java
=>
eventmesh-registry/eventmesh-registry-api/src/main/java/org/apache/eventmesh/registry/exception/RegistryException.java
(73%)
copy {eventmesh-connectors/eventmesh-connector-s3 =>
eventmesh-registry/eventmesh-registry-nacos}/build.gradle (83%)
create mode 100644
eventmesh-registry/eventmesh-registry-nacos/src/main/java/org/apache/eventmesh/registry/nacos/NacosDiscoveryService.java
create mode 100644
eventmesh-registry/eventmesh-registry-nacos/src/main/java/org/apache/eventmesh/registry/nacos/NacosRegistryConfiguration.java
copy eventmesh-storage-plugin/eventmesh-storage-redis/gradle.properties =>
eventmesh-registry/eventmesh-registry-nacos/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.registry.RegistryService
(92%)
copy {eventmesh-examples => eventmesh-runtime-v2}/build.gradle (51%)
rename
eventmesh-connectors/eventmesh-connector-openfunction/src/main/java/org/apache/eventmesh/connector/openfunction/sink/config/SinkConnectorConfig.java
=>
eventmesh-runtime-v2/src/main/java/org/apache/eventmesh/runtime/Runtime.java
(78%)
rename
eventmesh-connectors/eventmesh-connector-file/src/main/java/org/apache/eventmesh/connector/file/source/config/SourceConnectorConfig.java
=>
eventmesh-runtime-v2/src/main/java/org/apache/eventmesh/runtime/RuntimeFactory.java
(76%)
copy
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/ConfigInfo.java
=>
eventmesh-runtime-v2/src/main/java/org/apache/eventmesh/runtime/RuntimeInstanceConfig.java
(53%)
create mode 100644
eventmesh-runtime-v2/src/main/java/org/apache/eventmesh/runtime/boot/RuntimeInstance.java
create mode 100644
eventmesh-runtime-v2/src/main/java/org/apache/eventmesh/runtime/boot/RuntimeInstanceStarter.java
create mode 100644
eventmesh-runtime-v2/src/main/java/org/apache/eventmesh/runtime/connector/ConnectorRuntime.java
rename
eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt/api/config/OffsetStorageConfig.java
=>
eventmesh-runtime-v2/src/main/java/org/apache/eventmesh/runtime/connector/ConnectorRuntimeConfig.java
(57%)
copy
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/dialect/mysql/MysqlDatabaseDialectFactory.java
=>
eventmesh-runtime-v2/src/main/java/org/apache/eventmesh/runtime/connector/ConnectorRuntimeFactory.java
(58%)
copy
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/connector/SinkConnector.java
=>
eventmesh-runtime-v2/src/main/java/org/apache/eventmesh/runtime/function/FunctionRuntime.java
(69%)
copy
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/config/Config.java
=>
eventmesh-runtime-v2/src/main/java/org/apache/eventmesh/runtime/function/FunctionRuntimeConfig.java
(88%)
copy
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/dialect/mysql/MysqlDatabaseDialectFactory.java
=>
eventmesh-runtime-v2/src/main/java/org/apache/eventmesh/runtime/function/FunctionRuntimeFactory.java
(60%)
copy
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/config/Config.java
=>
eventmesh-runtime-v2/src/main/java/org/apache/eventmesh/runtime/manager/ConnectorManager.java
(89%)
copy
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/config/Config.java
=>
eventmesh-runtime-v2/src/main/java/org/apache/eventmesh/runtime/manager/FunctionManager.java
(89%)
copy
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/config/Config.java
=>
eventmesh-runtime-v2/src/main/java/org/apache/eventmesh/runtime/manager/MeshManager.java
(89%)
rename
eventmesh-connectors/eventmesh-connector-dingtalk/src/main/java/org/apache/eventmesh/connector/dingtalk/sink/config/SinkConnectorConfig.java
=>
eventmesh-runtime-v2/src/main/java/org/apache/eventmesh/runtime/mesh/MeshRuntime.java
(69%)
copy
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/config/Config.java
=>
eventmesh-runtime-v2/src/main/java/org/apache/eventmesh/runtime/mesh/MeshRuntimeConfig.java
(89%)
copy
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/dialect/mysql/MysqlDatabaseDialectFactory.java
=>
eventmesh-runtime-v2/src/main/java/org/apache/eventmesh/runtime/mesh/MeshRuntimeFactory.java
(60%)
copy {eventmesh-runtime =>
eventmesh-runtime-v2}/src/main/java/org/apache/eventmesh/runtime/meta/MetaStorage.java
(100%)
copy {eventmesh-runtime =>
eventmesh-runtime-v2}/src/main/java/org/apache/eventmesh/runtime/util/BannerUtil.java
(100%)
rename
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/config/Config.java
=>
eventmesh-runtime-v2/src/main/java/org/apache/eventmesh/runtime/util/RuntimeUtils.java
(90%)
copy eventmesh-storage-plugin/eventmesh-storage-redis/gradle.properties =>
eventmesh-runtime-v2/src/main/resources/connector.yaml (95%)
copy
eventmesh-storage-plugin/eventmesh-storage-redis/src/main/resources/redis-client.properties
=> eventmesh-runtime-v2/src/main/resources/runtime.yaml (84%)
create mode 100644 eventmesh-runtime/conf/admin-server.jks
delete mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/v1/MetricsHandler.java
create mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/configuration/EventMeshAdminConfiguration.java
create mode 100644 resources/eventmesh-architecture-5.png
create mode 100644 resources/eventmesh-operator.png
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
