This is an automated email from the ASF dual-hosted git repository.
xiatian pushed a change to branch dependabot/gradle/org.redisson-redisson-3.30.0
in repository https://gitbox.apache.org/repos/asf/eventmesh.git
from 7ab8997dc Fix address in use and try to fix countDownLatch await
blocking
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 befe38ac9 Merge branch 'master' into
dependabot/gradle/org.redisson-redisson-3.30.0
No new revisions were added by this update.
Summary of changes:
.github/workflows/ci.yml | 6 +-
.github/workflows/code-scanning.yml | 2 +-
.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 | 30 +-
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 | 29 +-
.../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 | 48 +-
.../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 | 22 +-
.../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 | 24 +-
.../service/impl/EventMeshJobInfoServiceImpl.java | 27 +-
.../impl/EventMeshMysqlPositionServiceImpl.java | 27 +-
...ventMeshPositionReporterHistoryServiceImpl.java | 24 +-
.../impl/EventMeshRuntimeHeartbeatServiceImpl.java | 27 +-
.../impl/EventMeshRuntimeHistoryServiceImpl.java | 24 +-
.../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 | 31 +-
.../src/main/resources/application.yaml | 44 +-
.../src/main/resources/eventmesh-admin.properties | 31 +-
.../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 | 2 +-
.../org/apache/eventmesh/common/Constants.java | 2 +
.../common/config/CommonConfiguration.java | 15 +
.../eventmesh/common/config/ConfigService.java | 3 +
.../apache/eventmesh/common/config/FileLoad.java | 1 +
.../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 | 27 +-
.../org/apache/eventmesh/common/remote/Job.java | 8 +-
.../apache/eventmesh/common/remote/JobState.java | 17 +-
.../apache/eventmesh/common/remote/JobType.java | 7 +-
.../org/apache/eventmesh/common/remote/Task.java | 30 +-
.../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 | 23 +-
.../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 | 23 +-
.../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 ++
.../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 | 37 +-
.../loadbalance/RandomLoadBalanceSelectorTest.java | 2 +-
.../apache/eventmesh/common/utils/IPUtilsTest.java | 7 -
.../eventmesh-connector-canal}/build.gradle | 20 +-
.../eventmesh-connector-canal/gradle.properties | 33 +-
.../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 | 31 +-
.../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 | 2 +-
.../chatgpt/config/ChatGPTServerConfig.java | 2 +-
.../chatgpt/source/config/ChatGPTSourceConfig.java | 2 +-
.../source/connector/ChatGPTSourceConnector.java | 2 +-
.../config/DingDingConnectServerConfig.java | 2 +-
.../sink/connector/DingDingSinkConnector.java | 4 +-
.../sink/connector/DingDingSinkConnectorTest.java | 8 +-
.../eventmesh-connector-file/build.gradle | 1 +
.../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 | 4 +-
.../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 | 4 +-
.../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 | 1 +
.../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 +-
.../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 | 1 +
.../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 +-
.../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 | 17 +-
.../eventmesh-meta-raft/gradle.properties | 31 +-
.../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 | 50 ++
.../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 | 32 +-
.../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 | 11 +-
.../gradle.properties | 32 +-
.../offsetmgmt/admin/AdminOffsetService.java | 270 ++++++
....offsetmgmt.api.storage.OffsetManagementService | 32 +-
.../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 +-
.../eventmesh-protocol-cloudevents/build.gradle | 2 +-
.../eventmesh-protocol-grpc/build.gradle | 2 +-
.../eventmesh-protocol-http/build.gradle | 2 +-
.../eventmesh-protocol-meshmessage/build.gradle | 2 +-
eventmesh-registry/.gitignore | 42 +
.../build.gradle | 0
.../eventmesh-registry-api}/build.gradle | 6 +-
.../org/apache/eventmesh/registry/NotifyEvent.java | 33 +-
.../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 | 32 +-
.../build.gradle | 46 +-
.../java/org/apache/eventmesh/runtime/Runtime.java | 59 +-
.../apache/eventmesh/runtime/RuntimeFactory.java | 57 +-
.../eventmesh/runtime/RuntimeInstanceConfig.java | 109 +--
.../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 | 69 ++
.../eventmesh/runtime/util/RuntimeUtils.java | 4 +-
.../src/main/resources/connector.yaml | 30 +-
.../src/main/resources/runtime.yaml | 34 +-
eventmesh-runtime/conf/eventmesh.properties | 14 +
eventmesh-runtime/conf/log4j2.xml | 9 +
.../runtime/admin/handler/AdminHandlerManager.java | 2 -
.../runtime/admin/handler/v1/MetricsHandler.java | 113 ---
eventmesh-sdks/eventmesh-sdk-java/build.gradle | 2 +-
.../auth/token/impl/auth/AuthTokenUtils.java | 114 +--
.../eventmesh/spi/EventMeshExtensionType.java | 1 +
.../eventmesh-storage-rabbitmq/build.gradle | 4 +-
resources/eventmesh-architecture-5.png | Bin 0 -> 169892 bytes
resources/eventmesh-operator.png | Bin 0 -> 184473 bytes
settings.gradle | 22 +-
469 files changed, 13628 insertions(+), 2887 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/source/connector/SourceConnectorConfig.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-dingtalk/src/main/java/org/apache/eventmesh/connector/dingtalk/sink/config/SinkConnectorConfig.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-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/config/MysqlConfig.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/OffsetStorageWriter.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/OffsetStorageWriter.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/OffsetStorageWriter.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/OffsetStorageWriter.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 .github/workflows/license.yml =>
eventmesh-admin-server/src/main/resources/META-INF/spring.factories (54%)
copy .github/workflows/license.yml =>
eventmesh-admin-server/src/main/resources/application.yaml (53%)
copy .github/workflows/license.yml =>
eventmesh-admin-server/src/main/resources/eventmesh-admin.properties (53%)
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%)
rename
{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%)
rename
{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
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/protocol/grpc/proto/event_mesh_admin_service.proto
(69%)
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.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/sink/config/SinkConnectorConfig.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-mongodb/src/main/java/org/apache/eventmesh/connector/mongodb/config/MongodbServerConfig.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-mongodb/src/main/java/org/apache/eventmesh/connector/mongodb/config/MongodbServerConfig.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/offset/RecordOffset.java
(80%)
copy
eventmesh-connectors/eventmesh-connector-mongodb/src/main/java/org/apache/eventmesh/connector/mongodb/config/MongodbServerConfig.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-chatgpt/src/main/java/org/apache/eventmesh/connector/chatgpt/source/config/ChatGPTSourceConfig.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-chatgpt/src/main/java/org/apache/eventmesh/connector/chatgpt/source/config/ChatGPTSourceConfig.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-chatgpt/src/main/java/org/apache/eventmesh/connector/chatgpt/source/config/ChatGPTSourceConfig.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-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/HttpRecordPartition.java
(69%)
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/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-chatgpt/src/main/java/org/apache/eventmesh/connector/chatgpt/source/config/ChatGPTSourceConfig.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-chatgpt/src/main/java/org/apache/eventmesh/connector/chatgpt/source/config/ChatGPTSourceConfig.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/offset/prometheus/PrometheusRecordOffset.java
(68%)
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/prometheus/PrometheusRecordPartition.java
(67%)
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/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-chatgpt/src/main/java/org/apache/eventmesh/connector/chatgpt/source/config/ChatGPTSourceConfig.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%)
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/spring/SpringRecordOffset.java
(69%)
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/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/source/connector/SourceConnectorConfig.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 .github/workflows/license.yml =>
eventmesh-common/src/main/resources/META-INF/services/org.apache.eventmesh.common.remote.payload.IPayload
(53%)
copy {eventmesh-meta/eventmesh-meta-consul =>
eventmesh-connectors/eventmesh-connector-canal}/build.gradle (73%)
copy .github/workflows/license.yml =>
eventmesh-connectors/eventmesh-connector-canal/gradle.properties (53%)
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
copy
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 .github/workflows/license.yml =>
eventmesh-connectors/eventmesh-connector-canal/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.openconnect.api.ConnectorCreateService
(53%)
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 (76%)
copy .github/workflows/license.yml =>
eventmesh-meta/eventmesh-meta-raft/gradle.properties (53%)
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-mongodb/src/main/java/org/apache/eventmesh/connector/mongodb/config/MongodbServerConfig.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
create mode 100644
eventmesh-meta/eventmesh-meta-raft/src/main/java/org/apache/eventmesh/meta/raft/config/RaftMetaStorageConfiguration.java
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 .github/workflows/license.yml =>
eventmesh-meta/eventmesh-meta-raft/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.meta.MetaService
(53%)
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-meta/eventmesh-meta-consul =>
eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-admin}/build.gradle
(75%)
copy .github/workflows/license.yml =>
eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-admin/gradle.properties
(53%)
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 .github/workflows/license.yml =>
eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-admin/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.openconnect.offsetmgmt.api.storage.OffsetManagementService
(53%)
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-common/src/test/java/org/apache/eventmesh/common/utils/IPUtilsTest.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 .github/workflows/license.yml =>
eventmesh-registry/eventmesh-registry-nacos/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.registry.RegistryService
(53%)
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%)
rename
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/config/MysqlConfig.java
=>
eventmesh-runtime-v2/src/main/java/org/apache/eventmesh/runtime/RuntimeInstanceConfig.java
(51%)
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%)
create mode 100644
eventmesh-runtime-v2/src/main/java/org/apache/eventmesh/runtime/util/BannerUtil.java
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 .github/workflows/license.yml =>
eventmesh-runtime-v2/src/main/resources/connector.yaml (53%)
copy .github/workflows/license.yml =>
eventmesh-runtime-v2/src/main/resources/runtime.yaml (53%)
delete mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/v1/MetricsHandler.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]
