This is an automated email from the ASF dual-hosted git repository.
harshitha pushed a change to branch harshithasudhakar-eventmesh#4254
in repository https://gitbox.apache.org/repos/asf/eventmesh.git
from a8b4eeb3b Update IPUtils.java
add 50d6113ce [ISSUE #4062]Implement the method
printRetryThreadPoolState() in EventMeshTcpRetryer (#4063)
add 3d4e922df [ISSUE #4025] Comparison using reference equality instead of
value equality (#4387)
add d7abc3113 [ISSUE #4087] Anonymous new can be replaced with lambda
(#4391)
add 1babec1ab [ISSUE #4027] Comparison using reference equality instead of
value equality (#4392)
add 95ec17362 [ISSUE #4388] Improve the rocketmq source connector offset
ack (#4389)
add 8f137844e feat: refactor with rabbitmq plugin.
add 32e11dd63 feat: refactor with rabbitmq plugin.
add beb2e57a5 feat: refactor with rabbitmq plugin.
add 403ae9ca7 feat: refactor with rabbitmq plugin.
add a5639bff8 feat: refactor with rabbitmq plugin.
add d37bd9e52 feat: refactor with rabbitmq plugin.
add 3cd567016 Merge branch 'apache:master' into rabbitmq_plugin
add a53d6b342 Merge remote-tracking branch 'origin/rabbitmq_plugin' into
rabbitmq_plugin
add d7bd58131 feat: refactor with rabbitmq plugin.
add 47d88a06f feat: refactor with rabbitmq plugin.
add ac4c5cb88 feat: refactor with rabbitmq plugin.
add 1b717a382 Merge branch 'apache:master' into rabbitmq_plugin
add ce4c8bb52 Merge remote-tracking branch 'origin/rabbitmq_plugin' into
rabbitmq_plugin
add 3f1783f6a feat: refactor with rabbitmq plugin.
add fd1102ac0 Merge pull request #4393 from fabian4/rabbitmq_plugin
add 5ecbe7bc1 Update .asf.yaml
add 738e98d03 Merge pull request #4399 from apache/qqeasonchen-patch-19
add 51a117154 [ISSUE #4195] Do some code optimization.[SubscribeProcessor]
(#4383)
add fcedbbc1c [ISSUE #4341] WebHookConfig failed to load after being
inserted (#4344)
add ebd5b5eac [ISSUE 4042] EventMesh Integrated k8s with different
components. (#4377)
add 707c98da9 [ISSUE #4390] Realize the SPI extension loading of RabbitMQ
admin-api (#4395)
add 3678c23bd [ISSUE #4398] Use bash to excute shell script and fix
mis-output (#4401)
add b55e6dbf0 [ISSUE #4403] Fix the SPI extension admin-api loading of
storage-plugins (#4404)
add af53e7a54 [ISSUE #549] Unify request handler code style of tcp and
http protocol (#4333)
add 1e59cdf5c [ISSUE #4369] Move Pravega plugin into Connector from
Storage plugin moudle (#4408)
add 643f059ac [ISSUE #4129]Enhance the functionality of
EventMeshExtensionFactory (#4131)
add eea1d01af Add connector jdbc interface (#4332)
add fbbb81de1 [ISSUE #4403] Fix redis admin spi (#4405)
add 9e4a0c031 [ISSUE #4406]Optimize Body#buildBody method (#4407)
add 5d390d3a6 [ISSUE #4374] Redesign registry module into meta storage
(#4418)
add c25a89b28 Update README.md (#4422)
add 1644984ad [ISSUE #4423] Fix the meta-file error in the meta module
(#4424)
add 3f2fd1c77 [ISSUE #4019][Enhancement] Code
optimization.[SubStreamHandler] (#4056)
add da0276587 [ISSUE #4277] Add eventmesh-connector-knative (#4428)
add 4d561b814 [ISSUE #4431]Support update subscription data for
http/tcp/grpc protocol to meta storage (#4432)
add ba694b437 remove duplicated moudle (#4429)
add fbf5c81a3 [ISSUE #4435] Fix license check error (#4436)
add b83663cec update architecture picture (#4437)
add 6dfd46d3e [ISSUE #4396] Realize the admin function for Kafka
storage-plugin (#4438)
add 74f9abf5e [ISSUE #4409]Support source connector jdbc handle snapshot
data for mysql (#4434)
add ff663e2fe [ISSUE #4091]refactor: replace with lambda. use the correct
log format. (#4445)
add 20ae1e120 Merge branch 'master' into harshithasudhakar-eventmesh#4254
No new revisions were added by this update.
Summary of changes:
.asf.yaml | 2 +-
.github/workflows/ci.yml | 23 +-
.gitignore | 2 +-
README.md | 6 +-
build.gradle | 8 +-
.../eventmesh/common/ResetCountDownLatch.java | 180 ++
.../org/apache/eventmesh/common/ThreadWrapper.java | 130 +
.../common/config/CommonConfiguration.java | 39 +-
.../catalog/protos/QueryOperationsResponse.java | 4 +-
.../protocol/catalog/protos/RegistryResponse.java | 4 +-
.../eventmesh/common/protocol/http/body/Body.java | 61 +-
.../eventmesh/common/ResetCountDownLatchTest.java | 79 +
.../apache/eventmesh/common/ThreadWrapperTest.java | 134 +
.../common/config/CommonConfigurationTest.java | 12 +-
.../src/test/resources/configuration.properties | 14 +-
.../eventmesh-connector-jdbc}/build.gradle | 47 +-
.../src/main/antlr/MySqlLexer.g4 | 1356 ++++++++++
.../src/main/antlr/MySqlParser.g4 | 2837 ++++++++++++++++++++
.../connector/jdbc/AbstractPartition.java | 6 +-
.../eventmesh/connector/jdbc/CatalogChanges.java | 140 +
.../connector/jdbc/DataTypeConvertor.java | 78 +
.../eventmesh/connector/jdbc/DatabaseDialect.java | 74 +
.../org/apache/eventmesh/connector/jdbc/Field.java | 72 +
.../eventmesh/connector/jdbc/JdbcConnectData.java | 0
.../eventmesh/connector/jdbc/JdbcContext.java | 15 +-
.../connector/jdbc/JdbcDriverMetaData.java | 29 +-
.../eventmesh/connector/jdbc/OffsetContext.java | 36 +-
.../apache/eventmesh/connector/jdbc/Partition.java | 31 +-
.../connector/jdbc/PartitionOffSetContextPair.java | 32 +-
.../apache/eventmesh/connector/jdbc/Payload.java | 84 +
.../apache/eventmesh/connector/jdbc/Schema.java | 18 +-
.../connector/jdbc/UniversalJdbcContext.java | 76 +
.../connector/jdbc/UniversalOffsetContext.java | 6 +-
.../connector/jdbc/antlr4/Antlr4DdlParser.java | 75 +
.../antlr4/listener/Antlr4DdlParserListener.java | 21 +-
.../connector/jdbc/common/SourceInfo.java | 10 +-
.../connector/jdbc/config/JdbcConfig.java | 63 +
.../connector/jdbc/config/JdbcServerConfig.java | 16 +-
.../connector/jdbc/connection/JdbcConnection.java | 596 ++++
.../jdbc/connection/JdbcConnectionProvider.java | 50 +
.../jdbc/connection/PreparedParameter.java | 16 +-
.../jdbc/connection/mysql/MysqlJdbcConnection.java | 186 ++
.../jdbc/context/mysql/MysqlOffsetContext.java | 45 +-
.../jdbc/context/mysql/MysqlPartition.java | 33 +-
.../connector/jdbc/ddl/AbstractDdlParser.java | 62 +
.../eventmesh/connector/jdbc/ddl/DdlParser.java | 57 +
.../connector/jdbc/ddl/DdlParserCallback.java | 28 +-
.../connector/jdbc/event/AbstractEvent.java | 42 +-
.../connector/jdbc/event/AlertDatabaseEvent.java | 25 +-
.../connector/jdbc/event/AlertTableEvent.java | 24 +-
.../connector/jdbc/event/CreateDatabaseEvent.java | 25 +-
.../connector/jdbc/event/CreateTableEvent.java | 25 +-
.../connector/jdbc/event/DataChangeEvent.java | 25 +-
.../connector/jdbc/event/DataChangeEventType.java | 17 +-
.../connector/jdbc/event/DeleteDataEvent.java | 23 +-
.../connector/jdbc/event/DropDatabaseEvent.java | 24 +-
.../connector/jdbc/event/DropTableEvent.java | 25 +-
.../eventmesh/connector/jdbc/event/Event.java | 27 +-
.../connector/jdbc/event/EventConsumer.java | 16 +-
.../connector/jdbc/event/EventHandler.java | 15 +-
.../jdbc/event/GeneralDataChangeEvent.java | 17 +-
.../jdbc/event/GeneralSchemaChangeEvent.java | 15 +-
.../connector/jdbc/event/InsertDataEvent.java | 24 +-
.../connector/jdbc/event/SchemaChangeEvent.java | 24 +-
.../jdbc/event/SchemaChangeEventType.java | 26 +-
.../connector/jdbc/event/UpdateDataEvent.java | 27 +-
.../connector/jdbc/exception/CatalogException.java | 80 +
.../jdbc/exception/DataTypeConvertException.java | 82 +
.../jdbc/exception/DatabaseNotExistException.java | 80 +
.../jdbc/exception/JdbcConnectionException.java | 6 +-
.../jdbc/exception/TableNotExistException.java | 79 +
.../connector/jdbc/server/JdbcConnectorServer.java | 37 +-
.../connector/jdbc/source/AbstractEngine.java | 121 +
.../source/AbstractEventMeshJdbcEventTask.java | 30 +-
.../jdbc/source/AbstractEventMeshJdbcTask.java | 17 +-
.../jdbc/source/AbstractJdbcTaskManager.java | 67 +
.../eventmesh/connector/jdbc/source/Engine.java | 28 +-
.../connector/jdbc/source/EventDispatcher.java | 39 +-
.../jdbc/source/EventMeshJdbcEventTask.java | 45 +
.../connector/jdbc/source/EventMeshJdbcTask.java | 24 +-
.../jdbc/source/JdbcAllFactoryLoader.java | 72 +
.../connector/jdbc/source/JdbcSourceConnector.java | 195 ++
.../connector/jdbc/source/JdbcTaskManager.java | 32 +-
.../jdbc/source/SourceEventMeshJdbcEventTask.java | 77 +
.../jdbc/source/SourceJdbcTaskManager.java | 91 +
.../connector/jdbc/source/SourceMateData.java | 64 +
.../jdbc/source/TaskManagerCoordinator.java | 116 +
.../connector/jdbc/source/TaskManagerListener.java | 18 +-
.../jdbc/source/config/JdbcSourceConfig.java | 14 +-
.../connector/jdbc/source/config/MysqlConfig.java | 36 +-
.../jdbc/source/config/SourceConnectorConfig.java | 78 +
.../dialect/AbstractGeneralDatabaseDialect.java | 57 +
.../source/dialect/DatabaseDialectFactory.java | 23 +-
.../jdbc/source/dialect/DatabaseType.java | 25 +-
.../dialect/antlr4/mysql/MysqlAntlr4DdlParser.java | 153 ++
.../listener/ColumnDefinitionParserListener.java | 149 +
.../listener/CreateDatabaseParserListener.java | 98 +
.../mysql/listener/CreateTableParserListener.java | 163 ++
.../mysql/listener/DefaultValueParserListener.java | 154 ++
.../mysql/listener/DropDatabaseParserListener.java | 64 +
.../listener/MySqlAntlr4DdlParserListener.java | 72 +
.../mysql/listener/TableBaseParserListener.java | 180 ++
.../listener/TruncateTableParserListener.java | 55 +
.../jdbc/source/dialect/cdc/CdcEngine.java | 33 +-
.../jdbc/source/dialect/cdc/CdcEngineFactory.java | 49 +
.../dialect/cdc/RandomTaskSelectStrategy.java | 53 +-
.../source/dialect/cdc/TaskSelectStrategy.java | 27 +-
.../EventDataDeserializationExceptionData.java | 31 +-
.../jdbc/source/dialect/mysql/GtidSet.java | 485 ++++
.../dialect/mysql/MysqlDataTypeConvertor.java | 230 ++
.../source/dialect/mysql/MysqlDatabaseDialect.java | 313 +++
.../dialect/mysql/MysqlDatabaseDialectFactory.java | 22 +-
.../jdbc/source/dialect/mysql/MysqlDialectSql.java | 87 +
.../source/dialect/mysql/MysqlJdbcContext.java | 108 +
.../jdbc/source/dialect/mysql/MysqlSourceInfo.java | 29 +-
.../source/dialect/mysql/MysqlSourceMateData.java | 162 ++
.../jdbc/source/dialect/mysql/StopEventData.java | 15 +-
.../dialect/mysql/StopEventDataDeserializer.java | 15 +-
.../dialect/snapshot/AbstractSnapshotEngine.java | 371 +++
.../source/dialect/snapshot/SnapshotEngine.java | 45 +
.../dialect/snapshot/SnapshotEngineFactory.java | 43 +
.../source/dialect/snapshot/SnapshotResult.java | 25 +-
.../jdbc/source/dialect/snapshot/SnapshotType.java | 18 +-
.../snapshot/mysql/MysqlSnapshotEngine.java | 311 +++
.../snapshot/mysql/MysqlSnapshotEngineFactory.java | 39 +
.../table/catalog/AbstractColumnEditorImpl.java | 269 ++
.../table/catalog/AbstractTableEditorImpl.java | 212 ++
.../connector/jdbc/table/catalog/Catalog.java | 96 +
.../jdbc/table/catalog/CatalogSchema.java | 39 +-
.../connector/jdbc/table/catalog/CatalogTable.java | 23 +-
.../jdbc/table/catalog/CatalogTableSet.java | 97 +
.../connector/jdbc/table/catalog/Column.java | 89 +
.../connector/jdbc/table/catalog/ColumnEditor.java | 135 +
.../jdbc/table/catalog/DefaultColumn.java | 62 +
.../connector/jdbc/table/catalog/Options.java | 8 +-
.../connector/jdbc/table/catalog/PrimaryKey.java | 61 +
.../connector/jdbc/table/catalog/Table.java | 23 +-
.../connector/jdbc/table/catalog/TableEditor.java | 119 +
.../connector/jdbc/table/catalog/TableId.java | 162 ++
.../connector/jdbc/table/catalog/TableSchema.java | 191 ++
.../connector/jdbc/table/catalog/UniqueKey.java | 74 +
.../jdbc/table/catalog/mysql/MysqlColumn.java | 81 +
.../table/catalog/mysql/MysqlColumnEditor.java | 70 +
.../table/catalog/mysql/MysqlColumnEditorImpl.java | 83 +
.../jdbc/table/catalog/mysql/MysqlTableEditor.java | 38 +-
.../table/catalog/mysql/MysqlTableEditorImpl.java | 48 +
.../table/catalog/mysql/MysqlTableOptions.java | 12 +-
.../jdbc/table/catalog/mysql/MysqlTableSchema.java | 44 +
.../connector/jdbc/table/type/CalendarType.java | 85 +
.../connector/jdbc/table/type/DecimalType.java | 44 +-
.../jdbc/table/type/EventMeshDataType.java | 30 +-
.../connector/jdbc/table/type/EventMeshRow.java | 87 +
.../table/type/EventMeshTypeNameConverter.java | 62 +
.../connector/jdbc/table/type/EvetMeshRowType.java | 37 +-
.../connector/jdbc/table/type/MapType.java | 105 +
.../eventmesh/connector/jdbc/table/type/Pair.java | 18 +-
.../jdbc/table/type/PrimitiveArrayType.java | 101 +
.../jdbc/table/type/PrimitiveByteArrayType.java | 55 +-
.../connector/jdbc/table/type/PrimitiveType.java | 84 +
.../connector/jdbc/table/type/RowHandleMode.java | 86 +
.../connector/jdbc/table/type/SQLType.java | 96 +
.../connector/jdbc/utils/Antlr4Utils.java | 24 +-
.../connector/jdbc/utils/JdbcStringUtils.java | 55 +-
.../eventmesh/connector/jdbc/utils/MysqlUtils.java | 19 +-
...ctor.jdbc.source.dialect.DatabaseDialectFactory | 5 +-
...nector.jdbc.source.dialect.cdc.CdcEngineFactory | 5 +-
...c.source.dialect.snapshot.SnapshotEngineFactory | 5 +-
.../src/main/resources/log4j2.xml | 31 +
.../src/main/resources/server-config.yml | 0
.../src/main/resources/source-config.yml | 59 +
.../connector/jdbc/table/catalog/TableIdTest.java | 70 +
.../connector/jdbc/utils/Antlr4UtilsTest.java | 72 +
.../connector/jdbc/utils/JdbcStringUtilsTest.java | 55 +
.../connector/jdbc/utils/MysqlUtilsTest.java | 36 +-
.../kafka/sink/connector/KafkaSinkConnector.java | 20 +-
.../source/connector/KafkaSourceConnector.java | 18 +-
.../eventmesh-connector-knative}/build.gradle | 14 +-
.../eventmesh-connector-knative}/gradle.properties | 2 +-
.../knative/cloudevent}/KnativeHeaders.java | 2 +-
.../knative/cloudevent/KnativeMessageFactory.java | 9 +-
.../knative/config/KnativeServerConfig.java | 16 +-
.../knative/server/KnativeConnectServer.java | 46 +
.../knative/sink/config/KnativeSinkConfig.java | 13 +-
.../knative/sink/config/SinkConnectorConfig.java | 14 +-
.../sink/connector/KnativeSinkConnector.java | 117 +
.../knative/source/config/KnativeSourceConfig.java | 13 +-
.../source/config/SourceConnectorConfig.java | 16 +-
.../source/connector/KnativeSourceConnector.java | 79 +
.../src/main/resources/server-config.yml | 0
.../src/main/resources/sink-config.yml | 16 +-
.../src/main/resources/source-config.yml | 24 +-
.../eventmesh-connector-mongodb/gradle.properties | 2 +-
.../sink/connector/MongodbSinkConnector.java | 47 +-
.../source/connector/MongodbSourceConnector.java | 30 +-
.../sink/connector/OpenFunctionSinkConnector.java | 2 +-
.../connector/OpenFunctionSourceConnector.java | 2 +-
.../eventmesh-connector-pravega}/build.gradle | 14 +-
.../eventmesh-connector-pravega}/gradle.properties | 2 +-
.../pravega/client/PravegaCloudEventWriter.java | 2 +-
.../connector}/pravega/client/PravegaEvent.java | 15 +-
.../pravega/config/PravegaServerConfig.java | 16 +-
.../exception/PravegaConnectorException.java | 10 +-
.../pravega/server/PravegaConnectServer.java | 46 +
.../pravega/sink/config/PravegaSinkConfig.java | 13 +-
.../pravega/sink/config/SinkConnectorConfig.java | 26 +-
.../sink/connector/PravegaSinkConnector.java | 158 ++
.../pravega/source/config/PravegaSourceConfig.java | 13 +-
.../source/config/SourceConnectorConfig.java | 27 +-
.../source/connector/PravegaSourceConnector.java | 215 ++
.../src/main/resources/server-config.yml | 0
.../src/main/resources/sink-config.yml | 22 +-
.../src/main/resources/source-config.yml | 31 +-
.../pulsar/sink/connector/PulsarSinkConnector.java | 13 +-
.../source/connector/PulsarSourceConnector.java | 14 +-
.../eventmesh-connector-rabbitmq}/build.gradle | 15 +-
.../gradle.properties | 4 +-
.../connector/rabbitmq/client/RabbitmqClient.java | 148 +
.../rabbitmq/client/RabbitmqConnectionFactory.java | 34 +-
.../rabbitmq/cloudevent/RabbitmqCloudEvent.java | 38 +-
.../cloudevent/RabbitmqCloudEventWriter.java | 38 +-
.../rabbitmq/config/RabbitMQServerConfig.java | 12 +-
.../exception/RabbitmqConnectorException.java | 10 +-
.../rabbitmq/server/RabbitMQConnectorServer.java | 46 +
.../rabbitmq/sink/config/RabbitMQSinkConfig.java | 13 +-
.../rabbitmq/sink/config/SinkConnectorConfig.java | 26 +-
.../sink/connector/RabbitMQSinkConnector.java | 128 +
.../source/config/RabbitMQSourceConfig.java | 14 +-
.../source/config/SourceConnectorConfig.java | 26 +-
.../source/connector/RabbitMQSourceConnector.java | 188 ++
.../connector/rabbitmq/utils/ByteArrayUtils.java | 42 +
.../src/main/resources/server-config.yml | 0
.../src/main/resources/sink-config.yml | 23 +-
.../src/main/resources/source-config.yml | 32 +-
.../eventmesh-connector-redis/gradle.properties | 2 +-
.../redis/sink/connector/RedisSinkConnector.java | 45 +-
.../source/connector/RedisSourceConnector.java | 28 +-
.../source/connector/RocketMQSourceConnector.java | 99 +-
.../s3/source/connector/S3SourceConnector.java | 13 +
.../build.gradle | 0
.../eventmesh-meta-api}/build.gradle | 0
.../eventmesh/api/exception/MetaException.java | 8 +-
.../org/apache/eventmesh/api/meta/MetaService.java | 48 +-
.../api/meta}/bo/EventMeshAppSubTopicInfo.java | 2 +-
.../api/meta}/bo/EventMeshServicePubTopicInfo.java | 2 +-
.../api/meta/config/EventMeshMetaConfig.java | 8 +-
.../eventmesh/api/meta}/dto/EventMeshDataInfo.java | 2 +-
.../api/meta}/dto/EventMeshRegisterInfo.java | 2 +-
.../api/meta}/dto/EventMeshUnRegisterInfo.java | 2 +-
.../eventmesh-meta-consul}/build.gradle | 2 +-
.../eventmesh-meta-consul}/gradle.properties | 2 +-
.../meta}/consul/config/ConsulTLSConfig.java | 2 +-
.../meta/consul/service/ConsulMetaService.java | 59 +-
.../meta}/consul/service/HeatBeatScheduler.java | 2 +-
.../org.apache.eventmesh.api.meta.MetaService | 5 +-
.../src/test/java/ConsulMetaServiceTest.java | 78 +-
.../eventmesh-meta-etcd}/build.gradle | 2 +-
.../eventmesh-meta-etcd}/gradle.properties | 4 +-
.../meta}/etcd/constant/EtcdConstant.java | 2 +-
.../meta}/etcd/factory/EtcdClientFactory.java | 8 +-
.../meta}/etcd/factory/EtcdClientWrapper.java | 2 +-
.../eventmesh/meta}/etcd/factory/EtcdLeaseId.java | 2 +-
.../meta}/etcd/factory/EtcdStreamObserver.java | 2 +-
.../meta}/etcd/service/EtcdCustomService.java | 20 +-
.../meta/etcd/service/EtcdMetaService.java | 80 +-
.../org.apache.eventmesh.api.meta.MetaService | 5 +-
.../registry/etcd/service/EtcdMetaServiceTest.java | 69 +-
.../eventmesh-meta-nacos}/build.gradle | 2 +-
.../eventmesh-meta-nacos}/gradle.properties | 4 +-
.../config/NacosMetaStorageConfiguration.java | 6 +-
.../meta}/nacos/constant/NacosConstant.java | 2 +-
.../meta/nacos/service/NacosMetaService.java | 139 +-
.../org.apache.eventmesh.api.meta.MetaService | 5 +-
.../nacos/service/NacosMetaServiceTest.java | 61 +-
.../eventmesh-meta-zookeeper}/build.gradle | 2 +-
.../eventmesh-meta-zookeeper}/gradle.properties | 2 +-
.../zookeeper/config/ZKRegistryConfiguration.java | 2 +-
.../zookeeper/constant/ZookeeperConstant.java | 2 +-
.../meta}/zookeeper/pojo/EventMeshInstance.java | 2 +-
.../zookeeper/service/ZookeeperMetaService.java | 65 +-
.../org.apache.eventmesh.api.meta.MetaService | 5 +-
.../service/ZookeeperMetaServiceTest.java | 17 +-
.../src/test/resources/log4j.properties | 0
.../apache/eventmesh/openconnect/Application.java | 2 -
.../apache/eventmesh/openconnect/SinkWorker.java | 17 +-
.../apache/eventmesh/openconnect/SourceWorker.java | 2 +-
.../api/connector/ConnectorContext.java | 3 -
.../api/connector/SinkConnectorContext.java | 2 -
.../api/connector/SourceConnectorContext.java | 1 -
.../eventmesh/openconnect/util/CloudEventUtil.java | 77 +
.../offsetmgmt/api/data/RecordOffset.java | 2 +-
.../api/storage/ConnectorRecordPartition.java | 1 -
.../offsetmgmt/nacos/NacosConfigService.java | 6 +-
eventmesh-operator/eventmesh-operator.md | 184 ++
...g.apache.eventmesh.api.registry.RegistryService | 16 -
...g.apache.eventmesh.api.registry.RegistryService | 16 -
eventmesh-runtime/bin/start.sh | 33 +-
eventmesh-runtime/bin/stop.sh | 23 +-
eventmesh-runtime/build.gradle | 4 +-
eventmesh-runtime/conf/eventmesh.properties | 68 +-
eventmesh-runtime/conf/log4j2.xml | 2 +-
.../java/org/apache/eventmesh/runtime/acl/Acl.java | 4 +-
.../admin/controller/ClientManageController.java | 34 +-
.../admin/handler/ConfigurationHandler.java | 4 +-
.../{RegistryHandler.java => MetaHandler.java} | 24 +-
.../handler/QueryRecommendEventMeshHandler.java | 2 +-
.../handler/RedirectClientByIpPortHandler.java | 2 +-
.../admin/handler/RedirectClientByPathHandler.java | 2 +-
.../handler/RedirectClientBySubSystemHandler.java | 2 +-
.../admin/handler/RejectAllClientHandler.java | 2 +-
.../admin/handler/RejectClientByIpPortHandler.java | 2 +-
.../handler/RejectClientBySubSystemHandler.java | 2 +-
.../runtime/admin/handler/TCPClientHandler.java | 2 +-
.../eventmesh/runtime/boot/AbstractHTTPServer.java | 522 ++--
.../runtime/boot/AbstractRemotingServer.java | 75 +-
.../eventmesh/runtime/boot/AbstractTCPServer.java | 498 ++++
.../runtime/boot/EventMeshGrpcServer.java | 22 +-
.../runtime/boot/EventMeshHTTPServer.java | 228 +-
.../runtime/boot/EventMeshHttpBootstrap.java | 1 +
.../eventmesh/runtime/boot/EventMeshServer.java | 32 +-
.../eventmesh/runtime/boot/EventMeshTCPServer.java | 371 +--
.../runtime/boot/HTTPThreadPoolGroup.java | 150 ++
.../eventmesh/runtime/boot/TCPThreadPoolGroup.java | 75 +
.../eventmesh/runtime/boot/ThreadPoolGroup.java | 13 +-
.../configuration/EventMeshGrpcConfiguration.java | 8 +-
.../configuration/EventMeshHTTPConfiguration.java | 8 +-
.../runtime/core/consumer/SubscriptionManager.java | 55 +
.../protocol/grpc/consumer/EventMeshConsumer.java | 65 +-
.../consumer/consumergroup/StreamTopicConfig.java | 4 +
.../grpc/processor/SubscribeProcessor.java | 8 +-
.../processor/LocalSubscribeEventProcessor.java | 2 +-
.../processor/LocalUnSubscribeEventProcessor.java | 2 +-
.../http/processor/SendAsyncEventProcessor.java | 2 +-
.../http/processor/SubscribeProcessor.java | 1 +
.../http/processor/UnSubscribeProcessor.java | 1 +
.../http/processor/inf/AbstractEventProcessor.java | 60 +-
.../http/producer/ProducerTopicManager.java | 6 +-
.../protocol/http/push/HTTPMessageHandler.java | 4 +-
.../protocol/tcp/client/EventMeshTcp2Client.java | 28 +-
.../tcp/client/EventMeshTcpConnectionHandler.java | 100 -
.../tcp/client/EventMeshTcpExceptionHandler.java | 61 -
.../tcp/client/EventMeshTcpMessageDispatcher.java | 248 --
.../tcp/client/group/ClientGroupWrapper.java | 7 +-
.../client/group/ClientSessionGroupMapping.java | 60 +-
.../GoodbyeProcessor.java} | 22 +-
.../HeartBeatProcessor.java} | 13 +-
.../HelloProcessor.java} | 15 +-
.../ListenProcessor.java} | 18 +-
.../MessageAckProcessor.java} | 17 +-
.../MessageTransferProcessor.java} | 29 +-
.../RecommendProcessor.java} | 20 +-
.../SubscribeProcessor.java} | 19 +-
.../tcp/client/processor/TcpProcessor.java | 13 +-
.../UnSubscribeProcessor.java} | 18 +-
.../client/rebalance/EventMeshRebalanceImpl.java | 8 +-
.../client/recommend/EventMeshRecommendImpl.java | 6 +-
.../client/session/retry/EventMeshTcpRetryer.java | 2 +
.../tcp/client/session/send/SessionSender.java | 2 +-
.../protocol/tcp/client/task/AbstractTask.java | 41 -
.../Registry.java => meta/MetaStorage.java} | 86 +-
.../runtime/metrics/http/HTTPMetricsServer.java | 14 +-
.../runtime/metrics/tcp/EventMeshTcpMonitor.java | 10 +-
.../eventmesh/runtime/util/ThreadPoolHelper.java | 46 +
.../controller/ClientManageControllerTest.java | 6 +-
.../QueryRecommendEventMeshHandlerTest.java | 4 +-
.../runtime/boot/EventMeshServerTest.java | 4 +-
.../EventMeshGrpcConfigurationTest.java | 8 +-
.../EventMeshHTTPConfigurationTest.java | 8 +-
.../EventMeshTCPConfigurationTest.java | 4 +-
.../eventmesh/runtime/demo/AsyncSubClient.java | 18 +-
.../eventmesh/runtime/demo/SyncSubClient.java | 18 +-
.../runtime/util/ThreadPoolHelperTest.java | 71 +
.../src/test/resources/configuration.properties | 19 +-
.../client/grpc/consumer/SubStreamHandler.java | 4 +-
.../eventmesh/spi/EventMeshExtensionFactory.java | 96 +-
.../eventmesh/spi/EventMeshExtensionType.java | 6 +-
.../spi/EventMeshExtensionFactoryTest.java | 9 +
.../spi/example/AnotherSingletonExtension.java | 13 +-
.../spi/example/TestAnotherSingletonExtension.java | 15 +-
...tmesh.spi.example.TestAnotherSingletonExtension | 4 +-
.../eventmesh/storage/kafka/admin/KafkaAdmin.java | 150 ++
.../storage/kafka/admin/KafkaAdminAdaptor.java | 85 +
.../storage/kafka/common/EventMeshConstants.java | 2 +
.../storage/kafka/config/ClientConfiguration.java | 8 +
.../eventmesh/org.apache.eventmesh.api.admin.Admin | 5 +-
.../src/main/resources/kafka-client.properties | 20 +-
.../eventmesh-storage-knative/build.gradle | 40 -
.../impl/KnativeBinaryMessageReader.java | 57 -
.../cloudevent/impl/KnativeMessageWriter.java | 84 -
.../knative/config/ClientConfiguration.java | 51 -
.../storage/knative/consumer/DefaultConsumer.java | 75 -
.../knative/consumer/KnativeConsumerImpl.java | 100 -
.../storage/knative/consumer/PullConsumerImpl.java | 177 --
.../EventMeshMessageListenerConcurrently.java | 24 -
.../storage/knative/producer/AbstractProducer.java | 67 -
.../knative/producer/KnativeProducerImpl.java | 101 -
.../storage/knative/producer/ProducerImpl.java | 128 -
.../org.apache.eventmesh.api.consumer.Consumer | 16 -
.../org.apache.eventmesh.api.producer.Producer | 16 -
...he.eventmesh.api.storage.StorageResourceService | 16 -
.../src/main/resources/knative-client.properties | 18 -
.../knative/config/ClientConfigurationTest.java | 51 -
.../knative/consumer/KnativeConsumerImplTest.java | 48 -
.../knative/producer/KnativeProducerImplTest.java | 66 -
.../src/test/resources/knative-client.properties | 18 -
.../eventmesh-storage-mongodb/gradle.properties | 18 -
.../storage/mongodb/constant/MongodbConstants.java | 37 -
.../storage/mongodb/consumer/MongodbConsumer.java | 90 -
.../consumer/MongodbReplicaSetConsumer.java | 140 -
.../consumer/MongodbStandaloneConsumer.java | 178 --
.../storage/mongodb/producer/MongodbProducer.java | 99 -
.../producer/MongodbReplicaSetProducer.java | 143 -
.../producer/MongodbStandaloneProducer.java | 157 --
.../storage/mongodb/utils/MongodbSequenceUtil.java | 54 -
.../org.apache.eventmesh.api.consumer.Consumer | 16 -
.../org.apache.eventmesh.api.producer.Producer | 16 -
...he.eventmesh.api.storage.StorageResourceService | 16 -
.../src/main/resources/mongodb-client.properties | 29 -
.../storage/mongodb/MongodbConnectorTest.java | 79 -
.../eventmesh/storage/mongodb/MongodbServer.java | 62 -
.../storage/mongodb/MongodbServerTest.java | 71 -
.../src/test/resources/mongodb-client.properties | 29 -
.../eventmesh-storage-pravega/README.md | 19 -
.../eventmesh-storage-pravega/pravega-storage.jpg | Bin 143684 -> 0 bytes
.../storage/pravega/PravegaConsumerImpl.java | 109 -
.../storage/pravega/PravegaProducerImpl.java | 121 -
.../storage/pravega/client/PravegaClient.java | 233 --
.../storage/pravega/client/SubscribeTask.java | 85 -
.../pravega/config/PravegaStorageConfig.java | 67 -
.../org.apache.eventmesh.api.consumer.Consumer | 16 -
.../org.apache.eventmesh.api.producer.Producer | 16 -
...he.eventmesh.api.storage.StorageResourceService | 16 -
.../src/main/resources/pravega-storage.properties | 26 -
.../storage/pravega/client/PravegaClientTest.java | 188 --
.../pravega/config/PravegaStorageConfigTest.java | 60 -
.../src/test/resources/pravega-storage.properties | 26 -
.../storage/pulsar/admin/PulsarAdmin.java | 36 +-
.../storage/pulsar/admin/PulsarAdminAdaptor.java | 85 +
.../eventmesh/org.apache.eventmesh.api.admin.Admin | 2 +-
.../eventmesh-storage-rabbitmq/src/README.md | 26 +
.../storage/rabbitmq/admin/RabbitMQAdmin.java | 72 +
.../rabbitmq/admin/RabbitMQAdminAdaptor.java | 85 +
.../rabbitmq/config/ConfigurationHolder.java | 6 +
.../eventmesh/org.apache.eventmesh.api.admin.Admin | 2 +-
.../src/main/resources/rabbitmq-client.properties | 23 +-
.../eventmesh/storage/redis/admin/RedisAdmin.java | 69 +
.../storage/redis/admin/RedisAdminAdaptor.java | 85 +
.../storage/redis/consumer/RedisConsumer.java | 1 -
.../eventmesh/org.apache.eventmesh.api.admin.Admin | 5 +-
.../src/main/resources/redis-client.properties | 2 +
.../webhook/admin/FileWebHookConfigOperation.java | 46 +-
.../webhook/api/common/SharedLatchHolder.java | 8 +-
.../receive/storage/WebhookFileListener.java | 46 +-
resources/eventmesh-architecture-4.png | Bin 1752505 -> 1655477
bytes
settings.gradle | 42 +-
tools/dependency-check/known-dependencies.txt | 1 -
455 files changed, 20200 insertions(+), 6877 deletions(-)
create mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/ResetCountDownLatch.java
create mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/ThreadWrapper.java
create mode 100644
eventmesh-common/src/test/java/org/apache/eventmesh/common/ResetCountDownLatchTest.java
create mode 100644
eventmesh-common/src/test/java/org/apache/eventmesh/common/ThreadWrapperTest.java
rename {eventmesh-storage-plugin/eventmesh-storage-mongodb =>
eventmesh-connectors/eventmesh-connector-jdbc}/build.gradle (53%)
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/antlr/MySqlLexer.g4
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/antlr/MySqlParser.g4
copy
eventmesh-storage-plugin/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/config/ConfigKey.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/AbstractPartition.java
(80%)
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/CatalogChanges.java
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/DataTypeConvertor.java
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/DatabaseDialect.java
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/Field.java
copy
eventmesh-storage-plugin/eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage/knative/utils/CloudEventUtils.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/JdbcConnectData.java
(100%)
copy
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/connector/ConnectorContext.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/JdbcContext.java
(70%)
copy
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/connector/SourceConnectorContext.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/JdbcDriverMetaData.java
(56%)
copy
eventmesh-storage-plugin/eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage/knative/patch/EventMeshConsumeConcurrentlyStatus.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/OffsetContext.java
(55%)
copy
eventmesh-registry-plugin/eventmesh-registry-zookeeper/src/main/java/org/apache/eventmesh/registry/zookeeper/pojo/EventMeshInstance.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/Partition.java
(67%)
copy
eventmesh-registry-plugin/eventmesh-registry-etcd/src/main/java/org/apache/eventmesh/registry/etcd/factory/EtcdStreamObserver.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/PartitionOffSetContextPair.java
(54%)
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/Payload.java
copy
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/connector/ConnectorContext.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/Schema.java
(76%)
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/UniversalJdbcContext.java
copy eventmesh-registry-plugin/eventmesh-registry-api/build.gradle =>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/UniversalOffsetContext.java
(87%)
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/antlr4/Antlr4DdlParser.java
copy
eventmesh-registry-plugin/eventmesh-registry-etcd/src/main/java/org/apache/eventmesh/registry/etcd/constant/EtcdConstant.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/antlr4/listener/Antlr4DdlParserListener.java
(69%)
copy
eventmesh-storage-plugin/eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage/knative/domain/NonStandardKeys.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/common/SourceInfo.java
(81%)
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/config/JdbcConfig.java
copy
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/connector/SourceConnectorContext.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/config/JdbcServerConfig.java
(69%)
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/connection/JdbcConnection.java
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/connection/JdbcConnectionProvider.java
copy
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/connector/ConnectorContext.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/connection/PreparedParameter.java
(76%)
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/connection/mysql/MysqlJdbcConnection.java
copy
eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt/api/data/RecordOffset.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/context/mysql/MysqlOffsetContext.java
(54%)
copy
eventmesh-registry-plugin/eventmesh-registry-etcd/src/main/java/org/apache/eventmesh/registry/etcd/factory/EtcdStreamObserver.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/context/mysql/MysqlPartition.java
(55%)
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/ddl/AbstractDdlParser.java
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/ddl/DdlParser.java
copy
eventmesh-storage-plugin/eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage/knative/patch/EventMeshConsumeConcurrentlyStatus.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/ddl/DdlParserCallback.java
(68%)
copy
eventmesh-registry-plugin/eventmesh-registry-etcd/src/main/java/org/apache/eventmesh/registry/etcd/factory/EtcdStreamObserver.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/event/AbstractEvent.java
(52%)
copy
eventmesh-storage-plugin/eventmesh-storage-pravega/src/main/java/org/apache/eventmesh/storage/pravega/PravegaStorageResourceServiceImpl.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/event/AlertDatabaseEvent.java
(60%)
copy
eventmesh-storage-plugin/eventmesh-storage-pravega/src/main/java/org/apache/eventmesh/storage/pravega/PravegaStorageResourceServiceImpl.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/event/AlertTableEvent.java
(61%)
copy
eventmesh-storage-plugin/eventmesh-storage-pravega/src/main/java/org/apache/eventmesh/storage/pravega/PravegaStorageResourceServiceImpl.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/event/CreateDatabaseEvent.java
(60%)
copy
eventmesh-storage-plugin/eventmesh-storage-pravega/src/main/java/org/apache/eventmesh/storage/pravega/PravegaStorageResourceServiceImpl.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/event/CreateTableEvent.java
(61%)
copy
eventmesh-storage-plugin/eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage/knative/patch/EventMeshConsumeConcurrentlyStatus.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/event/DataChangeEvent.java
(71%)
rename
eventmesh-storage-plugin/eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage/knative/patch/EventMeshConsumeConcurrentlyContext.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/event/DataChangeEventType.java
(74%)
copy
eventmesh-storage-plugin/eventmesh-storage-pravega/src/main/java/org/apache/eventmesh/storage/pravega/PravegaStorageResourceServiceImpl.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/event/DeleteDataEvent.java
(62%)
copy
eventmesh-storage-plugin/eventmesh-storage-pravega/src/main/java/org/apache/eventmesh/storage/pravega/PravegaStorageResourceServiceImpl.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/event/DropDatabaseEvent.java
(61%)
copy
eventmesh-storage-plugin/eventmesh-storage-pravega/src/main/java/org/apache/eventmesh/storage/pravega/PravegaStorageResourceServiceImpl.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/event/DropTableEvent.java
(61%)
copy
eventmesh-storage-plugin/eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage/knative/patch/EventMeshConsumeConcurrentlyStatus.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/event/Event.java
(68%)
copy
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/connector/ConnectorContext.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/event/EventConsumer.java
(73%)
copy
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/connector/ConnectorContext.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/event/EventHandler.java
(74%)
copy
eventmesh-storage-plugin/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/storage/MongodbStorageResourceService.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/event/GeneralDataChangeEvent.java
(64%)
copy
eventmesh-storage-plugin/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/exception/MongodbStorageException.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/event/GeneralSchemaChangeEvent.java
(63%)
copy
eventmesh-storage-plugin/eventmesh-storage-pravega/src/main/java/org/apache/eventmesh/storage/pravega/PravegaStorageResourceServiceImpl.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/event/InsertDataEvent.java
(61%)
copy
eventmesh-storage-plugin/eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage/knative/patch/EventMeshConsumeConcurrentlyStatus.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/event/SchemaChangeEvent.java
(70%)
copy
eventmesh-storage-plugin/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/storage/MongodbStorageResourceService.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/event/SchemaChangeEventType.java
(57%)
rename
eventmesh-storage-plugin/eventmesh-storage-pravega/src/main/java/org/apache/eventmesh/storage/pravega/PravegaStorageResourceServiceImpl.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/event/UpdateDataEvent.java
(59%)
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/exception/CatalogException.java
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/exception/DataTypeConvertException.java
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/exception/DatabaseNotExistException.java
copy eventmesh-registry-plugin/eventmesh-registry-api/build.gradle =>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/exception/JdbcConnectionException.java
(87%)
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/exception/TableNotExistException.java
copy
eventmesh-spi/src/main/java/org/apache/eventmesh/spi/EventMeshExtensionType.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/server/JdbcConnectorServer.java
(51%)
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/AbstractEngine.java
copy
eventmesh-registry-plugin/eventmesh-registry-etcd/src/main/java/org/apache/eventmesh/registry/etcd/factory/EtcdStreamObserver.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/AbstractEventMeshJdbcEventTask.java
(56%)
copy
eventmesh-storage-plugin/eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage/knative/storage/StorageResourceServiceKnativeImpl.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/AbstractEventMeshJdbcTask.java
(72%)
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/AbstractJdbcTaskManager.java
copy
eventmesh-storage-plugin/eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage/knative/patch/EventMeshConsumeConcurrentlyStatus.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/Engine.java
(62%)
copy
eventmesh-storage-plugin/eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage/knative/cloudevent/KnativeMessageFactory.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/EventDispatcher.java
(50%)
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/EventMeshJdbcEventTask.java
copy
eventmesh-storage-plugin/eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage/knative/patch/EventMeshConsumeConcurrentlyStatus.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/EventMeshJdbcTask.java
(60%)
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/JdbcAllFactoryLoader.java
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/JdbcSourceConnector.java
copy
eventmesh-storage-plugin/eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage/knative/patch/EventMeshConsumeConcurrentlyStatus.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/JdbcTaskManager.java
(50%)
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/SourceEventMeshJdbcEventTask.java
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/SourceJdbcTaskManager.java
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/SourceMateData.java
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/TaskManagerCoordinator.java
copy
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/connector/ConnectorContext.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/TaskManagerListener.java
(60%)
copy
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/connector/SinkConnectorContext.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/config/JdbcSourceConfig.java
(72%)
copy
eventmesh-registry-plugin/eventmesh-registry-zookeeper/src/main/java/org/apache/eventmesh/registry/zookeeper/pojo/EventMeshInstance.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/config/MysqlConfig.java
(56%)
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/config/SourceConnectorConfig.java
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/AbstractGeneralDatabaseDialect.java
copy
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/connector/SinkConnectorContext.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/DatabaseDialectFactory.java
(54%)
copy
eventmesh-storage-plugin/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/storage/MongodbStorageResourceService.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/DatabaseType.java
(59%)
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/antlr4/mysql/MysqlAntlr4DdlParser.java
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/antlr4/mysql/listener/ColumnDefinitionParserListener.java
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/antlr4/mysql/listener/CreateDatabaseParserListener.java
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/antlr4/mysql/listener/CreateTableParserListener.java
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/antlr4/mysql/listener/DefaultValueParserListener.java
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/antlr4/mysql/listener/DropDatabaseParserListener.java
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/antlr4/mysql/listener/MySqlAntlr4DdlParserListener.java
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/antlr4/mysql/listener/TableBaseParserListener.java
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/antlr4/mysql/listener/TruncateTableParserListener.java
copy
eventmesh-storage-plugin/eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage/knative/patch/EventMeshConsumeConcurrentlyStatus.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/cdc/CdcEngine.java
(50%)
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/cdc/CdcEngineFactory.java
copy
eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt/api/data/RecordOffset.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/cdc/RandomTaskSelectStrategy.java
(50%)
copy
eventmesh-storage-plugin/eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage/knative/patch/EventMeshConsumeConcurrentlyStatus.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/cdc/TaskSelectStrategy.java
(60%)
copy
eventmesh-registry-plugin/eventmesh-registry-etcd/src/main/java/org/apache/eventmesh/registry/etcd/factory/EtcdStreamObserver.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/mysql/EventDataDeserializationExceptionData.java
(53%)
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/mysql/GtidSet.java
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/mysql/MysqlDataTypeConvertor.java
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/mysql/MysqlDatabaseDialect.java
copy
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/connector/SinkConnectorContext.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/mysql/MysqlDatabaseDialectFactory.java
(60%)
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/mysql/MysqlDialectSql.java
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/mysql/MysqlJdbcContext.java
rename
eventmesh-storage-plugin/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/config/ConfigurationHolder.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/mysql/MysqlSourceInfo.java
(56%)
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/mysql/MysqlSourceMateData.java
copy
eventmesh-storage-plugin/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/storage/MongodbStorageResourceService.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/mysql/StopEventData.java
(73%)
copy
eventmesh-storage-plugin/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/storage/MongodbStorageResourceService.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/mysql/StopEventDataDeserializer.java
(64%)
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/snapshot/AbstractSnapshotEngine.java
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/snapshot/SnapshotEngine.java
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/snapshot/SnapshotEngineFactory.java
rename
eventmesh-storage-plugin/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/storage/MongodbStorageResourceService.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/snapshot/SnapshotResult.java
(62%)
copy
eventmesh-storage-plugin/eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage/knative/patch/EventMeshConsumeConcurrentlyStatus.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/snapshot/SnapshotType.java
(72%)
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/snapshot/mysql/MysqlSnapshotEngine.java
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/snapshot/mysql/MysqlSnapshotEngineFactory.java
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/table/catalog/AbstractColumnEditorImpl.java
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/table/catalog/AbstractTableEditorImpl.java
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/table/catalog/Catalog.java
copy
eventmesh-registry-plugin/eventmesh-registry-zookeeper/src/main/java/org/apache/eventmesh/registry/zookeeper/pojo/EventMeshInstance.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/table/catalog/CatalogSchema.java
(60%)
copy
eventmesh-registry-plugin/eventmesh-registry-zookeeper/src/main/java/org/apache/eventmesh/registry/zookeeper/pojo/EventMeshInstance.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/table/catalog/CatalogTable.java
(66%)
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/table/catalog/CatalogTableSet.java
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/table/catalog/Column.java
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/table/catalog/ColumnEditor.java
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/table/catalog/DefaultColumn.java
copy eventmesh-registry-plugin/eventmesh-registry-api/build.gradle =>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/table/catalog/Options.java
(85%)
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/table/catalog/PrimaryKey.java
copy
eventmesh-registry-plugin/eventmesh-registry-etcd/src/main/java/org/apache/eventmesh/registry/etcd/constant/EtcdConstant.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/table/catalog/Table.java
(69%)
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/table/catalog/TableEditor.java
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/table/catalog/TableId.java
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/table/catalog/TableSchema.java
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/table/catalog/UniqueKey.java
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/table/catalog/mysql/MysqlColumn.java
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/table/catalog/mysql/MysqlColumnEditor.java
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/table/catalog/mysql/MysqlColumnEditorImpl.java
copy
eventmesh-spi/src/main/java/org/apache/eventmesh/spi/EventMeshExtensionType.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/table/catalog/mysql/MysqlTableEditor.java
(54%)
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/table/catalog/mysql/MysqlTableEditorImpl.java
copy
eventmesh-registry-plugin/eventmesh-registry-zookeeper/src/main/java/org/apache/eventmesh/registry/zookeeper/constant/ZookeeperConstant.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/table/catalog/mysql/MysqlTableOptions.java
(73%)
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/table/catalog/mysql/MysqlTableSchema.java
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/table/type/CalendarType.java
copy
eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt/api/data/RecordOffset.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/table/type/DecimalType.java
(57%)
rename
eventmesh-storage-plugin/eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage/knative/patch/EventMeshConsumeConcurrentlyStatus.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/table/type/EventMeshDataType.java
(58%)
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/table/type/EventMeshRow.java
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/table/type/EventMeshTypeNameConverter.java
rename
eventmesh-storage-plugin/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/client/MongodbClientManager.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/table/type/EvetMeshRowType.java
(54%)
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/table/type/MapType.java
copy
eventmesh-registry-plugin/eventmesh-registry-zookeeper/src/main/java/org/apache/eventmesh/registry/zookeeper/constant/ZookeeperConstant.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/table/type/Pair.java
(72%)
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/table/type/PrimitiveArrayType.java
copy
eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt/api/data/RecordOffset.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/table/type/PrimitiveByteArrayType.java
(52%)
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/table/type/PrimitiveType.java
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/table/type/RowHandleMode.java
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/table/type/SQLType.java
rename
eventmesh-storage-plugin/eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage/knative/utils/CloudEventUtils.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/utils/Antlr4Utils.java
(62%)
copy
eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt/api/data/RecordOffset.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/utils/JdbcStringUtils.java
(51%)
rename
eventmesh-storage-plugin/eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage/knative/storage/StorageResourceServiceKnativeImpl.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/utils/MysqlUtils.java
(69%)
copy eventmesh-registry-plugin/eventmesh-registry-etcd/gradle.properties =>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.connector.jdbc.source.dialect.DatabaseDialectFactory
(89%)
copy eventmesh-registry-plugin/eventmesh-registry-etcd/gradle.properties =>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.connector.jdbc.source.dialect.cdc.CdcEngineFactory
(89%)
copy eventmesh-registry-plugin/eventmesh-registry-etcd/gradle.properties =>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.connector.jdbc.source.dialect.snapshot.SnapshotEngineFactory
(88%)
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/resources/log4j2.xml
copy eventmesh-connectors/{eventmesh-connector-mongodb =>
eventmesh-connector-jdbc}/src/main/resources/server-config.yml (100%)
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/resources/source-config.yml
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/test/java/org/apache/eventmesh/connector/jdbc/table/catalog/TableIdTest.java
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/test/java/org/apache/eventmesh/connector/jdbc/utils/Antlr4UtilsTest.java
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/test/java/org/apache/eventmesh/connector/jdbc/utils/JdbcStringUtilsTest.java
copy
eventmesh-registry-plugin/eventmesh-registry-etcd/src/main/java/org/apache/eventmesh/registry/etcd/factory/EtcdStreamObserver.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/test/java/org/apache/eventmesh/connector/jdbc/utils/MysqlUtilsTest.java
(53%)
copy {eventmesh-registry-plugin/eventmesh-registry-consul =>
eventmesh-connectors/eventmesh-connector-knative}/build.gradle (73%)
rename {eventmesh-storage-plugin/eventmesh-storage-knative =>
eventmesh-connectors/eventmesh-connector-knative}/gradle.properties (95%)
rename
{eventmesh-storage-plugin/eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage/knative/cloudevent/impl
=>
eventmesh-connectors/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/cloudevent}/KnativeHeaders.java
(94%)
rename
{eventmesh-storage-plugin/eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connectors/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector}/knative/cloudevent/KnativeMessageFactory.java
(81%)
copy
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/connector/ConnectorContext.java
=>
eventmesh-connectors/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/config/KnativeServerConfig.java
(76%)
create mode 100644
eventmesh-connectors/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/server/KnativeConnectServer.java
copy
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/connector/SinkConnectorContext.java
=>
eventmesh-connectors/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/sink/config/KnativeSinkConfig.java
(72%)
copy
eventmesh-storage-plugin/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/config/ConfigKey.java
=>
eventmesh-connectors/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/sink/config/SinkConnectorConfig.java
(79%)
create mode 100644
eventmesh-connectors/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/sink/connector/KnativeSinkConnector.java
copy
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/connector/SinkConnectorContext.java
=>
eventmesh-connectors/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/source/config/KnativeSourceConfig.java
(72%)
copy
eventmesh-storage-plugin/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/config/ConfigKey.java
=>
eventmesh-connectors/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/source/config/SourceConnectorConfig.java
(78%)
create mode 100644
eventmesh-connectors/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/source/connector/KnativeSourceConnector.java
copy eventmesh-connectors/{eventmesh-connector-mongodb =>
eventmesh-connector-knative}/src/main/resources/server-config.yml (100%)
copy eventmesh-registry-plugin/eventmesh-registry-etcd/gradle.properties =>
eventmesh-connectors/eventmesh-connector-knative/src/main/resources/sink-config.yml
(70%)
copy eventmesh-registry-plugin/eventmesh-registry-etcd/gradle.properties =>
eventmesh-connectors/eventmesh-connector-knative/src/main/resources/source-config.yml
(56%)
rename {eventmesh-storage-plugin/eventmesh-storage-pravega =>
eventmesh-connectors/eventmesh-connector-pravega}/build.gradle (73%)
rename {eventmesh-storage-plugin/eventmesh-storage-pravega =>
eventmesh-connectors/eventmesh-connector-pravega}/gradle.properties (95%)
copy
{eventmesh-storage-plugin/eventmesh-storage-pravega/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connectors/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector}/pravega/client/PravegaCloudEventWriter.java
(97%)
copy
{eventmesh-storage-plugin/eventmesh-storage-pravega/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connectors/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector}/pravega/client/PravegaEvent.java
(81%)
copy
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/connector/ConnectorContext.java
=>
eventmesh-connectors/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/config/PravegaServerConfig.java
(76%)
rename
eventmesh-storage-plugin/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/exception/MongodbStorageException.java
=>
eventmesh-connectors/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/exception/PravegaConnectorException.java
(73%)
create mode 100644
eventmesh-connectors/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/server/PravegaConnectServer.java
copy
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/connector/SinkConnectorContext.java
=>
eventmesh-connectors/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/sink/config/PravegaSinkConfig.java
(72%)
copy
eventmesh-registry-plugin/eventmesh-registry-zookeeper/src/main/java/org/apache/eventmesh/registry/zookeeper/pojo/EventMeshInstance.java
=>
eventmesh-connectors/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/sink/config/SinkConnectorConfig.java
(66%)
create mode 100644
eventmesh-connectors/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/sink/connector/PravegaSinkConnector.java
copy
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/connector/SinkConnectorContext.java
=>
eventmesh-connectors/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/source/config/PravegaSourceConfig.java
(72%)
copy
eventmesh-registry-plugin/eventmesh-registry-zookeeper/src/main/java/org/apache/eventmesh/registry/zookeeper/pojo/EventMeshInstance.java
=>
eventmesh-connectors/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/source/config/SourceConnectorConfig.java
(66%)
create mode 100644
eventmesh-connectors/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/source/connector/PravegaSourceConnector.java
copy eventmesh-connectors/{eventmesh-connector-mongodb =>
eventmesh-connector-pravega}/src/main/resources/server-config.yml (100%)
copy eventmesh-registry-plugin/eventmesh-registry-etcd/gradle.properties =>
eventmesh-connectors/eventmesh-connector-pravega/src/main/resources/sink-config.yml
(64%)
copy eventmesh-registry-plugin/eventmesh-registry-consul/gradle.properties =>
eventmesh-connectors/eventmesh-connector-pravega/src/main/resources/source-config.yml
(51%)
copy {eventmesh-registry-plugin/eventmesh-registry-consul =>
eventmesh-connectors/eventmesh-connector-rabbitmq}/build.gradle (72%)
copy eventmesh-connectors/{eventmesh-connector-mongodb =>
eventmesh-connector-rabbitmq}/gradle.properties (95%)
create mode 100644
eventmesh-connectors/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/client/RabbitmqClient.java
copy
eventmesh-spi/src/main/java/org/apache/eventmesh/spi/EventMeshExtensionType.java
=>
eventmesh-connectors/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/client/RabbitmqConnectionFactory.java
(54%)
rename
eventmesh-storage-plugin/eventmesh-storage-pravega/src/main/java/org/apache/eventmesh/storage/pravega/client/PravegaEvent.java
=>
eventmesh-connectors/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/cloudevent/RabbitmqCloudEvent.java
(66%)
rename
eventmesh-storage-plugin/eventmesh-storage-pravega/src/main/java/org/apache/eventmesh/storage/pravega/client/PravegaCloudEventWriter.java
=>
eventmesh-connectors/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/cloudevent/RabbitmqCloudEventWriter.java
(56%)
copy eventmesh-registry-plugin/eventmesh-registry-api/build.gradle =>
eventmesh-connectors/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/config/RabbitMQServerConfig.java
(81%)
rename
eventmesh-storage-plugin/eventmesh-storage-pravega/src/main/java/org/apache/eventmesh/storage/pravega/exception/PravegaStorageException.java
=>
eventmesh-connectors/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/exception/RabbitmqConnectorException.java
(73%)
create mode 100644
eventmesh-connectors/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/server/RabbitMQConnectorServer.java
copy
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/connector/SinkConnectorContext.java
=>
eventmesh-connectors/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/sink/config/RabbitMQSinkConfig.java
(72%)
copy
eventmesh-registry-plugin/eventmesh-registry-zookeeper/src/main/java/org/apache/eventmesh/registry/zookeeper/pojo/EventMeshInstance.java
=>
eventmesh-connectors/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/sink/config/SinkConnectorConfig.java
(65%)
create mode 100644
eventmesh-connectors/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/sink/connector/RabbitMQSinkConnector.java
copy
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/connector/SinkConnectorContext.java
=>
eventmesh-connectors/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/source/config/RabbitMQSourceConfig.java
(72%)
copy
eventmesh-registry-plugin/eventmesh-registry-zookeeper/src/main/java/org/apache/eventmesh/registry/zookeeper/pojo/EventMeshInstance.java
=>
eventmesh-connectors/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/source/config/SourceConnectorConfig.java
(64%)
create mode 100644
eventmesh-connectors/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/source/connector/RabbitMQSourceConnector.java
create mode 100644
eventmesh-connectors/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/utils/ByteArrayUtils.java
copy eventmesh-connectors/{eventmesh-connector-mongodb =>
eventmesh-connector-rabbitmq}/src/main/resources/server-config.yml (100%)
copy eventmesh-registry-plugin/eventmesh-registry-etcd/gradle.properties =>
eventmesh-connectors/eventmesh-connector-rabbitmq/src/main/resources/sink-config.yml
(65%)
copy eventmesh-registry-plugin/eventmesh-registry-etcd/gradle.properties =>
eventmesh-connectors/eventmesh-connector-rabbitmq/src/main/resources/source-config.yml
(53%)
rename {eventmesh-registry-plugin => eventmesh-meta}/build.gradle (100%)
copy {eventmesh-registry-plugin/eventmesh-registry-api =>
eventmesh-meta/eventmesh-meta-api}/build.gradle (100%)
rename
eventmesh-registry-plugin/eventmesh-registry-api/src/main/java/org/apache/eventmesh/api/exception/RegistryException.java
=>
eventmesh-meta/eventmesh-meta-api/src/main/java/org/apache/eventmesh/api/exception/MetaException.java
(82%)
rename
eventmesh-registry-plugin/eventmesh-registry-api/src/main/java/org/apache/eventmesh/api/registry/RegistryService.java
=>
eventmesh-meta/eventmesh-meta-api/src/main/java/org/apache/eventmesh/api/meta/MetaService.java
(62%)
rename
{eventmesh-registry-plugin/eventmesh-registry-api/src/main/java/org/apache/eventmesh/api/registry
=>
eventmesh-meta/eventmesh-meta-api/src/main/java/org/apache/eventmesh/api/meta}/bo/EventMeshAppSubTopicInfo.java
(97%)
rename
{eventmesh-registry-plugin/eventmesh-registry-api/src/main/java/org/apache/eventmesh/api/registry
=>
eventmesh-meta/eventmesh-meta-api/src/main/java/org/apache/eventmesh/api/meta}/bo/EventMeshServicePubTopicInfo.java
(97%)
rename eventmesh-registry-plugin/eventmesh-registry-api/build.gradle =>
eventmesh-meta/eventmesh-meta-api/src/main/java/org/apache/eventmesh/api/meta/config/EventMeshMetaConfig.java
(84%)
rename
{eventmesh-registry-plugin/eventmesh-registry-api/src/main/java/org/apache/eventmesh/api/registry
=>
eventmesh-meta/eventmesh-meta-api/src/main/java/org/apache/eventmesh/api/meta}/dto/EventMeshDataInfo.java
(98%)
rename
{eventmesh-registry-plugin/eventmesh-registry-api/src/main/java/org/apache/eventmesh/api/registry
=>
eventmesh-meta/eventmesh-meta-api/src/main/java/org/apache/eventmesh/api/meta}/dto/EventMeshRegisterInfo.java
(98%)
rename
{eventmesh-registry-plugin/eventmesh-registry-api/src/main/java/org/apache/eventmesh/api/registry
=>
eventmesh-meta/eventmesh-meta-api/src/main/java/org/apache/eventmesh/api/meta}/dto/EventMeshUnRegisterInfo.java
(97%)
rename {eventmesh-registry-plugin/eventmesh-registry-consul =>
eventmesh-meta/eventmesh-meta-consul}/build.gradle (93%)
rename {eventmesh-registry-plugin/eventmesh-registry-consul =>
eventmesh-meta/eventmesh-meta-consul}/gradle.properties (95%)
rename
{eventmesh-registry-plugin/eventmesh-registry-consul/src/main/java/org/apache/eventmesh/registry
=>
eventmesh-meta/eventmesh-meta-consul/src/main/java/org/apache/eventmesh/meta}/consul/config/ConsulTLSConfig.java
(96%)
rename
eventmesh-registry-plugin/eventmesh-registry-consul/src/main/java/org/apache/eventmesh/registry/consul/service/ConsulRegistryService.java
=>
eventmesh-meta/eventmesh-meta-consul/src/main/java/org/apache/eventmesh/meta/consul/service/ConsulMetaService.java
(81%)
rename
{eventmesh-registry-plugin/eventmesh-registry-consul/src/main/java/org/apache/eventmesh/registry
=>
eventmesh-meta/eventmesh-meta-consul/src/main/java/org/apache/eventmesh/meta}/consul/service/HeatBeatScheduler.java
(98%)
copy eventmesh-registry-plugin/eventmesh-registry-nacos/gradle.properties =>
eventmesh-meta/eventmesh-meta-consul/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.meta.MetaService
(92%)
rename
eventmesh-registry-plugin/eventmesh-registry-consul/src/test/java/ConsulRegistryServiceTest.java
=>
eventmesh-meta/eventmesh-meta-consul/src/test/java/ConsulMetaServiceTest.java
(57%)
rename {eventmesh-registry-plugin/eventmesh-registry-etcd =>
eventmesh-meta/eventmesh-meta-etcd}/build.gradle (92%)
copy {eventmesh-registry-plugin/eventmesh-registry-nacos =>
eventmesh-meta/eventmesh-meta-etcd}/gradle.properties (95%)
rename
{eventmesh-registry-plugin/eventmesh-registry-etcd/src/main/java/org/apache/eventmesh/registry
=>
eventmesh-meta/eventmesh-meta-etcd/src/main/java/org/apache/eventmesh/meta}/etcd/constant/EtcdConstant.java
(95%)
rename
{eventmesh-registry-plugin/eventmesh-registry-etcd/src/main/java/org/apache/eventmesh/registry
=>
eventmesh-meta/eventmesh-meta-etcd/src/main/java/org/apache/eventmesh/meta}/etcd/factory/EtcdClientFactory.java
(94%)
rename
{eventmesh-registry-plugin/eventmesh-registry-etcd/src/main/java/org/apache/eventmesh/registry
=>
eventmesh-meta/eventmesh-meta-etcd/src/main/java/org/apache/eventmesh/meta}/etcd/factory/EtcdClientWrapper.java
(97%)
rename
{eventmesh-registry-plugin/eventmesh-registry-etcd/src/main/java/org/apache/eventmesh/registry
=>
eventmesh-meta/eventmesh-meta-etcd/src/main/java/org/apache/eventmesh/meta}/etcd/factory/EtcdLeaseId.java
(97%)
copy
{eventmesh-registry-plugin/eventmesh-registry-etcd/src/main/java/org/apache/eventmesh/registry
=>
eventmesh-meta/eventmesh-meta-etcd/src/main/java/org/apache/eventmesh/meta}/etcd/factory/EtcdStreamObserver.java
(96%)
rename
{eventmesh-registry-plugin/eventmesh-registry-etcd/src/main/java/org/apache/eventmesh/registry
=>
eventmesh-meta/eventmesh-meta-etcd/src/main/java/org/apache/eventmesh/meta}/etcd/service/EtcdCustomService.java
(87%)
rename
eventmesh-registry-plugin/eventmesh-registry-etcd/src/main/java/org/apache/eventmesh/registry/etcd/service/EtcdRegistryService.java
=>
eventmesh-meta/eventmesh-meta-etcd/src/main/java/org/apache/eventmesh/meta/etcd/service/EtcdMetaService.java
(82%)
copy eventmesh-registry-plugin/eventmesh-registry-nacos/gradle.properties =>
eventmesh-meta/eventmesh-meta-etcd/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.meta.MetaService
(92%)
rename
eventmesh-registry-plugin/eventmesh-registry-etcd/src/test/java/org/apache/eventmesh/registry/etcd/service/EtcdRegistryServiceTest.java
=>
eventmesh-meta/eventmesh-meta-etcd/src/test/java/org/apache/eventmesh/registry/etcd/service/EtcdMetaServiceTest.java
(61%)
rename {eventmesh-registry-plugin/eventmesh-registry-nacos =>
eventmesh-meta/eventmesh-meta-nacos}/build.gradle (93%)
copy {eventmesh-registry-plugin/eventmesh-registry-etcd =>
eventmesh-meta/eventmesh-meta-nacos}/gradle.properties (95%)
rename
eventmesh-registry-plugin/eventmesh-registry-nacos/src/main/java/org/apache/eventmesh/registry/nacos/config/NacosRegistryConfiguration.java
=>
eventmesh-meta/eventmesh-meta-nacos/src/main/java/org/apache/eventmesh/meta/nacos/config/NacosMetaStorageConfiguration.java
(93%)
rename
{eventmesh-registry-plugin/eventmesh-registry-nacos/src/main/java/org/apache/eventmesh/registry
=>
eventmesh-meta/eventmesh-meta-nacos/src/main/java/org/apache/eventmesh/meta}/nacos/constant/NacosConstant.java
(95%)
rename
eventmesh-registry-plugin/eventmesh-registry-nacos/src/main/java/org/apache/eventmesh/registry/nacos/service/NacosRegistryService.java
=>
eventmesh-meta/eventmesh-meta-nacos/src/main/java/org/apache/eventmesh/meta/nacos/service/NacosMetaService.java
(67%)
copy eventmesh-registry-plugin/eventmesh-registry-nacos/gradle.properties =>
eventmesh-meta/eventmesh-meta-nacos/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.meta.MetaService
(92%)
rename
eventmesh-registry-plugin/eventmesh-registry-nacos/src/test/java/org/apache/eventmesh/registry/nacos/service/NacosRegistryServiceTest.java
=>
eventmesh-meta/eventmesh-meta-nacos/src/test/java/org/apache/eventmesh/registry/nacos/service/NacosMetaServiceTest.java
(64%)
rename {eventmesh-registry-plugin/eventmesh-registry-zookeeper =>
eventmesh-meta/eventmesh-meta-zookeeper}/build.gradle (94%)
rename {eventmesh-registry-plugin/eventmesh-registry-zookeeper =>
eventmesh-meta/eventmesh-meta-zookeeper}/gradle.properties (94%)
rename
{eventmesh-registry-plugin/eventmesh-registry-zookeeper/src/main/java/org/apache/eventmesh/registry
=>
eventmesh-meta/eventmesh-meta-zookeeper/src/main/java/org/apache/eventmesh/meta}/zookeeper/config/ZKRegistryConfiguration.java
(97%)
rename
{eventmesh-registry-plugin/eventmesh-registry-zookeeper/src/main/java/org/apache/eventmesh/registry
=>
eventmesh-meta/eventmesh-meta-zookeeper/src/main/java/org/apache/eventmesh/meta}/zookeeper/constant/ZookeeperConstant.java
(94%)
rename
{eventmesh-registry-plugin/eventmesh-registry-zookeeper/src/main/java/org/apache/eventmesh/registry
=>
eventmesh-meta/eventmesh-meta-zookeeper/src/main/java/org/apache/eventmesh/meta}/zookeeper/pojo/EventMeshInstance.java
(95%)
rename
eventmesh-registry-plugin/eventmesh-registry-zookeeper/src/main/java/org/apache/eventmesh/registry/zookeeper/service/ZookeeperRegistryService.java
=>
eventmesh-meta/eventmesh-meta-zookeeper/src/main/java/org/apache/eventmesh/meta/zookeeper/service/ZookeeperMetaService.java
(88%)
rename eventmesh-registry-plugin/eventmesh-registry-etcd/gradle.properties =>
eventmesh-meta/eventmesh-meta-zookeeper/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.meta.MetaService
(91%)
rename
eventmesh-registry-plugin/eventmesh-registry-zookeeper/src/test/java/org/apache/eventmesh/registry/zookeeper/service/ZookeeperRegistryServiceTest.java
=>
eventmesh-meta/eventmesh-meta-zookeeper/src/test/java/org/apache/eventmesh/registry/zookeeper/service/ZookeeperMetaServiceTest.java
(91%)
rename {eventmesh-registry-plugin/eventmesh-registry-zookeeper =>
eventmesh-meta/eventmesh-meta-zookeeper}/src/test/resources/log4j.properties
(100%)
create mode 100644
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/util/CloudEventUtil.java
create mode 100644 eventmesh-operator/eventmesh-operator.md
delete mode 100644
eventmesh-registry-plugin/eventmesh-registry-nacos/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.registry.RegistryService
delete mode 100644
eventmesh-registry-plugin/eventmesh-registry-zookeeper/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.registry.RegistryService
rename
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/{RegistryHandler.java
=> MetaHandler.java} (89%)
mode change 100755 => 100644
create mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/AbstractTCPServer.java
create mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/HTTPThreadPoolGroup.java
create mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/TCPThreadPoolGroup.java
rename
eventmesh-storage-plugin/eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage/knative/domain/NonStandardKeys.java
=>
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/ThreadPoolGroup.java
(76%)
delete mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/EventMeshTcpConnectionHandler.java
delete mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/EventMeshTcpExceptionHandler.java
delete mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/EventMeshTcpMessageDispatcher.java
rename
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/{task/GoodbyeTask.java
=> processor/GoodbyeProcessor.java} (69%)
rename
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/{task/HeartBeatTask.java
=> processor/HeartBeatProcessor.java} (82%)
rename
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/{task/HelloTask.java
=> processor/HelloProcessor.java} (90%)
rename
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/{task/ListenTask.java
=> processor/ListenProcessor.java} (75%)
rename
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/{task/MessageAckTask.java
=> processor/MessageAckProcessor.java} (77%)
rename
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/{task/MessageTransferTask.java
=> processor/MessageTransferProcessor.java} (92%)
rename
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/{task/RecommendTask.java
=> processor/RecommendProcessor.java} (84%)
rename
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/{task/SubscribeTask.java
=> processor/SubscribeProcessor.java} (83%)
copy
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/connector/ConnectorContext.java
=>
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/processor/TcpProcessor.java
(72%)
rename
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/{task/UnSubscribeTask.java
=> processor/UnSubscribeProcessor.java} (80%)
delete mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/task/AbstractTask.java
rename
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/{registry/Registry.java
=> meta/MetaStorage.java} (51%)
create mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util/ThreadPoolHelper.java
create mode 100644
eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/util/ThreadPoolHelperTest.java
copy
eventmesh-storage-plugin/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/config/ConfigKey.java
=>
eventmesh-spi/src/test/java/org/apache/eventmesh/spi/example/AnotherSingletonExtension.java
(75%)
copy
eventmesh-storage-plugin/eventmesh-storage-kafka/src/main/java/org/apache/eventmesh/storage/kafka/common/EventMeshConstants.java
=>
eventmesh-spi/src/test/java/org/apache/eventmesh/spi/example/TestAnotherSingletonExtension.java
(76%)
copy eventmesh-registry-plugin/eventmesh-registry-nacos/gradle.properties =>
eventmesh-spi/src/test/resources/META-INF/eventmesh/org.apache.eventmesh.spi.example.TestAnotherSingletonExtension
(90%)
create mode 100644
eventmesh-storage-plugin/eventmesh-storage-kafka/src/main/java/org/apache/eventmesh/storage/kafka/admin/KafkaAdmin.java
create mode 100644
eventmesh-storage-plugin/eventmesh-storage-kafka/src/main/java/org/apache/eventmesh/storage/kafka/admin/KafkaAdminAdaptor.java
copy eventmesh-registry-plugin/eventmesh-registry-nacos/gradle.properties =>
eventmesh-storage-plugin/eventmesh-storage-kafka/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.admin.Admin
(92%)
delete mode 100644
eventmesh-storage-plugin/eventmesh-storage-knative/build.gradle
delete mode 100644
eventmesh-storage-plugin/eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage/knative/cloudevent/impl/KnativeBinaryMessageReader.java
delete mode 100644
eventmesh-storage-plugin/eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage/knative/cloudevent/impl/KnativeMessageWriter.java
delete mode 100644
eventmesh-storage-plugin/eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage/knative/config/ClientConfiguration.java
delete mode 100644
eventmesh-storage-plugin/eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage/knative/consumer/DefaultConsumer.java
delete mode 100644
eventmesh-storage-plugin/eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage/knative/consumer/KnativeConsumerImpl.java
delete mode 100644
eventmesh-storage-plugin/eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage/knative/consumer/PullConsumerImpl.java
delete mode 100644
eventmesh-storage-plugin/eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage/knative/patch/EventMeshMessageListenerConcurrently.java
delete mode 100644
eventmesh-storage-plugin/eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage/knative/producer/AbstractProducer.java
delete mode 100644
eventmesh-storage-plugin/eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage/knative/producer/KnativeProducerImpl.java
delete mode 100644
eventmesh-storage-plugin/eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage/knative/producer/ProducerImpl.java
delete mode 100644
eventmesh-storage-plugin/eventmesh-storage-knative/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
delete mode 100644
eventmesh-storage-plugin/eventmesh-storage-knative/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
delete mode 100644
eventmesh-storage-plugin/eventmesh-storage-knative/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.storage.StorageResourceService
delete mode 100644
eventmesh-storage-plugin/eventmesh-storage-knative/src/main/resources/knative-client.properties
delete mode 100644
eventmesh-storage-plugin/eventmesh-storage-knative/src/test/java/org/apache/eventmesh/storage/knative/config/ClientConfigurationTest.java
delete mode 100644
eventmesh-storage-plugin/eventmesh-storage-knative/src/test/java/org/apache/eventmesh/storage/knative/consumer/KnativeConsumerImplTest.java
delete mode 100644
eventmesh-storage-plugin/eventmesh-storage-knative/src/test/java/org/apache/eventmesh/storage/knative/producer/KnativeProducerImplTest.java
delete mode 100644
eventmesh-storage-plugin/eventmesh-storage-knative/src/test/resources/knative-client.properties
delete mode 100644
eventmesh-storage-plugin/eventmesh-storage-mongodb/gradle.properties
delete mode 100644
eventmesh-storage-plugin/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/constant/MongodbConstants.java
delete mode 100644
eventmesh-storage-plugin/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/consumer/MongodbConsumer.java
delete mode 100644
eventmesh-storage-plugin/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/consumer/MongodbReplicaSetConsumer.java
delete mode 100644
eventmesh-storage-plugin/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/consumer/MongodbStandaloneConsumer.java
delete mode 100644
eventmesh-storage-plugin/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/producer/MongodbProducer.java
delete mode 100644
eventmesh-storage-plugin/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/producer/MongodbReplicaSetProducer.java
delete mode 100644
eventmesh-storage-plugin/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/producer/MongodbStandaloneProducer.java
delete mode 100644
eventmesh-storage-plugin/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/utils/MongodbSequenceUtil.java
delete mode 100644
eventmesh-storage-plugin/eventmesh-storage-mongodb/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
delete mode 100644
eventmesh-storage-plugin/eventmesh-storage-mongodb/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
delete mode 100644
eventmesh-storage-plugin/eventmesh-storage-mongodb/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.storage.StorageResourceService
delete mode 100644
eventmesh-storage-plugin/eventmesh-storage-mongodb/src/main/resources/mongodb-client.properties
delete mode 100644
eventmesh-storage-plugin/eventmesh-storage-mongodb/src/test/java/org/apache/eventmesh/storage/mongodb/MongodbConnectorTest.java
delete mode 100644
eventmesh-storage-plugin/eventmesh-storage-mongodb/src/test/java/org/apache/eventmesh/storage/mongodb/MongodbServer.java
delete mode 100644
eventmesh-storage-plugin/eventmesh-storage-mongodb/src/test/java/org/apache/eventmesh/storage/mongodb/MongodbServerTest.java
delete mode 100644
eventmesh-storage-plugin/eventmesh-storage-mongodb/src/test/resources/mongodb-client.properties
delete mode 100644 eventmesh-storage-plugin/eventmesh-storage-pravega/README.md
delete mode 100644
eventmesh-storage-plugin/eventmesh-storage-pravega/pravega-storage.jpg
delete mode 100644
eventmesh-storage-plugin/eventmesh-storage-pravega/src/main/java/org/apache/eventmesh/storage/pravega/PravegaConsumerImpl.java
delete mode 100644
eventmesh-storage-plugin/eventmesh-storage-pravega/src/main/java/org/apache/eventmesh/storage/pravega/PravegaProducerImpl.java
delete mode 100644
eventmesh-storage-plugin/eventmesh-storage-pravega/src/main/java/org/apache/eventmesh/storage/pravega/client/PravegaClient.java
delete mode 100644
eventmesh-storage-plugin/eventmesh-storage-pravega/src/main/java/org/apache/eventmesh/storage/pravega/client/SubscribeTask.java
delete mode 100644
eventmesh-storage-plugin/eventmesh-storage-pravega/src/main/java/org/apache/eventmesh/storage/pravega/config/PravegaStorageConfig.java
delete mode 100644
eventmesh-storage-plugin/eventmesh-storage-pravega/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
delete mode 100644
eventmesh-storage-plugin/eventmesh-storage-pravega/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
delete mode 100644
eventmesh-storage-plugin/eventmesh-storage-pravega/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.storage.StorageResourceService
delete mode 100644
eventmesh-storage-plugin/eventmesh-storage-pravega/src/main/resources/pravega-storage.properties
delete mode 100644
eventmesh-storage-plugin/eventmesh-storage-pravega/src/test/java/org/apache/eventmesh/storage/pravega/client/PravegaClientTest.java
delete mode 100644
eventmesh-storage-plugin/eventmesh-storage-pravega/src/test/java/org/apache/eventmesh/storage/pravega/config/PravegaStorageConfigTest.java
delete mode 100644
eventmesh-storage-plugin/eventmesh-storage-pravega/src/test/resources/pravega-storage.properties
rename
eventmesh-registry-plugin/eventmesh-registry-etcd/src/main/java/org/apache/eventmesh/registry/etcd/factory/EtcdStreamObserver.java
=>
eventmesh-storage-plugin/eventmesh-storage-pulsar/src/main/java/org/apache/eventmesh/storage/pulsar/admin/PulsarAdmin.java
(53%)
create mode 100644
eventmesh-storage-plugin/eventmesh-storage-pulsar/src/main/java/org/apache/eventmesh/storage/pulsar/admin/PulsarAdminAdaptor.java
rename
eventmesh-registry-plugin/eventmesh-registry-etcd/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.registry.RegistryService
=>
eventmesh-storage-plugin/eventmesh-storage-pulsar/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.admin.Admin
(92%)
create mode 100644
eventmesh-storage-plugin/eventmesh-storage-rabbitmq/src/README.md
create mode 100644
eventmesh-storage-plugin/eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage/rabbitmq/admin/RabbitMQAdmin.java
create mode 100644
eventmesh-storage-plugin/eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage/rabbitmq/admin/RabbitMQAdminAdaptor.java
rename
eventmesh-registry-plugin/eventmesh-registry-consul/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.registry.RegistryService
=>
eventmesh-storage-plugin/eventmesh-storage-rabbitmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.admin.Admin
(91%)
create mode 100644
eventmesh-storage-plugin/eventmesh-storage-redis/src/main/java/org/apache/eventmesh/storage/redis/admin/RedisAdmin.java
create mode 100644
eventmesh-storage-plugin/eventmesh-storage-redis/src/main/java/org/apache/eventmesh/storage/redis/admin/RedisAdminAdaptor.java
rename eventmesh-registry-plugin/eventmesh-registry-nacos/gradle.properties =>
eventmesh-storage-plugin/eventmesh-storage-redis/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.admin.Admin
(92%)
rename
eventmesh-storage-plugin/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/config/ConfigKey.java
=>
eventmesh-webhook/eventmesh-webhook-api/src/main/java/org/apache/eventmesh/webhook/api/common/SharedLatchHolder.java
(80%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
