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 323867bdd generalized suppression
add e66109c94 [ISSUE #4193]Do some code optimization. (#4452)
add 109c49377 [ISSUE #4450] Add retry strategy for sourceWorker(#4451)
add 08fabd20e [ISSUE #4060]Use AbstractRetryer to unify GrpcRetryer,
HttpRetryer and EventMeshTcpRetryer
add df0798616 [ISSUE #4454] Support File Sink Connector (#4455)
add f8d4023c5 [ISSUE #4448] Fix meta plugin dist startup failure and
upgrade gradle to 8.2.1 (#4449)
add b4feffcf5 [ISSUE #4456] startup failure caused by Retryer
add a18ff1f8b [ISSUE #4089] Anonymous new can be replaced with
lambda.[CClientDemo] (#4461)
add 927bc5bcc [ISSUE #4192] Do some code optimization.[StreamTopicConfig]
(#4464)
add ce15df9b6 [ISSUE #4439]Support source connector jdbc handle CDC for
mysql (#4457)
add 73af459c4 [ISSUE #4443] Automatically format code at build time using
the Spotless plugin with the EventMesh coding style. (#4447)
add 05900d0a1 [ISSUE #3397] Make field a static final constant or
non-public
add b6f9ca581 [ISSUE #4275] Support subscription info management with
eventmesh-admin module (#4468)
add c8b7916f7 [ISSUE #4472]Fix MeshMessageProtocolAdaptor#fromCloudEvent
throw NPE (#4473)
add 750825158 [ISSUE #4478] Upgrade JUnit to JUnit Jupiter (#4475)
add 47203c745 [ISSUE #3516] Do some code optimization.[SubClientImpl]
(#4480)
add d2ce6c963 [ISSUE #4024] Change to use equals() to compare
object.[QueryOperationsRequest]
add 82e00390c [ISSUE #4026] Comparison using reference equality instead of
value equality.[RegistryRequest] (#4482)
add d327ff3ed [ISSUE #4413] Add spring boot source connector. (#4477)
add 1a35984bc [ISSUE #4483] Standardize exception handling in tests (#4484)
add 01cec6e62 [ISSUE #4090]replace with lambda. (#4487)
add 46f7c5b88 Avoid unnecessary boxing by using plain == for primitive
types (#4485)
add 093fb6b3c [ISSUE #3520]Swap these 2 arguments so they are in the
correct order: expected value, actual value.[EventMeshServerTest] (#4486)
add e9e0080ef [ISSUE #4467]Rust SDK supports the latest gRPC protocol
(#4488)
add 53e36b56d [ISSUE #4489] Migrate eventmesh-admin module (#4490)
add f6297308f [ISSUE #4414] Add spring sink connector. (#4491)
add d2531b2ba [ISSUE #4474] Uniformly manage duplicate static variables
(#4495)
add 1b3e4962f [ISSUE#4496] Fix gradle dist error. (#4497)
add 62935c4c2 [ISSUE #4494] RESTful API framework for EventMeshAdmin
(#4498)
add d3f688dd0 [ISSUE #4415] Add Promethus source connector (#4493)
add 31b4e96a7 [ISSUE#4459] Fix unchecked call to a original type member
(#4506)
add 0b2632a1d Merge branch 'master' into harshithasudhakar-eventmesh#4254
No new revisions were added by this update.
Summary of changes:
.github/workflows/ci.yml | 4 +-
.gitignore | 3 +
build.gradle | 54 +-
eventmesh-admin/.gitignore | 36 +
eventmesh-admin/README.md | 65 +-
eventmesh-admin/build.gradle | 60 +
.../gradle.properties => docker/Dockerfile} | 7 +-
eventmesh-admin/docs/UserGuide_CN.md | 1 +
eventmesh-admin/docs/UserGuide_EN.md | 1 +
.../admin/rocketmq/controller/AdminController.java | 59 -
.../admin/rocketmq/handler/TopicsHandler.java | 133 --
.../admin/rocketmq/request/TopicCreateRequest.java | 67 -
.../admin/rocketmq/response/TopicResponse.java | 72 -
.../admin/rocketmq/util/RequestMapping.java | 94 --
.../admin/rocketmq/util/UrlMappingPattern.java | 117 --
.../rocketmq/request/TopicCreateRequestTest.java | 63 -
.../admin/rocketmq/response/TopicResponseTest.java | 56 -
.../admin/rocketmq/util/RequestMappingTest.java | 79 -
.../admin/rocketmq/util/UrlMappingPatternTest.java | 117 --
eventmesh-admin/gradle/wrapper/gradle-wrapper.jar | Bin 0 -> 63375 bytes
.../gradle}/wrapper/gradle-wrapper.properties | 4 +-
eventmesh-admin/gradlew | 248 +++
gradlew.bat => eventmesh-admin/gradlew.bat | 17 +-
eventmesh-admin/{build.gradle => settings.gradle} | 2 +
.../eventmesh/admin/EventMeshAdminApplication.java | 17 +-
.../apache/eventmesh/admin/common/ConfigConst.java | 36 +-
.../apache/eventmesh/admin/common/NacosConst.java | 43 +
.../eventmesh/admin/config/AdminProperties.java | 80 +
.../eventmesh/admin/config/MetaTypeConfig.java | 68 +
.../admin/controller/ConnectionController.java | 51 +
.../admin/controller/SubscriptionController.java | 75 +
.../org/apache/eventmesh/admin/dto/Result.java | 144 ++
.../org/apache/eventmesh/admin/enums/Errors.java | 91 ++
.../eventmesh/admin/exception/BaseException.java | 54 +
.../admin/exception/EventMeshAdminException.java | 35 +-
.../admin/exception/EventMeshException.java | 20 +-
.../admin/exception/GlobalExceptionHandler.java | 61 +
.../eventmesh/admin/exception/MetaException.java | 37 +-
.../eventmesh/admin/model/ConnectionInfo.java} | 6 +
.../eventmesh/admin/model/SubscriptionInfo.java | 19 +-
.../eventmesh/admin/service/ConnectionService.java | 11 +-
.../admin/service/SubscriptionService.java | 21 +-
.../admin/service/impl/EtcdConnectionService.java | 12 +-
.../service/impl/EtcdSubscriptionService.java | 31 +-
.../admin/service/impl/NacosConnectionService.java | 43 +
.../service/impl/NacosSubscriptionService.java | 193 +++
.../eventmesh/admin/utils/ExceptionUtils.java | 32 +-
.../src/main/resources/application.yml | 50 +-
eventmesh-admin/src/main/resources/logback.xml | 50 +
.../admin/EventMeshAdminApplicationTests.java | 11 +-
eventmesh-common/build.gradle | 5 +-
.../org/apache/eventmesh/common/Constants.java | 21 +
.../eventmesh/common/ResetCountDownLatch.java | 4 +-
.../apache/eventmesh/common/ThreadPoolFactory.java | 1 -
.../org/apache/eventmesh/common/ThreadWrapper.java | 8 +-
.../common/config/CommonConfiguration.java | 7 +-
.../org/apache/eventmesh/common/config/Config.java | 3 -
.../common/config/convert/ConverterMap.java | 1 -
.../convert/converter/BaseDataTypeConverter.java | 2 +-
.../config/convert/converter/ListConverter.java | 1 -
.../config/convert/converter/ObjectConverter.java | 2 +-
.../common/enums/EventMeshDataContentType.java | 2 +-
.../common/exception/EventMeshException.java | 2 +-
.../eventmesh/common/file/WatchFileManager.java | 1 -
.../eventmesh/common/file/WatchFileTask.java | 1 -
.../common/loadbalance/LoadBalanceType.java | 1 +
.../loadbalance/RandomLoadBalanceSelector.java | 1 -
.../eventmesh/common/loadbalance/Weight.java | 2 -
.../WeightRoundRobinLoadBalanceSelector.java | 2 -
.../common/protocol/SubscriptionItem.java | 2 -
.../common/protocol/SubscriptionMode.java | 3 +-
.../common/protocol/SubscriptionType.java | 1 +
.../catalog/protos/QueryOperationsRequest.java | 4 +-
.../protocol/catalog/protos/RegistryRequest.java | 4 +-
.../common/protocol/grpc/common/Response.java | 1 -
.../common/protocol/http/HttpCommand.java | 4 +-
.../common/protocol/http/HttpEventWrapper.java | 5 +-
.../http/WebhookProtocolTransportObject.java | 1 -
.../protocol/http/body/BaseResponseBody.java | 1 -
.../eventmesh/common/protocol/http/body/Body.java | 1 -
.../http/body/client/HeartbeatResponseBody.java | 6 +-
.../body/message/ReplyMessageResponseBody.java | 6 +-
.../body/message/SendMessageBatchRequestBody.java | 5 +-
.../body/message/SendMessageBatchResponseBody.java | 6 +-
.../message/SendMessageBatchV2ResponseBody.java | 6 +-
.../common/protocol/http/common/ProtocolKey.java | 8 +-
.../common/protocol/http/common/RequestURI.java | 1 -
.../protocol/http/header/BaseResponseHeader.java | 1 -
.../common/protocol/http/header/Header.java | 1 -
.../http/header/client/HeartbeatRequestHeader.java | 22 +-
.../header/client/HeartbeatResponseHeader.java | 1 -
.../http/header/client/RegResponseHeader.java | 11 +-
.../http/header/client/UnRegRequestHeader.java | 20 +-
.../http/header/client/UnRegResponseHeader.java | 1 -
.../header/message/PushMessageRequestHeader.java | 6 +-
.../header/message/PushMessageResponseHeader.java | 21 +-
.../header/message/ReplyMessageRequestHeader.java | 28 +-
.../header/message/ReplyMessageResponseHeader.java | 11 +-
.../message/SendMessageBatchRequestHeader.java | 26 +-
.../message/SendMessageBatchResponseHeader.java | 11 +-
.../message/SendMessageBatchV2RequestHeader.java | 27 +-
.../message/SendMessageBatchV2ResponseHeader.java | 10 +-
.../header/message/SendMessageRequestHeader.java | 26 +-
.../header/message/SendMessageResponseHeader.java | 11 +-
.../eventmesh/common/protocol/tcp/Command.java | 128 +-
.../eventmesh/common/protocol/tcp/Header.java | 1 -
.../eventmesh/common/protocol/tcp/Package.java | 2 -
.../eventmesh/common/protocol/tcp/UserAgent.java | 1 -
.../eventmesh/common/protocol/tcp/codec/Codec.java | 1 -
.../apache/eventmesh/common/utils/AssertUtils.java | 1 -
.../common/utils/ConfigurationContextUtil.java | 6 +-
.../eventmesh/common/utils/HttpConvertsUtils.java | 9 +-
.../org/apache/eventmesh/common/utils/IPUtils.java | 13 +-
.../apache/eventmesh/common/utils/JsonUtils.java | 2 +-
.../apache/eventmesh/common/utils/LogUtils.java | 214 +++
.../eventmesh/common/utils/PropertiesUtils.java | 45 +-
.../apache/eventmesh/common/utils/SystemUtils.java | 2 +-
.../apache/eventmesh/common/utils/TypeUtils.java} | 26 +-
.../eventmesh/common/EventMeshMessageTest.java | 20 +-
.../common/EventMeshThreadFactoryTest.java | 12 +-
.../eventmesh/common/ResetCountDownLatchTest.java | 37 +-
.../apache/eventmesh/common/ThreadWrapperTest.java | 29 +-
.../common/config/CommonConfigurationTest.java | 52 +-
.../eventmesh/common/config/ConfigServiceTest.java | 6 +-
.../common/file/WatchFileManagerTest.java | 9 +-
.../loadbalance/RandomLoadBalanceSelectorTest.java | 14 +-
.../WeightRandomLoadBalanceSelectorTest.java | 17 +-
.../WeightRoundRobinLoadBalanceSelectorTest.java | 16 +-
.../eventmesh/common/loadbalance/WeightTest.java | 10 +-
.../grpc/common/EventMeshCloudEventUtilsTest.java | 170 +--
.../common/protocol/http/HttpCommandTest.java | 34 +-
.../common/protocol/http/HttpEventWrapperTest.java | 41 +-
.../protocol/http/body/BaseResponseBodyTest.java | 16 +-
.../common/protocol/http/body/BodyTest.java | 62 +-
.../http/header/BaseRequestHeaderTest.java | 11 +-
.../http/header/BaseResponseHeaderTest.java | 10 +-
.../common/protocol/http/header/HeaderTest.java | 62 +-
.../header/client/AbstractRequestHeaderTest.java | 22 +-
.../header/client/AbstractResponseHeaderTest.java | 24 +-
.../header/client/HeartbeatRequestHeaderTest.java | 3 +-
.../header/client/HeartbeatResponseHeaderTest.java | 2 +-
.../http/header/client/RegRequestHeaderTest.java | 2 +-
.../http/header/client/RegResponseHeaderTest.java | 2 +-
.../header/client/SubscribeRequestHeaderTest.java | 2 +-
.../header/client/SubscribeResponseHeaderTest.java | 3 +-
.../http/header/client/UnRegRequestHeaderTest.java | 3 +-
.../header/client/UnRegResponseHeaderTest.java | 2 +-
.../client/UnSubscribeRequestHeaderTest.java | 2 +-
.../client/UnSubscribeResponseHeaderTest.java | 3 +-
.../message/PushMessageRequestHeaderTest.java | 24 +-
.../message/PushMessageResponseHeaderTest.java | 22 +-
.../message/ReplyMessageRequestHeaderTest.java | 26 +-
.../message/ReplyMessageResponseHeaderTest.java | 16 +-
.../common/protocol/tcp/codec/CodecTest.java | 8 +-
.../eventmesh/common/utils/AssertUtilsTest.java | 11 +-
.../common/utils/ConfigurationContextUtilTest.java | 45 +-
.../apache/eventmesh/common/utils/IPUtilsTest.java | 13 +-
.../eventmesh/common/utils/JsonUtilsTest.java | 32 +-
.../eventmesh/common/utils/NetUtilsTest.java | 16 +-
.../common/utils/PropertiesUtilsTest.java | 18 +-
.../common/utils/RandomStringUtilsTest.java | 10 +-
.../eventmesh/common/utils/ReflectUtilsTest.java | 12 +-
.../eventmesh/common/utils/SystemUtilsTest.java | 14 +-
.../utils/{IPUtilsTest.java => TypeUtilsTest.java} | 26 +-
.../build.gradle} | 11 +-
.../eventmesh-connector-file}/gradle.properties | 5 +-
.../connector/file/config/FileServerConfig.java} | 9 +-
.../connector/file/server/FileConnectServer.java} | 26 +-
.../file/sink/config/FileSinkConfig.java} | 12 +-
.../file/sink/config/SinkConnectorConfig.java} | 7 +-
.../file/sink/connector/FileSinkConnector.java | 166 ++
.../file/source/config/FileSourceConfig.java} | 7 +-
.../file}/source/config/SourceConnectorConfig.java | 3 +-
.../file/source/connector/FileSourceConnector.java | 84 +
.../src/main/resources/server-config.yml | 5 +-
.../src/main/resources/sink-config.yml | 17 +-
.../src/main/resources/source-config.yml | 10 +-
.../eventmesh-connector-jdbc/build.gradle | 2 -
.../connector/jdbc/AbstractPartition.java | 1 -
.../eventmesh/connector/jdbc/DataChanges.java | 71 +
.../connector/jdbc/DataTypeConvertor.java | 1 -
.../eventmesh/connector/jdbc/DatabaseDialect.java | 1 -
.../eventmesh/connector/jdbc/JdbcConnectData.java | 16 +
.../eventmesh/connector/jdbc/OffsetContext.java | 1 -
.../apache/eventmesh/connector/jdbc/Payload.java | 20 +-
.../apache/eventmesh/connector/jdbc/Schema.java | 17 +-
.../connector/jdbc/UniversalJdbcContext.java | 2 -
.../connector/jdbc/connection/JdbcConnection.java | 3 -
.../jdbc/connection/mysql/MysqlJdbcConnection.java | 7 +-
.../eventmesh/connector/jdbc/ddl/DdlParser.java | 2 -
.../connector/jdbc/ddl/DdlParserCallback.java | 2 -
.../connector/jdbc/event/AlertDatabaseEvent.java | 3 -
.../connector/jdbc/event/AlertTableEvent.java | 2 -
.../connector/jdbc/event/CreateDatabaseEvent.java | 3 -
.../connector/jdbc/event/CreateTableEvent.java | 3 -
.../connector/jdbc/event/DataChangeEvent.java | 2 -
.../connector/jdbc/event/DeleteDataEvent.java | 3 +-
.../connector/jdbc/event/DropDatabaseEvent.java | 2 -
.../connector/jdbc/event/DropTableEvent.java | 3 -
.../connector/jdbc/event/EventHandler.java | 1 -
.../jdbc/event/GeneralDataChangeEvent.java | 3 +-
.../jdbc/event/GeneralSchemaChangeEvent.java | 2 +-
.../connector/jdbc/event/InsertDataEvent.java | 2 -
.../connector/jdbc/event/SchemaChangeEvent.java | 2 -
.../connector/jdbc/event/UpdateDataEvent.java | 4 +-
.../jdbc/exception/DataTypeConvertException.java | 2 -
.../connector/jdbc/server/JdbcConnectorServer.java | 2 +-
.../jdbc/source/AbstractEventMeshJdbcTask.java | 1 -
.../jdbc/source/AbstractJdbcTaskManager.java | 2 -
.../jdbc/source/EventMeshJdbcEventTask.java | 1 -
.../connector/jdbc/source/EventMeshJdbcTask.java | 1 -
.../connector/jdbc/source/JdbcSourceConnector.java | 23 +-
.../connector/jdbc/source/JdbcTaskManager.java | 1 -
.../jdbc/source/SourceEventMeshJdbcEventTask.java | 8 +-
.../jdbc/source/SourceJdbcTaskManager.java | 4 +-
.../connector/jdbc/source/SourceMateData.java | 1 -
.../jdbc/source/TaskManagerCoordinator.java | 4 -
.../jdbc/source/config/SourceConnectorConfig.java | 4 +-
.../dialect/AbstractGeneralDatabaseDialect.java | 2 -
.../jdbc/source/dialect/DatabaseType.java | 1 +
.../dialect/antlr4/mysql/MysqlAntlr4DdlParser.java | 1 -
.../listener/ColumnDefinitionParserListener.java | 12 +-
.../mysql/listener/CreateTableParserListener.java | 8 +-
.../mysql/listener/DefaultValueParserListener.java | 4 +-
.../mysql/listener/TableBaseParserListener.java | 16 +-
.../listener/TruncateTableParserListener.java | 3 +-
.../jdbc/source/dialect/cdc/AbstractCdcEngine.java | 130 ++
.../dialect/cdc/AbstractCdcEngineFactory.java | 7 +-
.../jdbc/source/dialect/cdc/CdcEngineFactory.java | 1 -
.../source/dialect/cdc/mysql/MysqlCdcEngine.java | 809 ++++++++++
.../MysqlCdcEngineFactory.java} | 39 +-
.../source/dialect/cdc/mysql/RowDeserializers.java | 451 ++++++
.../mysql/{GtidSet.java => EventMeshGtidSet.java} | 36 +-
.../{StopEventData.java => MysqlConstants.java} | 17 +-
.../dialect/mysql/MysqlDataTypeConvertor.java | 1 -
.../source/dialect/mysql/MysqlDatabaseDialect.java | 10 +-
.../jdbc/source/dialect/mysql/MysqlDialectSql.java | 1 -
.../source/dialect/mysql/MysqlJdbcContext.java | 29 +-
.../jdbc/source/dialect/mysql/MysqlSourceInfo.java | 10 +-
.../source/dialect/mysql/MysqlSourceMateData.java | 1 -
.../jdbc/source/dialect/mysql/StopEventData.java | 1 -
.../dialect/snapshot/AbstractSnapshotEngine.java | 36 +-
.../source/dialect/snapshot/SnapshotEngine.java | 1 -
.../dialect/snapshot/SnapshotEngineFactory.java | 1 -
.../jdbc/source/dialect/snapshot/SnapshotType.java | 2 +-
.../snapshot/mysql/MysqlSnapshotEngine.java | 30 +-
.../table/catalog/AbstractColumnEditorImpl.java | 20 +-
.../connector/jdbc/table/catalog/Catalog.java | 2 +-
.../connector/jdbc/table/catalog/ColumnEditor.java | 10 +-
.../connector/jdbc/table/catalog/TableEditor.java | 4 -
.../connector/jdbc/table/catalog/TableId.java | 4 +
.../connector/jdbc/table/catalog/TableSchema.java | 23 +-
.../connector/jdbc/table/catalog/UniqueKey.java | 2 -
.../jdbc/table/catalog/mysql/MysqlColumn.java | 1 -
.../table/catalog/mysql/MysqlColumnEditorImpl.java | 2 +-
.../jdbc/table/catalog/mysql/MysqlTableEditor.java | 1 -
.../jdbc/table/catalog/mysql/MysqlTableSchema.java | 7 +-
.../connector/jdbc/table/type/CalendarType.java | 1 -
.../connector/jdbc/table/type/DecimalType.java | 2 -
.../table/type/EventMeshTypeNameConverter.java | 1 -
.../connector/jdbc/table/type/EvetMeshRowType.java | 4 +-
.../connector/jdbc/table/type/MapType.java | 1 -
.../jdbc/table/type/PrimitiveArrayType.java | 2 -
.../jdbc/table/type/PrimitiveByteArrayType.java | 1 -
.../connector/jdbc/table/type/RowHandleMode.java | 2 +-
.../connector/jdbc/utils/JdbcStringUtils.java | 1 -
.../eventmesh/connector/jdbc/utils/MysqlUtils.java | 1 -
...nector.jdbc.source.dialect.cdc.CdcEngineFactory | 2 +-
.../connector/jdbc/table/catalog/TableIdTest.java | 6 +-
.../connector/jdbc/utils/Antlr4UtilsTest.java | 4 +-
.../connector/jdbc/utils/JdbcStringUtilsTest.java | 8 +-
.../connector/jdbc/utils/MysqlUtilsTest.java | 4 +-
.../connector/kafka/server/KafkaConnectServer.java | 1 -
.../kafka/source/config/SourceConnectorConfig.java | 1 -
.../sink/connector/KnativeSinkConnector.java | 14 +-
.../mongodb/constant/MongodbConstants.java | 1 +
.../sink/client/MongodbReplicaSetSinkClient.java | 2 +-
.../sink/client/MongodbStandaloneSinkClient.java | 2 +-
.../client/MongodbReplicaSetSourceClient.java | 2 +-
.../client/MongodbStandaloneSourceClient.java | 12 +-
.../source/connector/MongodbSourceConnector.java | 1 -
.../mongodb/utils/MongodbCloudEventUtil.java | 13 +-
.../openfunction/client/CallbackService.java | 2 +-
.../client/CloudEventsPublishInstance.java | 5 +-
.../server/OpenFunctionConnectServer.java | 1 -
.../openfunction/service/ConsumerService.java | 3 -
.../openfunction/service/ProducerService.java | 4 +-
.../sink/connector/PravegaSinkConnector.java | 12 +-
.../source/connector/PravegaSourceConnector.java | 50 +-
.../eventmesh-connector-prometheus}/build.gradle | 11 +-
.../gradle.properties | 5 +-
.../prometheus/config/PrometheusServerConfig.java} | 9 +-
.../prometheus/model/QueryPrometheusReq.java} | 13 +-
.../prometheus/model/QueryPrometheusRsp.java | 10 +-
.../connector/prometheus/model/ResponseData.java} | 12 +-
.../server/PrometheusConnectServer.java} | 26 +-
.../source/config/PrometheusSourceConfig.java} | 7 +-
.../source/config/SourceConnectorConfig.java | 19 +-
.../connector/PrometheusSourceConnector.java | 192 +++
.../src/main/resources/server-config.yml | 0
.../src/main/resources/source-config.yml | 27 +-
.../pulsar/config/PulsarServerConfig.java | 2 +-
.../pulsar/server/PulsarConnectServer.java | 2 -
.../pulsar/sink/config/PulsarSinkConfig.java | 2 -
.../pulsar/sink/connector/PulsarSinkConnector.java | 8 +-
.../pulsar/source/config/PulsarSourceConfig.java | 1 -
.../source/config/SourceConnectorConfig.java | 1 +
.../source/connector/PulsarSourceConnector.java | 4 -
.../connector/rabbitmq/client/RabbitmqClient.java | 2 -
.../rabbitmq/server/RabbitMQConnectorServer.java | 1 -
.../sink/connector/RabbitMQSinkConnector.java | 14 +-
.../source/connector/RabbitMQSourceConnector.java | 19 +-
.../eventmesh-connector-rocketmq/build.gradle | 1 -
.../rocketmq/server/RocketMQConnectServer.java | 2 -
.../sink/connector/RocketMQSinkConnector.java | 1 -
.../source/config/SourceConnectorConfig.java | 1 -
.../src/main/resources/source-config.yml | 2 +-
.../connector/s3/source/config/S3SourceConfig.java | 3 +-
.../s3/source/config/SourceConnectorConfig.java | 3 +-
.../s3/source/connector/S3SourceConnector.java | 2 -
.../connector/s3/source/S3SourceConnectorTest.java | 23 +-
.../eventmesh-connector-spring}/build.gradle | 23 +-
.../eventmesh-connector-spring}/gradle.properties | 5 +-
.../common/SpringApplicationContextHolder.java | 33 +-
.../spring/config/EventMeshAutoConfiguration.java | 72 +
.../spring/config/SpringConnectServerConfig.java} | 8 +-
.../spring/server/SpringConnectServer.java | 50 +
.../spring/sink/EventMeshConsumerMetadata.java} | 15 +-
.../connector/spring/sink/EventMeshListener.java | 27 +-
.../sink/EventMeshListenerBeanPostProcessor.java | 143 ++
.../spring/sink/config/SpringSinkConfig.java} | 12 +-
.../sink/connector/SinkConnectorConfig.java} | 8 +-
.../sink/connector/SpringSinkConnector.java} | 85 +-
.../SpringSinkConnectorCreateServiceImpl.java} | 27 +-
.../spring/source/MessageSendingOperations.java | 9 +-
.../spring/source/config/SpringSourceConfig.java} | 10 +-
.../source/connector}/SourceConnectorConfig.java | 6 +-
.../source/connector/SpringSourceConnector.java} | 74 +-
.../SpringSourceConnectorCreateServiceImpl.java} | 27 +-
...ventmesh.openconnect.api.ConnectorCreateService | 7 +-
.../src/main/resources/META-INF/spring.factories | 4 +-
.../src/main/resources/server-config.yml | 0
.../src/main/resources/sink-config.yml | 16 +-
.../src/main/resources/source-config.yml | 16 +-
.../apache/eventmesh/grpc/GrpcAbstractDemo.java | 5 +-
.../cloudevents/CloudEventsPublishInstance.java | 1 -
.../cloudevents/CloudEventsRequestInstance.java | 1 -
.../eventmeshmessage/AsyncPublishBroadcast.java | 1 -
.../pub/eventmeshmessage/AsyncPublishInstance.java | 1 -
.../pub/eventmeshmessage/BatchPublishInstance.java | 1 -
.../pub/eventmeshmessage/RequestReplyInstance.java | 1 -
.../WorkflowAsyncPublishInstance.java | 1 -
.../eventmesh/http/demo/HttpAbstractDemo.java | 6 +-
.../demo/pub/cloudevents/AsyncPublishInstance.java | 1 -
.../pub/eventmeshmessage/AsyncPublishInstance.java | 1 -
.../eventmeshmessage/AsyncSyncRequestInstance.java | 3 +-
.../pub/eventmeshmessage/SyncRequestInstance.java | 1 -
.../http/demo/sub/controller/SubController.java | 8 +-
.../http/demo/sub/service/SubService.java | 3 +-
.../eventmesh/tcp/common/EventMeshTestUtils.java | 56 +-
.../eventmesh/tcp/common/UtilsConstants.java | 2 -
.../demo/pub/eventmeshmessage/AsyncPublish.java | 1 -
.../eventmeshmessage/AsyncPublishBroadcast.java | 1 -
.../main/java/org/apache/eventmesh/util/Utils.java | 5 +-
.../org/apache/eventmesh/api/meta/MetaService.java | 2 +-
.../api/meta/bo/EventMeshAppSubTopicInfo.java | 2 -
.../api/meta/bo/EventMeshServicePubTopicInfo.java | 4 +-
eventmesh-meta/eventmesh-meta-consul/build.gradle | 1 +
.../meta/consul/service/HeatBeatScheduler.java | 3 +-
.../consul/service}/ConsulMetaServiceTest.java | 82 +-
eventmesh-meta/eventmesh-meta-etcd/build.gradle | 1 +
.../eventmesh/meta/etcd/constant/EtcdConstant.java | 1 -
.../meta/etcd/factory/EtcdClientFactory.java | 3 -
.../meta/etcd/factory/EtcdClientWrapper.java | 2 -
.../eventmesh/meta/etcd/factory/EtcdLeaseId.java | 1 -
.../meta/etcd/factory/EtcdStreamObserver.java | 1 -
.../meta/etcd/service/EtcdCustomService.java | 4 +-
.../meta/etcd/service/EtcdMetaService.java | 5 +-
.../registry/etcd/service/EtcdMetaServiceTest.java | 96 +-
eventmesh-meta/eventmesh-meta-nacos/build.gradle | 1 +
.../meta/nacos/service/NacosMetaService.java | 3 +-
.../nacos/service/NacosMetaServiceTest.java | 54 +-
.../eventmesh-meta-zookeeper/build.gradle | 1 +
.../meta/zookeeper/constant/ZookeeperConstant.java | 1 -
.../meta/zookeeper/pojo/EventMeshInstance.java | 2 -
.../zookeeper/service/ZookeeperMetaService.java | 2 -
.../service/ZookeeperMetaServiceTest.java | 52 +-
.../eventmesh-metrics-api/build.gradle | 1 -
.../metrics/api/model/HttpSummaryMetrics.java | 10 +-
.../metrics/api/MetricsPluginFactoryTest.java | 8 +-
.../metrics/api/model/GrpcSummaryMetricsTest.java | 14 +-
.../prometheus/PrometheusMetricsRegistry.java | 2 +-
.../prometheus/metrics/PrometheusGrpcExporter.java | 8 +-
.../prometheus/metrics/PrometheusHttpExporter.java | 138 +-
.../prometheus/metrics/PrometheusTcpExporter.java | 36 +-
.../prometheus/utils/PrometheusExporterUtils.java | 6 +-
.../config/PrometheusConfigurationTest.java | 6 +-
.../apache/eventmesh/openconnect/Application.java | 33 +-
.../apache/eventmesh/openconnect/SourceWorker.java | 66 +-
.../openconnect/api/ConnectorCreateService.java | 20 +-
.../eventmesh/openconnect/util/CloudEventUtil.java | 4 +-
.../build.gradle | 1 -
.../offsetmgmt/api/data/ConnectRecord.java | 1 -
.../api/data/RecordOffsetManagement.java | 36 +-
.../api/storage/ConnectorRecordPartition.java | 1 +
...ava => DefaultOffsetManagementServiceImpl.java} | 49 +-
.../offsetmgmt/api/storage/KeyValueStore.java | 2 -
.../api/storage/MemoryBasedKeyValueStore.java | 1 -
.../api/storage/OffsetManagementService.java | 1 -
.../api/storage/OffsetStorageReaderImpl.java | 1 -
.../api/storage/OffsetStorageWriterImpl.java | 3 +-
.../offsetmgmt/nacos/NacosConfigService.java | 1 +
.../build.gradle | 0
.../protocol/api/ProtocolPluginFactory.java | 6 +-
.../cloudevents/CloudEventsProtocolAdaptor.java | 1 +
.../cloudevents/CloudEventsProtocolConstant.java | 1 +
.../resolver/tcp/TcpMessageProtocolResolver.java | 2 +-
.../eventmesh-protocol-grpc/build.gradle | 7 +-
.../protocol/http/HttpProtocolAdaptor.java | 1 -
.../protocol/http/HttpProtocolConstant.java | 1 +
.../http/resolver/HttpRequestProtocolResolver.java | 3 +-
.../protocol/http/HttpProtocolAdaptorTest.java | 10 +-
.../meshmessage/MeshMessageProtocolAdaptor.java | 14 +-
.../meshmessage/MeshMessageProtocolConstant.java | 9 +-
.../GrpcEventMeshCloudEventProtocolResolver.java | 1 -
.../http/SendMessageBatchV2ProtocolResolver.java | 2 +-
.../MeshMessageProtocolAdaptorTest.java | 11 +-
.../OpenMessageProtocolAdaptorTest.java | 13 +-
.../protocol/webhook/WebHookProtocolAdaptor.java | 1 -
eventmesh-runtime/build.gradle | 10 +-
eventmesh-runtime/conf/eventmesh.properties | 26 +-
.../java/org/apache/eventmesh/runtime/acl/Acl.java | 1 +
.../admin/controller/ClientManageController.java | 21 +-
.../admin/handler/ConfigurationHandler.java | 9 +-
.../admin/handler/DeleteWebHookConfigHandler.java | 1 -
.../runtime/admin/handler/EventHandler.java | 7 +-
.../runtime/admin/handler/GrpcClientHandler.java | 7 +-
.../runtime/admin/handler/HTTPClientHandler.java | 4 +-
.../admin/handler/InsertWebHookConfigHandler.java | 1 -
.../runtime/admin/handler/MetaHandler.java | 8 +-
.../runtime/admin/handler/MetricsHandler.java | 4 +-
.../handler/QueryRecommendEventMeshHandler.java | 1 -
.../QueryWebHookConfigByManufacturerHandler.java | 1 -
.../handler/RedirectClientByIpPortHandler.java | 13 +-
.../admin/handler/RedirectClientByPathHandler.java | 9 +-
.../handler/RedirectClientBySubSystemHandler.java | 14 +-
.../admin/handler/RejectAllClientHandler.java | 3 +-
.../admin/handler/RejectClientByIpPortHandler.java | 1 -
.../handler/RejectClientBySubSystemHandler.java | 4 +-
.../admin/handler/ShowClientBySystemHandler.java | 6 +-
.../runtime/admin/handler/ShowClientHandler.java | 1 -
.../handler/ShowListenClientByTopicHandler.java | 3 +-
.../runtime/admin/handler/TCPClientHandler.java | 14 +-
.../runtime/admin/handler/TopicHandler.java | 4 +-
.../admin/handler/UpdateWebHookConfigHandler.java | 1 -
.../runtime/admin/response/GetMetricsResponse.java | 1 -
.../admin/response/GetRegistryResponse.java | 1 -
.../eventmesh/runtime/boot/AbstractHTTPServer.java | 106 +-
.../runtime/boot/AbstractRemotingServer.java | 2 +-
.../eventmesh/runtime/boot/AbstractTCPServer.java | 95 +-
.../runtime/boot/EventMeshGrpcBootstrap.java | 4 +-
.../runtime/boot/EventMeshGrpcServer.java | 9 +-
.../runtime/boot/EventMeshHTTPServer.java | 35 +-
.../runtime/boot/EventMeshHttpBootstrap.java | 6 +-
.../eventmesh/runtime/boot/EventMeshServer.java | 21 +-
.../eventmesh/runtime/boot/EventMeshStartup.java | 1 -
.../eventmesh/runtime/boot/EventMeshTCPServer.java | 25 +-
.../runtime/boot/EventMeshTcpBootstrap.java | 4 +-
.../runtime/boot/HTTPThreadPoolGroup.java | 74 +-
.../eventmesh/runtime/boot/TCPThreadPoolGroup.java | 19 +-
.../eventmesh/runtime/boot/ThreadPoolGroup.java | 1 +
.../org/apache/eventmesh/runtime/common/Pair.java | 1 -
.../configuration/EventMeshTCPConfiguration.java | 2 +-
.../runtime/constants/EventMeshConstants.java | 7 +-
.../runtime/core/consumer/SubscriptionManager.java | 19 +-
.../core/consumergroup/ConsumerGroupConf.java | 6 +-
.../core/consumergroup/ConsumerGroupMetadata.java | 1 -
.../consumergroup/ConsumerGroupTopicMetadata.java | 2 -
.../event/ConsumerGroupStateEvent.java | 1 -
.../runtime/core/plugin/MQAdminWrapper.java | 1 -
.../runtime/core/plugin/MQConsumerWrapper.java | 1 -
.../runtime/core/plugin/MQProducerWrapper.java | 1 -
.../runtime/core/protocol/AbstractRetryer.java | 87 ++
.../protocol/grpc/consumer/ConsumerManager.java | 14 +-
.../protocol/grpc/consumer/EventMeshConsumer.java | 6 +-
.../consumergroup/ConsumerGroupClient.java | 1 -
.../consumer/consumergroup/StreamTopicConfig.java | 17 +-
.../consumer/consumergroup/WebhookTopicConfig.java | 2 -
.../processor/BatchPublishCloudEventProcessor.java | 3 +-
.../processor/PublishCloudEventsProcessor.java | 1 +
.../grpc/processor/ReplyMessageProcessor.java | 2 +-
.../grpc/processor/RequestCloudEventProcessor.java | 3 +-
.../grpc/processor/SubscribeProcessor.java | 3 +-
.../protocol/grpc/producer/EventMeshProducer.java | 2 +-
.../protocol/grpc/producer/ProducerManager.java | 1 -
.../protocol/grpc/producer/SendMessageContext.java | 2 +-
.../protocol/grpc/push/AbstractPushRequest.java | 2 +-
.../core/protocol/grpc/push/HandleMsgContext.java | 1 -
.../core/protocol/grpc/push/MessageHandler.java | 1 -
.../core/protocol/grpc/push/StreamPushRequest.java | 4 +-
.../protocol/grpc/push/WebhookPushRequest.java | 37 +-
.../core/protocol/grpc/retry/GrpcRetryer.java | 57 +-
.../protocol/grpc/service/ConsumerService.java | 1 +
.../protocol/grpc/service/HeartbeatService.java | 2 -
.../protocol/grpc/service/PublisherService.java | 1 -
.../core/protocol/grpc/service/ServiceUtils.java | 1 -
.../protocol/http/consumer/ConsumerManager.java | 6 +-
.../protocol/http/consumer/EventMeshConsumer.java | 13 +-
.../http/consumer/HttpClientGroupMapping.java | 51 +-
.../http/processor/AdminShutdownProcessor.java | 3 +-
.../http/processor/BatchSendMessageProcessor.java | 8 +-
.../processor/BatchSendMessageV2Processor.java | 56 +-
.../http/processor/CreateTopicProcessor.java | 10 +-
.../http/processor/DeleteTopicProcessor.java | 12 +-
.../protocol/http/processor/HandlerService.java | 11 +-
.../http/processor/HeartBeatProcessor.java | 31 +-
.../processor/LocalSubscribeEventProcessor.java | 13 +-
.../processor/LocalUnSubscribeEventProcessor.java | 20 +-
.../http/processor/QuerySubscriptionProcessor.java | 3 +-
.../processor/RemoteSubscribeEventProcessor.java | 68 +-
.../processor/RemoteUnSubscribeEventProcessor.java | 17 +-
.../http/processor/ReplyMessageProcessor.java | 58 +-
.../http/processor/SendAsyncEventProcessor.java | 10 +-
.../http/processor/SendAsyncMessageProcessor.java | 49 +-
.../processor/SendAsyncRemoteEventProcessor.java | 9 +-
.../http/processor/SendSyncMessageProcessor.java | 49 +-
.../http/processor/ShortHttpProcessor.java | 3 +-
.../http/processor/SubscribeProcessor.java | 54 +-
.../http/processor/UnSubscribeProcessor.java | 47 +-
.../http/processor/inf/AbstractEventProcessor.java | 12 +-
.../core/protocol/http/processor/inf/Client.java | 2 -
.../http/processor/inf/HttpRequestProcessor.java | 10 +-
.../protocol/http/producer/EventMeshProducer.java | 6 +-
.../protocol/http/producer/ProducerManager.java | 6 +-
.../http/producer/ProducerTopicManager.java | 1 -
.../protocol/http/producer/SendMessageContext.java | 3 +-
.../http/push/AbstractHTTPPushRequest.java | 5 +-
.../protocol/http/push/AsyncHTTPPushRequest.java | 7 +-
.../core/protocol/http/push/HTTPClientPool.java | 6 +-
.../protocol/http/push/HTTPMessageHandler.java | 19 +-
.../core/protocol/http/retry/HttpRetryer.java | 66 +-
.../protocol/tcp/client/EventMeshTcp2Client.java | 10 +-
.../tcp/client/group/ClientGroupWrapper.java | 37 +-
.../client/group/ClientSessionGroupMapping.java | 25 +-
.../group/dispatch/DownstreamDispatchStrategy.java | 1 -
.../tcp/client/processor/GoodbyeProcessor.java | 3 +-
.../tcp/client/processor/HeartBeatProcessor.java | 3 +-
.../tcp/client/processor/HelloProcessor.java | 20 +-
.../tcp/client/processor/ListenProcessor.java | 4 +-
.../tcp/client/processor/MessageAckProcessor.java | 2 +-
.../client/processor/MessageTransferProcessor.java | 20 +-
.../tcp/client/processor/RecommendProcessor.java | 3 +-
.../tcp/client/processor/SubscribeProcessor.java | 1 -
.../tcp/client/processor/TcpProcessor.java | 1 +
.../tcp/client/processor/UnSubscribeProcessor.java | 2 +-
.../client/rebalance/EventMeshRebalanceImpl.java | 15 +-
.../rebalance/EventMeshRebalanceService.java | 1 -
.../client/recommend/EventMeshRecommendImpl.java | 8 +-
.../core/protocol/tcp/client/session/Session.java | 42 +-
.../tcp/client/session/SessionContext.java | 2 +-
.../tcp/client/session/push/ClientAckContext.java | 9 +-
.../client/session/push/DownStreamMsgContext.java | 7 +-
.../tcp/client/session/push/PushContext.java | 2 -
.../tcp/client/session/push/SessionPusher.java | 10 +-
.../client/session/retry/EventMeshTcpRetryer.java | 56 +-
.../tcp/client/session/send/SessionSender.java | 6 +-
.../client/session/send/UpStreamMsgContext.java | 5 +-
.../apache/eventmesh/runtime/meta/MetaStorage.java | 1 -
.../runtime/metrics/MonitorMetricConstants.java | 1 -
.../runtime/metrics/grpc/EventMeshGrpcMonitor.java | 3 +-
.../runtime/metrics/http/HTTPMetricsServer.java | 16 +-
.../runtime/metrics/tcp/EventMeshTcpMonitor.java | 5 +-
.../eventmesh/runtime/trace/LogExporter.java | 1 -
.../apache/eventmesh/runtime/trace/SpanKey.java | 1 -
.../org/apache/eventmesh/runtime/trace/Trace.java | 3 +-
.../apache/eventmesh/runtime/util/BannerUtil.java | 12 +-
.../runtime/util/EventMeshCloudEventWriter.java | 1 -
.../eventmesh/runtime/util/EventMeshUtil.java | 16 +-
.../eventmesh/runtime/util/HttpTinyClient.java | 4 +-
.../eventmesh/runtime/util/RemotingHelper.java | 2 -
.../apache/eventmesh/runtime/util/TraceUtils.java | 1 -
.../org/apache/eventmesh/runtime/util/Utils.java | 8 +-
.../controller/ClientManageControllerTest.java | 17 +-
.../QueryRecommendEventMeshHandlerTest.java | 12 +-
.../handler/RedirectClientByIpPortHandlerTest.java | 20 +-
.../handler/RedirectClientByPathHandlerTest.java | 14 +-
.../runtime/boot/EventMeshServerTest.java | 86 +-
.../runtime/client/common/ClientGlobal.java | 1 -
.../eventmesh/runtime/client/common/Codec.java | 5 +-
.../runtime/client/common/MessageUtils.java | 1 -
.../runtime/client/common/RequestContext.java | 1 -
.../eventmesh/runtime/client/common/TCPClient.java | 3 +-
.../runtime/client/common/UserAgentUtils.java | 8 +-
.../runtime/client/impl/EventMeshClientImpl.java | 38 +-
.../runtime/client/impl/PubClientImpl.java | 21 +-
.../runtime/client/impl/SubClientImpl.java | 85 +-
.../EventMeshGrpcConfigurationTest.java | 82 +-
.../EventMeshHTTPConfigurationTest.java | 90 +-
.../EventMeshTCPConfigurationTest.java | 86 +-
.../eventmesh/runtime/demo/AsyncSubClient.java | 2 +-
.../eventmesh/runtime/demo/BroadCastSubClient.java | 2 +-
.../apache/eventmesh/runtime/demo/CCSubClient.java | 21 +-
.../apache/eventmesh/runtime/demo/CClientDemo.java | 19 +-
.../eventmesh/runtime/demo/SyncPubClient.java | 4 +-
.../eventmesh/runtime/demo/SyncSubClient.java | 2 -
.../protocol/processor/WebHookProcessorTest.java | 52 +-
.../eventmesh/runtime/util/BannerUtilTest.java | 10 +-
.../eventmesh/runtime/util/EventMeshUtilTest.java | 62 +-
.../runtime/util/HttpResponseUtilsTest.java | 16 +-
.../eventmesh/runtime/util/HttpTinyClientTest.java | 16 +-
.../eventmesh/runtime/util/RemotingHelperTest.java | 16 +-
.../eventmesh/runtime/util/ServerGlobalTest.java | 10 +-
.../runtime/util/ThreadPoolHelperTest.java | 10 +-
.../runtime/util/ValueComparatorTest.java | 10 +-
.../eventmesh/runtime/util/WebhookUtilTest.java | 23 +-
eventmesh-sdks/eventmesh-sdk-java/build.gradle | 4 +-
.../grpc/consumer/EventMeshGrpcConsumer.java | 2 +-
.../client/grpc/consumer/SubStreamHandler.java | 1 +
.../grpc/producer/EventMeshGrpcProducer.java | 4 +-
.../client/grpc/producer/GrpcProducer.java | 2 -
.../grpc/util/EventMeshCloudEventBuilder.java | 62 +-
.../client/http/AbstractProducerHttpClient.java | 3 +-
.../eventmesh/client/http/EventMeshRetObj.java | 1 -
.../eventmesh/client/http/ProtocolConstant.java | 1 -
.../http/consumer/EventMeshHttpConsumer.java | 8 +-
.../client/http/producer/CloudEventProducer.java | 2 +-
.../http/producer/EventMeshMessageProducer.java | 2 +-
.../client/http/producer/OpenMessageProducer.java | 2 +-
.../client/http/ssl/MyX509TrustManager.java | 3 +-
.../client/http/util/HttpLoadBalanceUtils.java | 3 +-
.../eventmesh/client/http/util/HttpUtils.java | 12 +-
.../client/tcp/common/EventMeshCommon.java | 2 -
.../eventmesh/client/tcp/common/MessageUtils.java | 5 +-
.../client/tcp/common/RequestContext.java | 1 -
.../eventmesh/client/tcp/common/TcpClient.java | 4 +-
.../tcp/impl/AbstractEventMeshTCPPubHandler.java | 2 +-
.../impl/cloudevent/CloudEventTCPSubClient.java | 3 +-
.../EventMeshMessageTCPPubClient.java | 6 +-
.../EventMeshMessageTCPSubClient.java | 4 +-
.../grpc/consumer/EventMeshGrpcConsumerTest.java | 25 +-
.../grpc/producer/CloudEventProducerTest.java | 19 +-
.../grpc/producer/EventMeshGrpcProducerTest.java | 26 +-
.../producer/EventMeshMessageProducerTest.java | 19 +-
.../grpc/util/EventMeshCloudEventBuilderTest.java | 76 +-
.../client/http/demo/AsyncPublishInstance.java | 1 -
.../client/http/demo/AsyncSyncRequestInstance.java | 7 +-
.../client/http/demo/SyncRequestInstance.java | 1 -
.../client/http/util/HttpLoadBalanceUtilsTest.java | 10 +-
.../eventmesh/client/http/util/HttpUtilsTest.java | 58 +-
.../tcp/common/EventMeshTestCaseTopicSet.java | 6 +-
.../client/tcp/common/EventMeshTestUtils.java | 1 -
.../client/tcp/common/MessageUtilsTest.java | 103 +-
.../tcp/impl/EventMeshTCPClientFactoryTest.java | 10 +-
eventmesh-sdks/eventmesh-sdk-rust/.gitignore | 6 +-
eventmesh-sdks/eventmesh-sdk-rust/Cargo.lock | 1606 --------------------
eventmesh-sdks/eventmesh-sdk-rust/Cargo.toml | 67 +-
eventmesh-sdks/eventmesh-sdk-rust/README.md | 150 ++
.../eventmesh-sdk-rust/build.rs | 27 +-
.../eventmesh-sdk-rust/eventmesh/Cargo.toml | 38 -
.../eventmesh-sdk-rust/eventmesh/build.rs | 21 -
.../eventmesh/proto/eventmesh-client.proto | 150 --
.../eventmesh-sdk-rust/eventmesh/src/constants.rs | 24 -
.../eventmesh/src/grpc/config.rs | 54 -
.../eventmesh/src/grpc/consumer.rs | 263 ----
.../eventmesh-sdk-rust/eventmesh/src/grpc/mod.rs | 27 -
.../eventmesh/src/grpc/producer.rs | 127 --
.../eventmesh/src/http/config.rs | 29 -
.../eventmesh-sdk-rust/eventmesh/src/http/mod.rs | 38 -
.../eventmesh/src/http/producer.rs | 117 --
.../eventmesh/src/http/protocol_key.rs | 34 -
.../eventmesh/src/http/request_code.rs | 76 -
.../eventmesh-sdk-rust/eventmesh/src/lib.rs | 22 -
.../eventmesh-sdk-rust/eventmesh/src/message.rs | 55 -
.../eventmesh-sdk-rust/examples/Cargo.lock | 1044 -------------
.../eventmesh-sdk-rust/examples/Cargo.toml | 63 -
.../examples/grpc-consumer-stream.rs | 93 --
.../eventmesh-sdk-rust/examples/grpc-consumer.rs | 81 -
.../examples/grpc-producer-batch-publish.rs | 57 -
.../examples/grpc-producer-publish.rs | 57 -
.../examples/grpc-producer-request.rs | 57 -
.../examples/grpc/consumer_example.rs | 58 +
.../examples/grpc/producer_example.rs | 61 +
.../examples/http-producer-publish.rs | 56 -
.../examples/http-producer-request.rs | 56 -
.../proto/eventmesh-cloudevents.proto | 0
.../proto/eventmesh-service.proto | 0
eventmesh-sdks/eventmesh-sdk-rust/src/common.rs | 55 +
.../eventmesh-sdk-rust/src/common/constants.rs | 49 +-
.../src/common/eventmesh_message_utils.rs | 501 ++++++
.../eventmesh-sdk-rust/src/common/local_ip.rs | 23 +-
.../eventmesh-sdk-rust/src/common/protocol_key.rs | 60 +
.../src/common/random_string_util.rs | 53 +
.../eventmesh-sdk-rust/src/config.rs | 11 +-
.../eventmesh-sdk-rust/src/config/grpc_config.rs | 127 ++
eventmesh-sdks/eventmesh-sdk-rust/src/error.rs | 58 +
.../eventmesh-sdk-rust/src/grpc.rs | 35 +-
.../src/grpc/eventmesh_message.rs | 3 +
.../eventmesh_message_producer.rs | 158 ++
.../eventmesh-sdk-rust/src/grpc/grpc_consumer.rs | 252 +++
.../eventmesh-sdk-rust/src/grpc/grpc_producer.rs | 37 +-
.../eventmesh-sdk-rust/src/grpc/pb.rs | 3 +
eventmesh-sdks/eventmesh-sdk-rust/src/lib.rs | 311 ++++
.../eventmesh-sdk-rust/src/log.rs | 15 +-
eventmesh-sdks/eventmesh-sdk-rust/src/model.rs | 57 +
.../eventmesh-sdk-rust/src/model/convert.rs | 38 +-
.../eventmesh-sdk-rust/src/model/message.rs | 192 +++
.../eventmesh-sdk-rust/src/model/response.rs | 63 +
.../eventmesh-sdk-rust/src/model/subscription.rs | 275 ++++
.../eventmesh-sdk-rust/src/net.rs | 9 +-
.../eventmesh-sdk-rust/src/net/grpc.rs | 1 +
.../eventmesh-sdk-rust/src/net/grpc/grpc_client.rs | 212 +++
.../tests/eventmesh_message_utils_test.rs | 62 +
.../apache/eventmesh/acl/impl/AclServiceImpl.java | 15 +-
.../eventmesh/acl/impl/AclServiceImplTest.java | 52 +-
.../org/apache/eventmesh/api/acl/AclService.java | 1 -
.../apache/eventmesh/api/acl/AclServiceTest.java | 51 +-
.../apache/eventmesh/api/auth/AuthServiceTest.java | 34 +-
.../eventmesh/api/exception/AclExceptionTest.java | 22 +-
.../auth/http/basic/config/AuthConfigsTest.java | 8 +-
.../http/basic/impl/AuthHttpBasicServiceTest.java | 37 +-
.../auth/token/impl/auth/AuthTokenUtils.java | 21 +-
.../eventmesh/spi/EventMeshExtensionFactory.java | 2 -
.../eventmesh/spi/EventMeshExtensionType.java | 3 +-
.../org/apache/eventmesh/spi/EventMeshSPI.java | 1 -
.../spi/loader/JarExtensionClassLoader.java | 5 +-
.../spi/loader/MetaInfExtensionClassLoader.java | 1 -
.../spi/EventMeshExtensionFactoryTest.java | 33 +-
.../spi/example/AnotherSingletonExtension.java | 1 -
.../eventmesh/spi/example/PrototypeExtension.java | 1 -
.../eventmesh/spi/example/SingletonExtension.java | 1 -
.../apache/eventmesh/api/AsyncConsumeContext.java | 1 -
.../org/apache/eventmesh/api/EventListener.java | 1 -
.../eventmesh/api/admin/TopicProperties.java | 3 +-
.../eventmesh-storage-kafka/build.gradle | 5 +-
.../storage/kafka/consumer/ConsumerImpl.java | 4 -
.../kafka/consumer/KafkaConsumerRunner.java | 1 +
.../kafka/config/ClientConfigurationTest.java | 36 +-
.../eventmesh-storage-pulsar/build.gradle | 2 -
.../storage/pulsar/client/PulsarClientWrapper.java | 12 +-
.../storage/pulsar/config/ClientConfiguration.java | 6 +-
.../pulsar/consumer/PulsarConsumerImpl.java | 15 +-
.../storage/pulsar/producer/AbstractProducer.java | 1 -
.../pulsar/config/ClientConfigurationTest.java | 10 +-
.../eventmesh-storage-rabbitmq/build.gradle | 2 -
.../storage/rabbitmq/client/RabbitmqClient.java | 2 -
.../rabbitmq/consumer/RabbitmqConsumer.java | 2 -
.../rabbitmq/consumer/RabbitmqConsumerHandler.java | 2 +-
.../rabbitmq/producer/RabbitmqProducer.java | 3 +-
.../eventmesh/storage/rabbitmq/RabbitmqServer.java | 8 +-
.../cloudevent/RabbitmqCloudEventTest.java | 18 +-
.../rabbitmq/config/ConfigurationHolderTest.java | 26 +-
.../rabbitmq/consumer/RabbitmqConsumerTest.java | 21 +-
.../rabbitmq/producer/RabbitmqProducerTest.java | 21 +-
.../storage/redis/consumer/RedisConsumer.java | 1 +
.../storage/redis/producer/RedisProducer.java | 6 +-
.../storage/redis/AbstractRedisServer.java | 8 +-
.../storage/redis/client/RedissonClientTest.java | 8 +-
.../storage/redis/config/RedisPropertiesTest.java | 12 +-
.../storage/redis/connector/UnitTest.java | 21 +-
.../storage/redis/consumer/RedisConsumerTest.java | 21 +-
.../storage/redis/producer/RedisProducerTest.java | 20 +-
.../eventmesh-storage-rocketmq/build.gradle | 4 +-
.../storage/rocketmq/admin/RocketMQAdmin.java | 4 +-
.../cloudevent/RocketMQMessageFactory.java | 6 +-
.../rocketmq/cloudevent/impl/RocketMQHeaders.java | 2 -
.../cloudevent/impl/RocketMQMessageWriter.java | 2 -
.../storage/rocketmq/config/ClientConfig.java | 3 +-
.../rocketmq/consumer/PushConsumerImpl.java | 13 +-
.../EventMeshMessageListenerConcurrently.java | 2 +-
.../rocketmq/producer/AbstractProducer.java | 24 +-
.../storage/rocketmq/producer/ProducerImpl.java | 7 +-
.../rocketmq/producer/RocketMQProducerImpl.java | 5 +-
.../storage/rocketmq/utils/BeanUtils.java | 3 +-
.../storage/rocketmq/utils/CloudEventUtils.java | 7 +-
.../ConsumeMessageConcurrentlyService.java | 9 +-
.../cloudevent/RocketMQMessageFactoryTest.java | 11 +-
.../rocketmq/config/ClientConfigurationTest.java | 36 +-
.../rocketmq/consumer/PushConsumerImplTest.java | 27 +-
.../rocketmq/producer/DefaultProducerImplTest.java | 54 +-
.../rocketmq/producer/ProducerImplTest.java | 26 +-
.../rocketmq/promise/DefaultPromiseTest.java | 122 --
.../storage/rocketmq/utils/BeanUtilsTest.java | 34 +-
.../eventmesh-storage-standalone/build.gradle | 2 +-
.../storage/standalone/admin/StandaloneAdmin.java | 3 +-
.../storage/standalone/broker/MessageQueue.java | 1 -
.../broker/task/HistoryMessageClear.java | 2 -
.../storage/standalone/broker/task/Subscribe.java | 1 +
.../standalone/consumer/StandaloneConsumer.java | 6 +-
.../eventmesh/storage/standalone/TestUtils.java | 6 +-
.../standalone/admin/StandaloneAdminTest.java | 33 +-
.../standalone/broker/MessageQueueTest.java | 44 +-
.../standalone/broker/StandaloneBrokerTest.java | 20 +-
.../broker/task/HistoryMessageClearTest.java | 10 +-
.../standalone/broker/task/SubscribeTest.java | 12 +-
.../consumer/StandaloneConsumerTest.java | 22 +-
.../producer/StandaloneProducerTest.java | 18 +-
.../eventmesh/trace/api/AbstractTraceService.java | 1 +
.../eventmesh/trace/api/EventMeshTraceService.java | 4 +-
.../trace/api/common/EventMeshTraceConstants.java | 1 -
.../api/config/ExporterConfigurationTest.java | 12 +-
.../eventmesh-trace-jaeger/build.gradle | 1 -
.../eventmesh/trace/jaeger/JaegerTraceService.java | 3 +-
.../trace/jaeger/JaegerTraceServiceTest.java | 11 +-
.../jaeger/config/JaegerConfigurationTest.java | 4 +-
.../eventmesh-trace-pinpoint/build.gradle | 1 -
.../trace/pinpoint/PinpointTraceService.java | 10 +-
.../pinpoint/exporter/PinpointSpanExporter.java | 21 +-
.../trace/pinpoint/PinpointTraceServiceTest.java | 11 +-
.../pinpoint/config/PinpointConfigurationTest.java | 33 +-
.../exporter/PinpointSpanExporterTest.java | 22 +-
.../eventmesh-trace-zipkin/build.gradle | 1 -
.../eventmesh/trace/zipkin/ZipkinTraceService.java | 9 +-
.../trace/zipkin/TracePluginFactoryTest.java | 19 +-
.../trace/zipkin/ZipkinTraceServiceTest.java | 12 +-
.../zipkin/config/ZipkinConfigurationTest.java | 16 +-
.../admin/AdminWebHookConfigOperationManager.java | 4 +-
.../webhook/admin/NacosWebHookConfigOperation.java | 7 +-
.../webhook/config/AdminConfiguration.java | 1 -
.../AdminWebHookConfigOperationManagerTest.java | 6 +-
.../admin/FileWebHookConfigOperationTest.java | 15 +-
.../webhook/config/AdminConfigurationTest.java | 12 +-
.../apache/eventmesh/webhook/api/Manufacturer.java | 1 -
.../webhook/receive/ManufacturerProtocol.java | 1 -
.../webhook/receive/WebHookController.java | 1 +
.../webhook/receive/protocol/GithubProtocol.java | 1 -
.../receive/config/ReceiveConfigurationTest.java | 14 +-
gradle.properties | 2 +-
gradle/wrapper/gradle-wrapper.jar | Bin 59536 -> 63375 bytes
gradle/wrapper/gradle-wrapper.properties | 4 +-
gradlew | 235 +--
gradlew.bat | 17 +-
settings.gradle | 7 +-
style/checkstyle-header1.txt | 1 +
style/task/eventmesh-spotless-formatter.xml | 59 +
tools/dependency-check/known-dependencies.txt | 8 +-
835 files changed, 11063 insertions(+), 10314 deletions(-)
create mode 100644 eventmesh-admin/.gitignore
copy eventmesh-admin/{eventmesh-admin-rocketmq/gradle.properties =>
docker/Dockerfile} (80%)
create mode 100644 eventmesh-admin/docs/UserGuide_CN.md
create mode 100644 eventmesh-admin/docs/UserGuide_EN.md
delete mode 100644
eventmesh-admin/eventmesh-admin-rocketmq/src/main/java/org/apache/eventmesh/admin/rocketmq/controller/AdminController.java
delete mode 100644
eventmesh-admin/eventmesh-admin-rocketmq/src/main/java/org/apache/eventmesh/admin/rocketmq/handler/TopicsHandler.java
delete mode 100644
eventmesh-admin/eventmesh-admin-rocketmq/src/main/java/org/apache/eventmesh/admin/rocketmq/request/TopicCreateRequest.java
delete mode 100644
eventmesh-admin/eventmesh-admin-rocketmq/src/main/java/org/apache/eventmesh/admin/rocketmq/response/TopicResponse.java
delete mode 100644
eventmesh-admin/eventmesh-admin-rocketmq/src/main/java/org/apache/eventmesh/admin/rocketmq/util/RequestMapping.java
delete mode 100644
eventmesh-admin/eventmesh-admin-rocketmq/src/main/java/org/apache/eventmesh/admin/rocketmq/util/UrlMappingPattern.java
delete mode 100644
eventmesh-admin/eventmesh-admin-rocketmq/src/test/java/org/apache/eventmesh/admin/rocketmq/request/TopicCreateRequestTest.java
delete mode 100644
eventmesh-admin/eventmesh-admin-rocketmq/src/test/java/org/apache/eventmesh/admin/rocketmq/response/TopicResponseTest.java
delete mode 100644
eventmesh-admin/eventmesh-admin-rocketmq/src/test/java/org/apache/eventmesh/admin/rocketmq/util/RequestMappingTest.java
delete mode 100644
eventmesh-admin/eventmesh-admin-rocketmq/src/test/java/org/apache/eventmesh/admin/rocketmq/util/UrlMappingPatternTest.java
create mode 100644 eventmesh-admin/gradle/wrapper/gradle-wrapper.jar
copy {gradle => eventmesh-admin/gradle}/wrapper/gradle-wrapper.properties (93%)
create mode 100644 eventmesh-admin/gradlew
copy gradlew.bat => eventmesh-admin/gradlew.bat (89%)
copy eventmesh-admin/{build.gradle => settings.gradle} (95%)
copy
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/mysql/StopEventData.java
=>
eventmesh-admin/src/main/java/org/apache/eventmesh/admin/EventMeshAdminApplication.java
(70%)
copy
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/SubscriptionType.java
=>
eventmesh-admin/src/main/java/org/apache/eventmesh/admin/common/ConfigConst.java
(63%)
create mode 100644
eventmesh-admin/src/main/java/org/apache/eventmesh/admin/common/NacosConst.java
create mode 100644
eventmesh-admin/src/main/java/org/apache/eventmesh/admin/config/AdminProperties.java
create mode 100644
eventmesh-admin/src/main/java/org/apache/eventmesh/admin/config/MetaTypeConfig.java
create mode 100644
eventmesh-admin/src/main/java/org/apache/eventmesh/admin/controller/ConnectionController.java
create mode 100644
eventmesh-admin/src/main/java/org/apache/eventmesh/admin/controller/SubscriptionController.java
create mode 100644
eventmesh-admin/src/main/java/org/apache/eventmesh/admin/dto/Result.java
create mode 100644
eventmesh-admin/src/main/java/org/apache/eventmesh/admin/enums/Errors.java
create mode 100644
eventmesh-admin/src/main/java/org/apache/eventmesh/admin/exception/BaseException.java
copy
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/SubscriptionMode.java
=>
eventmesh-admin/src/main/java/org/apache/eventmesh/admin/exception/EventMeshAdminException.java
(61%)
copy
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/event/EventHandler.java
=>
eventmesh-admin/src/main/java/org/apache/eventmesh/admin/exception/EventMeshException.java
(73%)
create mode 100644
eventmesh-admin/src/main/java/org/apache/eventmesh/admin/exception/GlobalExceptionHandler.java
copy
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/SubscriptionMode.java
=>
eventmesh-admin/src/main/java/org/apache/eventmesh/admin/exception/MetaException.java
(59%)
copy eventmesh-admin/{build.gradle =>
src/main/java/org/apache/eventmesh/admin/model/ConnectionInfo.java} (91%)
copy
eventmesh-connectors/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/config/PulsarServerConfig.java
=>
eventmesh-admin/src/main/java/org/apache/eventmesh/admin/model/SubscriptionInfo.java
(76%)
copy
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/ThreadPoolGroup.java
=>
eventmesh-admin/src/main/java/org/apache/eventmesh/admin/service/ConnectionService.java
(74%)
copy
eventmesh-sdks/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/producer/GrpcProducer.java
=>
eventmesh-admin/src/main/java/org/apache/eventmesh/admin/service/SubscriptionService.java
(58%)
copy
eventmesh-spi/src/test/java/org/apache/eventmesh/spi/example/AnotherSingletonExtension.java
=>
eventmesh-admin/src/main/java/org/apache/eventmesh/admin/service/impl/EtcdConnectionService.java
(78%)
copy
eventmesh-meta/eventmesh-meta-etcd/src/main/java/org/apache/eventmesh/meta/etcd/factory/EtcdStreamObserver.java
=>
eventmesh-admin/src/main/java/org/apache/eventmesh/admin/service/impl/EtcdSubscriptionService.java
(58%)
create mode 100644
eventmesh-admin/src/main/java/org/apache/eventmesh/admin/service/impl/NacosConnectionService.java
create mode 100644
eventmesh-admin/src/main/java/org/apache/eventmesh/admin/service/impl/NacosSubscriptionService.java
copy
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/SubscriptionType.java
=>
eventmesh-admin/src/main/java/org/apache/eventmesh/admin/utils/ExceptionUtils.java
(68%)
copy gradle.properties => eventmesh-admin/src/main/resources/application.yml
(55%)
create mode 100644 eventmesh-admin/src/main/resources/logback.xml
copy
eventmesh-storage-plugin/eventmesh-storage-api/src/main/java/org/apache/eventmesh/api/AsyncConsumeContext.java
=>
eventmesh-admin/src/test/java/org/apache/eventmesh/admin/EventMeshAdminApplicationTests.java
(77%)
create mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/utils/LogUtils.java
copy
eventmesh-common/src/{test/java/org/apache/eventmesh/common/utils/AssertUtilsTest.java
=> main/java/org/apache/eventmesh/common/utils/TypeUtils.java} (66%)
copy
eventmesh-common/src/test/java/org/apache/eventmesh/common/utils/{IPUtilsTest.java
=> TypeUtilsTest.java} (63%)
copy
eventmesh-connectors/{eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/AbstractPartition.java
=> eventmesh-connector-file/build.gradle} (81%)
copy {eventmesh-admin/eventmesh-admin-rocketmq =>
eventmesh-connectors/eventmesh-connector-file}/gradle.properties (95%)
copy
eventmesh-connectors/{eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/config/PulsarServerConfig.java
=>
eventmesh-connector-file/src/main/java/org/apache/eventmesh/connector/file/config/FileServerConfig.java}
(84%)
copy
eventmesh-connectors/{eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/server/JdbcConnectorServer.java
=>
eventmesh-connector-file/src/main/java/org/apache/eventmesh/connector/file/server/FileConnectServer.java}
(64%)
copy
eventmesh-connectors/{eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/sink/config/PulsarSinkConfig.java
=>
eventmesh-connector-file/src/main/java/org/apache/eventmesh/connector/file/sink/config/FileSinkConfig.java}
(78%)
copy
eventmesh-connectors/{eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/source/config/SourceConnectorConfig.java
=>
eventmesh-connector-file/src/main/java/org/apache/eventmesh/connector/file/sink/config/SinkConnectorConfig.java}
(87%)
create mode 100644
eventmesh-connectors/eventmesh-connector-file/src/main/java/org/apache/eventmesh/connector/file/sink/connector/FileSinkConnector.java
copy
eventmesh-connectors/{eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/source/config/PulsarSourceConfig.java
=>
eventmesh-connector-file/src/main/java/org/apache/eventmesh/connector/file/source/config/FileSourceConfig.java}
(83%)
copy
eventmesh-connectors/{eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq
=>
eventmesh-connector-file/src/main/java/org/apache/eventmesh/connector/file}/source/config/SourceConnectorConfig.java
(94%)
create mode 100644
eventmesh-connectors/eventmesh-connector-file/src/main/java/org/apache/eventmesh/connector/file/source/connector/FileSourceConnector.java
rename eventmesh-admin/gradle.properties =>
eventmesh-connectors/eventmesh-connector-file/src/main/resources/server-config.yml
(95%)
copy gradle/wrapper/gradle-wrapper.properties =>
eventmesh-connectors/eventmesh-connector-file/src/main/resources/sink-config.yml
(75%)
copy eventmesh-connectors/{eventmesh-connector-rocketmq =>
eventmesh-connector-file}/src/main/resources/source-config.yml (88%)
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/DataChanges.java
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/cdc/AbstractCdcEngine.java
copy
eventmesh-storage-plugin/eventmesh-storage-api/src/main/java/org/apache/eventmesh/api/AsyncConsumeContext.java
=>
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/cdc/AbstractCdcEngineFactory.java
(85%)
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/cdc/mysql/MysqlCdcEngine.java
copy
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/cdc/{CdcEngineFactory.java
=> mysql/MysqlCdcEngineFactory.java} (55%)
create mode 100644
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/cdc/mysql/RowDeserializers.java
rename
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/mysql/{GtidSet.java
=> EventMeshGtidSet.java} (93%)
copy
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/mysql/{StopEventData.java
=> MysqlConstants.java} (69%)
copy {eventmesh-meta/eventmesh-meta-etcd =>
eventmesh-connectors/eventmesh-connector-prometheus}/build.gradle (79%)
copy {eventmesh-admin/eventmesh-admin-rocketmq =>
eventmesh-connectors/eventmesh-connector-prometheus}/gradle.properties (94%)
copy
eventmesh-connectors/{eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/config/PulsarServerConfig.java
=>
eventmesh-connector-prometheus/src/main/java/org/apache/eventmesh/connector/prometheus/config/PrometheusServerConfig.java}
(84%)
copy
eventmesh-connectors/{eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/source/config/SourceConnectorConfig.java
=>
eventmesh-connector-prometheus/src/main/java/org/apache/eventmesh/connector/prometheus/model/QueryPrometheusReq.java}
(81%)
copy
eventmesh-storage-plugin/eventmesh-storage-api/src/main/java/org/apache/eventmesh/api/AsyncConsumeContext.java
=>
eventmesh-connectors/eventmesh-connector-prometheus/src/main/java/org/apache/eventmesh/connector/prometheus/model/QueryPrometheusRsp.java
(82%)
copy
eventmesh-connectors/{eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/source/config/SourceConnectorConfig.java
=>
eventmesh-connector-prometheus/src/main/java/org/apache/eventmesh/connector/prometheus/model/ResponseData.java}
(81%)
copy
eventmesh-connectors/{eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/server/JdbcConnectorServer.java
=>
eventmesh-connector-prometheus/src/main/java/org/apache/eventmesh/connector/prometheus/server/PrometheusConnectServer.java}
(65%)
copy
eventmesh-connectors/{eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/source/config/PulsarSourceConfig.java
=>
eventmesh-connector-prometheus/src/main/java/org/apache/eventmesh/connector/prometheus/source/config/PrometheusSourceConfig.java}
(83%)
copy
eventmesh-connectors/{eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq
=>
eventmesh-connector-prometheus/src/main/java/org/apache/eventmesh/connector/prometheus}/source/config/SourceConnectorConfig.java
(77%)
create mode 100644
eventmesh-connectors/eventmesh-connector-prometheus/src/main/java/org/apache/eventmesh/connector/prometheus/source/connector/PrometheusSourceConnector.java
copy eventmesh-connectors/{eventmesh-connector-kafka =>
eventmesh-connector-prometheus}/src/main/resources/server-config.yml (100%)
copy eventmesh-connectors/{eventmesh-connector-rocketmq =>
eventmesh-connector-prometheus}/src/main/resources/source-config.yml (65%)
rename {eventmesh-admin/eventmesh-admin-rocketmq =>
eventmesh-connectors/eventmesh-connector-spring}/build.gradle (62%)
copy {eventmesh-admin/eventmesh-admin-rocketmq =>
eventmesh-connectors/eventmesh-connector-spring}/gradle.properties (94%)
copy
eventmesh-meta/eventmesh-meta-etcd/src/main/java/org/apache/eventmesh/meta/etcd/factory/EtcdStreamObserver.java
=>
eventmesh-connectors/eventmesh-connector-spring/src/main/java/org/apache/eventmesh/connector/spring/common/SpringApplicationContextHolder.java
(50%)
create mode 100644
eventmesh-connectors/eventmesh-connector-spring/src/main/java/org/apache/eventmesh/connector/spring/config/EventMeshAutoConfiguration.java
copy
eventmesh-connectors/{eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/config/PulsarServerConfig.java
=>
eventmesh-connector-spring/src/main/java/org/apache/eventmesh/connector/spring/config/SpringConnectServerConfig.java}
(84%)
create mode 100644
eventmesh-connectors/eventmesh-connector-spring/src/main/java/org/apache/eventmesh/connector/spring/server/SpringConnectServer.java
copy
eventmesh-connectors/{eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/Schema.java
=>
eventmesh-connector-spring/src/main/java/org/apache/eventmesh/connector/spring/sink/EventMeshConsumerMetadata.java}
(79%)
copy eventmesh-spi/src/main/java/org/apache/eventmesh/spi/EventMeshSPI.java =>
eventmesh-connectors/eventmesh-connector-spring/src/main/java/org/apache/eventmesh/connector/spring/sink/EventMeshListener.java
(74%)
create mode 100644
eventmesh-connectors/eventmesh-connector-spring/src/main/java/org/apache/eventmesh/connector/spring/sink/EventMeshListenerBeanPostProcessor.java
copy
eventmesh-connectors/{eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/sink/config/PulsarSinkConfig.java
=>
eventmesh-connector-spring/src/main/java/org/apache/eventmesh/connector/spring/sink/config/SpringSinkConfig.java}
(74%)
copy
eventmesh-connectors/{eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/source/config/SourceConnectorConfig.java
=>
eventmesh-connector-spring/src/main/java/org/apache/eventmesh/connector/spring/sink/connector/SinkConnectorConfig.java}
(84%)
copy
eventmesh-connectors/{eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/sink/connector/PulsarSinkConnector.java
=>
eventmesh-connector-spring/src/main/java/org/apache/eventmesh/connector/spring/sink/connector/SpringSinkConnector.java}
(50%)
copy
eventmesh-connectors/{eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/DatabaseType.java
=>
eventmesh-connector-spring/src/main/java/org/apache/eventmesh/connector/spring/sink/connector/SpringSinkConnectorCreateServiceImpl.java}
(55%)
copy
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/ShortHttpProcessor.java
=>
eventmesh-connectors/eventmesh-connector-spring/src/main/java/org/apache/eventmesh/connector/spring/source/MessageSendingOperations.java
(82%)
copy
eventmesh-connectors/{eventmesh-connector-s3/src/main/java/org/apache/eventmesh/connector/s3/source/config/S3SourceConfig.java
=>
eventmesh-connector-spring/src/main/java/org/apache/eventmesh/connector/spring/source/config/SpringSourceConfig.java}
(77%)
copy
eventmesh-connectors/{eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/source/config
=>
eventmesh-connector-spring/src/main/java/org/apache/eventmesh/connector/spring/source/connector}/SourceConnectorConfig.java
(88%)
copy
eventmesh-connectors/{eventmesh-connector-mongodb/src/main/java/org/apache/eventmesh/connector/mongodb/source/connector/MongodbSourceConnector.java
=>
eventmesh-connector-spring/src/main/java/org/apache/eventmesh/connector/spring/source/connector/SpringSourceConnector.java}
(57%)
copy
eventmesh-connectors/{eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/DatabaseType.java
=>
eventmesh-connector-spring/src/main/java/org/apache/eventmesh/connector/spring/source/connector/SpringSourceConnectorCreateServiceImpl.java}
(55%)
copy gradle/wrapper/gradle-wrapper.properties =>
eventmesh-connectors/eventmesh-connector-spring/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.openconnect.api.ConnectorCreateService
(79%)
rename eventmesh-admin/eventmesh-admin-rocketmq/gradle.properties =>
eventmesh-connectors/eventmesh-connector-spring/src/main/resources/META-INF/spring.factories
(85%)
copy eventmesh-connectors/{eventmesh-connector-jdbc =>
eventmesh-connector-spring}/src/main/resources/server-config.yml (100%)
copy gradle/wrapper/gradle-wrapper.properties =>
eventmesh-connectors/eventmesh-connector-spring/src/main/resources/sink-config.yml
(76%)
copy gradle/wrapper/gradle-wrapper.properties =>
eventmesh-connectors/eventmesh-connector-spring/src/main/resources/source-config.yml
(75%)
rename eventmesh-meta/eventmesh-meta-consul/src/test/java/{ =>
org/apache/eventmesh/meta/consul/service}/ConsulMetaServiceTest.java (59%)
copy
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/event/SchemaChangeEvent.java
=>
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/ConnectorCreateService.java
(66%)
copy
eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt/api/storage/{MemoryBasedKeyValueStore.java
=> DefaultOffsetManagementServiceImpl.java} (55%)
copy {eventmesh-connectors => eventmesh-protocol-plugin}/build.gradle (100%)
create mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/AbstractRetryer.java
delete mode 100644 eventmesh-sdks/eventmesh-sdk-rust/Cargo.lock
create mode 100644 eventmesh-sdks/eventmesh-sdk-rust/README.md
copy
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/event/EventHandler.java
=> eventmesh-sdks/eventmesh-sdk-rust/build.rs (70%)
delete mode 100644 eventmesh-sdks/eventmesh-sdk-rust/eventmesh/Cargo.toml
delete mode 100644 eventmesh-sdks/eventmesh-sdk-rust/eventmesh/build.rs
delete mode 100644
eventmesh-sdks/eventmesh-sdk-rust/eventmesh/proto/eventmesh-client.proto
delete mode 100644 eventmesh-sdks/eventmesh-sdk-rust/eventmesh/src/constants.rs
delete mode 100644
eventmesh-sdks/eventmesh-sdk-rust/eventmesh/src/grpc/config.rs
delete mode 100644
eventmesh-sdks/eventmesh-sdk-rust/eventmesh/src/grpc/consumer.rs
delete mode 100644 eventmesh-sdks/eventmesh-sdk-rust/eventmesh/src/grpc/mod.rs
delete mode 100644
eventmesh-sdks/eventmesh-sdk-rust/eventmesh/src/grpc/producer.rs
delete mode 100644
eventmesh-sdks/eventmesh-sdk-rust/eventmesh/src/http/config.rs
delete mode 100644 eventmesh-sdks/eventmesh-sdk-rust/eventmesh/src/http/mod.rs
delete mode 100644
eventmesh-sdks/eventmesh-sdk-rust/eventmesh/src/http/producer.rs
delete mode 100644
eventmesh-sdks/eventmesh-sdk-rust/eventmesh/src/http/protocol_key.rs
delete mode 100644
eventmesh-sdks/eventmesh-sdk-rust/eventmesh/src/http/request_code.rs
delete mode 100644 eventmesh-sdks/eventmesh-sdk-rust/eventmesh/src/lib.rs
delete mode 100644 eventmesh-sdks/eventmesh-sdk-rust/eventmesh/src/message.rs
delete mode 100644 eventmesh-sdks/eventmesh-sdk-rust/examples/Cargo.lock
delete mode 100644 eventmesh-sdks/eventmesh-sdk-rust/examples/Cargo.toml
delete mode 100644
eventmesh-sdks/eventmesh-sdk-rust/examples/grpc-consumer-stream.rs
delete mode 100644 eventmesh-sdks/eventmesh-sdk-rust/examples/grpc-consumer.rs
delete mode 100644
eventmesh-sdks/eventmesh-sdk-rust/examples/grpc-producer-batch-publish.rs
delete mode 100644
eventmesh-sdks/eventmesh-sdk-rust/examples/grpc-producer-publish.rs
delete mode 100644
eventmesh-sdks/eventmesh-sdk-rust/examples/grpc-producer-request.rs
create mode 100644
eventmesh-sdks/eventmesh-sdk-rust/examples/grpc/consumer_example.rs
create mode 100644
eventmesh-sdks/eventmesh-sdk-rust/examples/grpc/producer_example.rs
delete mode 100644
eventmesh-sdks/eventmesh-sdk-rust/examples/http-producer-publish.rs
delete mode 100644
eventmesh-sdks/eventmesh-sdk-rust/examples/http-producer-request.rs
copy {eventmesh-connectors/eventmesh-connector-openfunction/src/main =>
eventmesh-sdks/eventmesh-sdk-rust}/proto/eventmesh-cloudevents.proto (100%)
copy {eventmesh-connectors/eventmesh-connector-openfunction/src/main =>
eventmesh-sdks/eventmesh-sdk-rust}/proto/eventmesh-service.proto (100%)
create mode 100644 eventmesh-sdks/eventmesh-sdk-rust/src/common.rs
copy
eventmesh-common/src/test/java/org/apache/eventmesh/common/utils/SystemUtilsTest.java
=> eventmesh-sdks/eventmesh-sdk-rust/src/common/constants.rs (50%)
create mode 100644
eventmesh-sdks/eventmesh-sdk-rust/src/common/eventmesh_message_utils.rs
rename
eventmesh-admin/eventmesh-admin-rocketmq/src/main/java/org/apache/eventmesh/admin/rocketmq/Constants.java
=> eventmesh-sdks/eventmesh-sdk-rust/src/common/local_ip.rs (68%)
create mode 100644 eventmesh-sdks/eventmesh-sdk-rust/src/common/protocol_key.rs
create mode 100644
eventmesh-sdks/eventmesh-sdk-rust/src/common/random_string_util.rs
copy
eventmesh-storage-plugin/eventmesh-storage-api/src/main/java/org/apache/eventmesh/api/AsyncConsumeContext.java
=> eventmesh-sdks/eventmesh-sdk-rust/src/config.rs (77%)
create mode 100644 eventmesh-sdks/eventmesh-sdk-rust/src/config/grpc_config.rs
create mode 100644 eventmesh-sdks/eventmesh-sdk-rust/src/error.rs
copy
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/SubscriptionType.java
=> eventmesh-sdks/eventmesh-sdk-rust/src/grpc.rs (62%)
copy eventmesh-admin/build.gradle =>
eventmesh-sdks/eventmesh-sdk-rust/src/grpc/eventmesh_message.rs (89%)
create mode 100644
eventmesh-sdks/eventmesh-sdk-rust/src/grpc/eventmesh_message/eventmesh_message_producer.rs
create mode 100644 eventmesh-sdks/eventmesh-sdk-rust/src/grpc/grpc_consumer.rs
copy
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/SubscriptionMode.java
=> eventmesh-sdks/eventmesh-sdk-rust/src/grpc/grpc_producer.rs (59%)
copy eventmesh-admin/build.gradle =>
eventmesh-sdks/eventmesh-sdk-rust/src/grpc/pb.rs (89%)
create mode 100644 eventmesh-sdks/eventmesh-sdk-rust/src/lib.rs
copy
eventmesh-storage-plugin/eventmesh-storage-api/src/main/java/org/apache/eventmesh/api/AsyncConsumeContext.java
=> eventmesh-sdks/eventmesh-sdk-rust/src/log.rs (77%)
create mode 100644 eventmesh-sdks/eventmesh-sdk-rust/src/model.rs
copy
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/common/Response.java
=> eventmesh-sdks/eventmesh-sdk-rust/src/model/convert.rs (65%)
create mode 100644 eventmesh-sdks/eventmesh-sdk-rust/src/model/message.rs
create mode 100644 eventmesh-sdks/eventmesh-sdk-rust/src/model/response.rs
create mode 100644 eventmesh-sdks/eventmesh-sdk-rust/src/model/subscription.rs
copy
eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/AbstractPartition.java
=> eventmesh-sdks/eventmesh-sdk-rust/src/net.rs (86%)
copy eventmesh-admin/build.gradle =>
eventmesh-sdks/eventmesh-sdk-rust/src/net/grpc.rs (96%)
create mode 100644
eventmesh-sdks/eventmesh-sdk-rust/src/net/grpc/grpc_client.rs
create mode 100644
eventmesh-sdks/eventmesh-sdk-rust/tests/eventmesh_message_utils_test.rs
delete mode 100644
eventmesh-storage-plugin/eventmesh-storage-rocketmq/src/test/java/org/apache/eventmesh/storage/rocketmq/promise/DefaultPromiseTest.java
create mode 100644 style/task/eventmesh-spotless-formatter.xml
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
