This is an automated email from the ASF dual-hosted git repository.
shenlin pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git
from 51dfa1e Create maven-publish.yml
add 3536bec Build runtimer (#56)
add c250d29 Update Runtimer Listener Offer Connect Record (#57)
add 03cc691 feat:add TargetRunnerConfigObserver (#58)
add 701cdac feat:add watch runner config. (#63)
add b753b88 Optimize Event Circulator Context (#70)
add 00003f3 fix: Null pointer exception when TargetRunner starts in file
mode
add 4673ae1 Optimize fileObserver formate and Support module (#76)
add 7437e43 feat:add ConfigModeEnum(File/DB/CONTROLLER)
add 2f63927 new implementation of RocketMQEventSubscriber
add 9d057bd add apache licence
add 02cb142 solve rmq conflict
add 44c3b6b feat:add error handler to runtime.
add 3589b53 feat:add rumtimer.config.mode
add 7233b2e Standard the run context of the config json file (#89)
add 978ba15 Add simulated backpressure test code
add bff124c feat:support record commit.
add 534f8eb feat:support record commit.
add a42a6ac feat:targets own isolate consumerGroup
add 64e6e9d extract the storage module
add 81fdd91 Integrate rocketmq-related content into storage module
add 63eef78 feat:support runtimer db observer
add 083fab9 feat:support standard sink connector.
add 456c09d feature:update runner json file, rule transfer biz optimize,
commit biz (#102)
add b972f88 ResetDefaultConfig (#105)
add f2ba4ba add license
add 7b28c24 refactor shutdown
add 53980a1 refactor shutdown
add ab13b5c adjust logic
add 1b6c079 1.add embedded database 2.add default validateFilter
add aa291ea 1.add h2 db migration file directory
add 530532e 1.add readme 2.modify ValidateFilter, add default filter
add 6afebb0 1.merge h2-migration and migration
add f9fb2e9 feat:add runtime demo.
add cdcdc51 feat:add runtime demo.
add 89137e7 feat:add runtime demo.
add 2a0770c feat:add runtime demo.
No new revisions were added by this update.
Summary of changes:
.licenserc.yaml | 2 +
README.md | 217 ++----------
.../adapter/api/controller/EventBusController.java | 2 +-
.../api/converter/EventTargetConverter.java | 4 +-
.../api/converter/EventTargetDTOConverter.java | 2 +-
.../adapter/api/dto/bus/ListEventBusesRequest.java | 2 +-
.../api/converter/EventTargetConverterTest.java | 4 +-
.../api/converter/EventTargetDTOConverterTest.java | 4 +-
adapter/persistence/pom.xml | 12 +-
.../adapter/persistence/DatasourceConfig.java | 110 ++++++
.../adapter/persistence/FlywayConfig.java | 45 +++
.../adapter/persistence/PersistenceConfig.java | 2 -
.../MybatisEventTargetRunnerRepository.java | 14 +
.../main/resources/db/migration/V1__baseline.sql | 76 ++---
.../main/resources/db/migration/V2__baseline.sql | 42 +--
.../migration/V3__change_target_transform_type.sql | 30 +-
.../db/migration/V4__register_source_acs_mns.sql | 30 +-
.../migration/V5__register_target_acs_dingtalk.sql | 52 ++-
.../V6__register_target_acs_eventbridge.sql | 71 +++-
...V7__update_event_connection_table_structure.sql | 35 +-
.../db/migration/V8__update_unique_key.sql | 40 +--
.../db/migration/V9__init_file_target_class.sql} | 35 +-
.../resources/mybatis/EventTargetRunnerMapper.xml | 14 +-
adapter/pom.xml | 2 +
adapter/rpc/pom.xml | 11 +-
.../RocketMQConnectSourceRunnerAPIImpl.java | 2 +-
.../RocketMQConnectTargetRunnerAPIImpl.java | 107 ------
.../rpc/impl/connect/RocketMQConverter.java | 14 +-
.../RocketMQConnectTargetRunnerContext.java | 5 +
.../connect/dto/CreateSinkConnectorRequest.java | 11 +-
.../connect/dto/CreateSourceConnectorRequest.java | 7 +-
.../impl/runtime/RuntimeTargetRunnerAPIImpl.java | 93 +++++
adapter/runtime/README.md | 68 ++++
{domain => adapter/runtime}/pom.xml | 82 +++--
.../eventbridge/adapter/runtime/Runtime.java | 105 ++++++
.../adapter/runtime/boot/EventBusListener.java | 78 +++++
.../adapter/runtime/boot/EventRuleTransfer.java | 133 ++++++++
.../adapter/runtime/boot/EventTargetTrigger.java | 107 ++++++
.../runtime/boot/common/CirculatorContext.java | 321 ++++++++++++++++++
.../adapter/runtime/boot/common/OffsetManager.java | 44 +++
.../runtime/boot/common/TargetRunnerListener.java | 45 +++
.../boot/hook/AbstractStartAndShutdown.java | 73 ++++
.../adapter/runtime/boot/hook/Shutdown.java} | 16 +-
.../adapter/runtime/boot/hook/Start.java} | 17 +-
.../runtime/boot/hook/StartAndShutdown.java} | 15 +-
.../runtime/boot/listener/EventSubscriber.java | 97 ++++++
.../runtime/boot/transfer/TransformEngine.java | 174 ++++++++++
.../runtime/boot/trigger/TriggerTaskContext.java | 188 +++++++++++
.../runtime/common/FileAndPropertyUtil.java | 145 ++++++++
.../adapter/runtime/common/FilePathConfigUtil.java | 39 +++
.../adapter/runtime/common/LoggerName.java | 28 ++
.../adapter/runtime/common/QueueState.java} | 7 +-
.../adapter/runtime/common/RuntimeState.java} | 20 +-
.../adapter/runtime/common/ServiceThread.java | 143 ++++++++
.../runtime/common/entity/SubscribeRunnerKeys.java | 58 ++++
.../runtime/common/entity/TargetKeyValue.java | 171 ++++++++++
.../runtime/common/entity/TargetRunnerConfig.java | 127 +++++++
.../runtime/common/enums/ConfigModeEnum.java | 39 +++
.../runtime/common/enums/RefreshTypeEnum.java | 27 ++
.../runtime/common/enums/StorageModeEnum.java | 41 +++
.../adapter/runtime/common/plugin/Plugin.java | 192 +++++++++++
.../runtime/common/plugin/PluginClassLoader.java | 75 +++++
.../adapter/runtime/common/plugin/PluginUtils.java | 239 +++++++++++++
.../runtime/common/plugin/PluginWrapper.java | 76 +++++
.../common/store/FileBaseKeyValueStore.java | 130 +++++++
.../runtime/common/store/KeyValueStore.java | 106 ++++++
.../common/store/MemoryBasedKeyValueStore.java | 81 +++++
.../runtime/config/RuntimeConfigDefine.java | 53 ++-
.../adapter/runtime/config/RuntimeConfigProps.java | 53 +++
.../runtime/config/RuntimeConfiguration.java | 45 +++
.../adapter/runtime/config/TraceConfig.java} | 15 +-
.../adapter/runtime/converter/JsonConverter.java | 77 +++++
.../adapter/runtime/converter/ListConverter.java | 64 ++++
.../runtime/converter/RecordOffsetConverter.java | 58 ++++
.../runtime/error/DeadLetterQueueService.java} | 16 +-
.../adapter/runtime/error/ErrorHandler.java | 100 ++++++
.../AbstractTargetRunnerConfigObserver.java | 136 ++++++++
.../service/TargetRunnerConfigObserver.java | 50 +++
.../TargetRunnerConfigOnControllerObserver.java | 46 +++
.../service/TargetRunnerConfigOnDBObserver.java | 89 +++++
.../service/TargetRunnerConfigOnFileObserver.java | 115 +++++++
.../runtime/trace/JaegerTraceStrategy.java} | 15 +-
.../adapter/runtime/trace/TraceConstants.java} | 15 +-
.../adapter/runtime/trace/TraceFactory.java | 31 ++
.../adapter/runtime/utils/ExceptionUtil.java | 47 +++
.../adapter/runtime/utils/ShutdownUtils.java | 45 +++
.../src/main/resources/runtime.properties} | 19 +-
.../runtime/src/main/resources/target-runner.json | 24 ++
.../TargetRunnerConfigOnFileObserverTest.java | 103 ++++++
.../runtimer/service/TargetRunnerConfigUtil.java | 132 ++++++++
.../runtimer/service/TestConstants.java | 23 ++
.../ConsumerSlowerPIDControllerTest.java | 56 ++++
.../backpressure/MockEventBusListenerTest.java | 55 +++
.../service/backpressure/PIDContextTest.java | 59 ++++
.../service/backpressure/PIDController.java | 128 +++++++
.../ProductSlowerPIDControllerTest.java | 44 +++
.../runtimer/service/backpressure/PusherTest.java | 63 ++++
.../service/backpressure/RateEstimatorTest.java | 90 +++++
.../service/backpressure/TransformTest.java | 61 ++++
adapter/storage/pom.xml | 82 +++++
.../api}/EventDataOnRocketMQConnectAPI.java | 2 +-
.../rocketmq/api}/RocketMQEventDataAPIImpl.java | 3 +-
.../rocketmq/impl}/DefaultSendCallback.java | 2 +-
.../impl}/RocketMQEventDataRepository.java | 11 +-
.../rocketmq/impl}/RocketMQMetaService.java | 18 +-
.../rocketmq/runtimer/RocketMQEventSubscriber.java | 373 +++++++++++++++++++++
.../rocketmq/runtimer/consumer/ClientConfig.java | 130 +++++++
.../rocketmq/runtimer/consumer/ConsumeRequest.java | 51 +++
.../runtimer/consumer/ExponentialRetryPolicy.java | 86 +++++
.../runtimer/consumer/LitePullConsumer.java | 28 +-
.../runtimer/consumer/LitePullConsumerImpl.java | 310 +++++++++++++++++
.../runtimer/consumer/LocalMessageCache.java | 174 ++++++++++
.../rocketmq/runtimer/consumer/RetryPolicy.java} | 12 +-
.../eventbridge}/enums/ErrorToleranceEnum.java | 2 +-
.../eventbridge}/enums/PushRetryStrategyEnum.java | 4 +-
.../eventbridge/enums/props/Constants.java | 24 +-
.../ServiceProviderNotFoundException.java} | 27 +-
docs/CreateFileTarget.md | 51 +++
docs/EventSource.md | 42 +++
docs/cn/RocketMQEventBridgeDatabaseUsage.md | 29 ++
docs/cn/RocketMQEventBridgeRuleValidation.md | 44 +++
docs/cn/images/demo.png | Bin 0 -> 49258 bytes
docs/cn/images/h2.png | Bin 0 -> 188366 bytes
.../domain/model/bus/EventBusService.java | 2 +-
.../domain/model/data/EventDataService.java | 2 +-
.../domain/model/run/EventTargetRunnerService.java | 37 +-
.../domain/model/run/RetryStrategy.java | 2 +-
.../eventbridge/domain/model/run/RunOptions.java | 2 +-
.../domain/model/target/EventTargetService.java | 3 +-
.../repository/EventTargetRunnerRepository.java | 3 +
.../EventDataRepository.java | 16 +-
infrastructure/README-CN.md | 16 +
{adapter => infrastructure}/pom.xml | 28 +-
.../infrastructure/metric/MonitorFactory.java | 31 ++
.../infrastructure/trace/TraceException.java | 15 +-
.../infrastructure/trace/TraceStrategy.java | 20 +-
.../infrastructure/trace/ZipkinTraceStrategy.java | 35 ++
.../infrastructure/validate/AuthValidation.java | 25 +-
.../validate/DefaultAuthValidation.java | 47 +++
.../validate/spi/ServiceLifecycle.java | 31 ++
.../validate/spi/ValidationServiceFactory.java | 47 +++
.../validate/spi/ValidationServiceLoader.java | 91 +++++
.../validate/spi/annotation/SingletonSPI.java | 11 +-
.../validate/spi/typed/TypedSPI.java | 28 +-
.../validate/spi/typed/TypedSPIRegistry.java | 79 +++++
...ntbridge.infrastructure.validate.AuthValidation | 6 +-
pom.xml | 47 +++
start/pom.xml | 16 +
.../java/org/apache/rocketmq/eventbridge/Main.java | 3 +-
.../eventbridge/config/H2ServerConfig.java | 31 +-
.../rocketmq/eventbridge/filter/LoginFilter.java | 26 +-
.../eventbridge/filter/ValidateFilter.java | 69 ++++
start/src/main/resources/application.properties | 24 +-
supports/connect-cloudevent-transform/pom.xml | 2 +-
.../transform/eventbridge/CloudEventTransform.java | 8 +-
.../rocketmq/connect/CloudEventTransformTest.java | 2 +-
supports/connect-eventbridge-transform/pom.xml | 2 +-
.../eventbridge/EventBridgeTransform.java | 8 +-
.../rocketmq/connect/EventBridgeTransformTest.java | 2 +-
supports/connect-filter-transform/pom.xml | 2 +-
.../eventbridge/EventBridgeFilterTransform.java | 10 +-
.../EventBridgeFilterTransformTest.java | 2 +-
.../eventbridge-connect-file}/README.md | 0
.../pom.xml | 19 +-
.../apache/rocketmq/connect/sink/FileConstant.java | 18 +-
.../apache/rocketmq/connect/sink/FileSinkTask.java | 84 +++++
.../apache/rocketmq/connect/FileSinkTaskTest.java | 39 +++
.../eventbridge-connect-standard}/README.md | 0
.../pom.xml | 19 +-
.../rocketmq/connect/sink/StandardConstant.java | 18 +-
.../rocketmq/connect/sink/StandardSinkTask.java | 57 ++++
{adapter/api => test/demo}/pom.xml | 13 +-
.../rocketmq/eventbridge/demo/DefaultDemo.java | 105 ++++++
.../ApiDestinationDTOControllerTest.java | 2 +-
.../api/controller/ConnectionControllerTest.java | 0
.../api/converter/EventConverterAdapterTest.java | 0
.../api/converter/EventTargetConverterTest.java | 4 +-
.../api/converter/EventTargetDTOConverterTest.java | 4 +-
.../adapter/api/handler/EventDataHandlerTest.java | 0
{adapter => test}/pom.xml | 6 +-
180 files changed, 8181 insertions(+), 874 deletions(-)
create mode 100644
adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/DatasourceConfig.java
create mode 100644
adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/FlywayConfig.java
copy
adapter/{api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/dto/BaseRequest.java
=> persistence/src/main/resources/db/migration/V9__init_file_target_class.sql}
(58%)
delete mode 100644
adapter/rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/impl/connect/RocketMQConnectTargetRunnerAPIImpl.java
create mode 100644
adapter/rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/impl/runtime/RuntimeTargetRunnerAPIImpl.java
create mode 100644 adapter/runtime/README.md
copy {domain => adapter/runtime}/pom.xml (52%)
create mode 100644
adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/Runtime.java
create mode 100644
adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/EventBusListener.java
create mode 100644
adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/EventRuleTransfer.java
create mode 100644
adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/EventTargetTrigger.java
create mode 100644
adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/common/CirculatorContext.java
create mode 100644
adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/common/OffsetManager.java
create mode 100644
adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/common/TargetRunnerListener.java
create mode 100644
adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/hook/AbstractStartAndShutdown.java
copy
adapter/{rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/config/RpcConfiguration.java
=>
runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/hook/Shutdown.java}
(51%)
copy
adapter/{rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/config/RpcConfiguration.java
=>
runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/hook/Start.java}
(51%)
copy
adapter/{rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/config/RpcConfiguration.java
=>
runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/hook/StartAndShutdown.java}
(51%)
create mode 100644
adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/listener/EventSubscriber.java
create mode 100644
adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/transfer/TransformEngine.java
create mode 100644
adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/trigger/TriggerTaskContext.java
create mode 100644
adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/FileAndPropertyUtil.java
create mode 100644
adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/FilePathConfigUtil.java
create mode 100644
adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/LoggerName.java
copy
adapter/{rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/config/RpcConfiguration.java
=>
runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/QueueState.java}
(88%)
copy
adapter/{rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/config/RpcConfiguration.java
=>
runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/RuntimeState.java}
(51%)
create mode 100644
adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/ServiceThread.java
create mode 100644
adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/entity/SubscribeRunnerKeys.java
create mode 100644
adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/entity/TargetKeyValue.java
create mode 100644
adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/entity/TargetRunnerConfig.java
create mode 100644
adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/enums/ConfigModeEnum.java
create mode 100644
adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/enums/RefreshTypeEnum.java
create mode 100644
adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/enums/StorageModeEnum.java
create mode 100644
adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/plugin/Plugin.java
create mode 100644
adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/plugin/PluginClassLoader.java
create mode 100644
adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/plugin/PluginUtils.java
create mode 100644
adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/plugin/PluginWrapper.java
create mode 100644
adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/store/FileBaseKeyValueStore.java
create mode 100644
adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/store/KeyValueStore.java
create mode 100644
adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/store/MemoryBasedKeyValueStore.java
copy
domain/src/main/java/org/apache/rocketmq/eventbridge/domain/common/enums/ErrorToleranceEnum.java
=>
adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/config/RuntimeConfigDefine.java
(53%)
create mode 100644
adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/config/RuntimeConfigProps.java
create mode 100644
adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/config/RuntimeConfiguration.java
copy
adapter/{rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/config/RpcConfiguration.java
=>
runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/config/TraceConfig.java}
(53%)
create mode 100644
adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/converter/JsonConverter.java
create mode 100644
adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/converter/ListConverter.java
create mode 100644
adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/converter/RecordOffsetConverter.java
copy
adapter/{rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/config/RpcConfiguration.java
=>
runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/error/DeadLetterQueueService.java}
(53%)
create mode 100644
adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/error/ErrorHandler.java
create mode 100644
adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/service/AbstractTargetRunnerConfigObserver.java
create mode 100644
adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/service/TargetRunnerConfigObserver.java
create mode 100644
adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/service/TargetRunnerConfigOnControllerObserver.java
create mode 100644
adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/service/TargetRunnerConfigOnDBObserver.java
create mode 100644
adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/service/TargetRunnerConfigOnFileObserver.java
copy
adapter/{rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/config/RpcConfiguration.java
=>
runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/trace/JaegerTraceStrategy.java}
(53%)
copy
adapter/{rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/config/RpcConfiguration.java
=>
runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/trace/TraceConstants.java}
(53%)
create mode 100644
adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/trace/TraceFactory.java
create mode 100644
adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/utils/ExceptionUtil.java
create mode 100644
adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/utils/ShutdownUtils.java
copy
adapter/{persistence/src/main/resources/db/migration/V8__update_unique_key.sql
=> runtime/src/main/resources/runtime.properties} (66%)
create mode 100644 adapter/runtime/src/main/resources/target-runner.json
create mode 100644
adapter/runtime/src/test/java/org/apache/rocketmq/eventbridge/runtimer/service/TargetRunnerConfigOnFileObserverTest.java
create mode 100644
adapter/runtime/src/test/java/org/apache/rocketmq/eventbridge/runtimer/service/TargetRunnerConfigUtil.java
create mode 100644
adapter/runtime/src/test/java/org/apache/rocketmq/eventbridge/runtimer/service/TestConstants.java
create mode 100644
adapter/runtime/src/test/java/org/apache/rocketmq/eventbridge/runtimer/service/backpressure/ConsumerSlowerPIDControllerTest.java
create mode 100644
adapter/runtime/src/test/java/org/apache/rocketmq/eventbridge/runtimer/service/backpressure/MockEventBusListenerTest.java
create mode 100644
adapter/runtime/src/test/java/org/apache/rocketmq/eventbridge/runtimer/service/backpressure/PIDContextTest.java
create mode 100644
adapter/runtime/src/test/java/org/apache/rocketmq/eventbridge/runtimer/service/backpressure/PIDController.java
create mode 100644
adapter/runtime/src/test/java/org/apache/rocketmq/eventbridge/runtimer/service/backpressure/ProductSlowerPIDControllerTest.java
create mode 100644
adapter/runtime/src/test/java/org/apache/rocketmq/eventbridge/runtimer/service/backpressure/PusherTest.java
create mode 100644
adapter/runtime/src/test/java/org/apache/rocketmq/eventbridge/runtimer/service/backpressure/RateEstimatorTest.java
create mode 100644
adapter/runtime/src/test/java/org/apache/rocketmq/eventbridge/runtimer/service/backpressure/TransformTest.java
create mode 100644 adapter/storage/pom.xml
rename
adapter/{persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/rpc
=>
storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/api}/EventDataOnRocketMQConnectAPI.java
(94%)
rename
adapter/{rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/impl =>
storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/api}/RocketMQEventDataAPIImpl.java
(97%)
rename
adapter/{persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/data/rocketmq/repository
=>
storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/impl}/DefaultSendCallback.java
(95%)
rename
adapter/{persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/data/rocketmq/repository
=>
storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/impl}/RocketMQEventDataRepository.java
(91%)
rename
adapter/{persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/data/rocketmq/repository
=>
storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/impl}/RocketMQMetaService.java
(93%)
create mode 100644
adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/RocketMQEventSubscriber.java
create mode 100644
adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/consumer/ClientConfig.java
create mode 100644
adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/consumer/ConsumeRequest.java
create mode 100644
adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/consumer/ExponentialRetryPolicy.java
copy
domain/src/main/java/org/apache/rocketmq/eventbridge/domain/repository/EventBusRepository.java
=>
adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/consumer/LitePullConsumer.java
(55%)
create mode 100644
adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/consumer/LitePullConsumerImpl.java
create mode 100644
adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/consumer/LocalMessageCache.java
copy
adapter/{api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/dto/rule/DisableRuleResponse.java
=>
storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/consumer/RetryPolicy.java}
(79%)
rename {domain/src/main/java/org/apache/rocketmq/eventbridge/domain/common =>
common/src/main/java/org/apache/rocketmq/eventbridge}/enums/ErrorToleranceEnum.java
(95%)
rename {domain/src/main/java/org/apache/rocketmq/eventbridge/domain/common =>
common/src/main/java/org/apache/rocketmq/eventbridge}/enums/PushRetryStrategyEnum.java
(94%)
copy
adapter/rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/impl/connect/dto/TransformRequest.java
=>
common/src/main/java/org/apache/rocketmq/eventbridge/enums/props/Constants.java
(67%)
copy
common/src/{test/java/org/apache/rocketmq/eventbridge/tools/transform/OriginalTransformTest.java
=>
main/java/org/apache/rocketmq/eventbridge/exception/ServiceProviderNotFoundException.java}
(60%)
create mode 100644 docs/CreateFileTarget.md
create mode 100644 docs/EventSource.md
create mode 100644 docs/cn/RocketMQEventBridgeDatabaseUsage.md
create mode 100644 docs/cn/RocketMQEventBridgeRuleValidation.md
create mode 100644 docs/cn/images/demo.png
create mode 100644 docs/cn/images/h2.png
rename domain/src/main/java/org/apache/rocketmq/eventbridge/domain/{repository
=> storage}/EventDataRepository.java (82%)
create mode 100644 infrastructure/README-CN.md
copy {adapter => infrastructure}/pom.xml (60%)
create mode 100644
infrastructure/src/main/java/org/apache/rocketmq/eventbridge/infrastructure/metric/MonitorFactory.java
copy
adapter/rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/config/RpcConfiguration.java
=>
infrastructure/src/main/java/org/apache/rocketmq/eventbridge/infrastructure/trace/TraceException.java
(52%)
copy
common/src/main/java/org/apache/rocketmq/eventbridge/config/GlobalConfig.java
=>
infrastructure/src/main/java/org/apache/rocketmq/eventbridge/infrastructure/trace/TraceStrategy.java
(70%)
create mode 100644
infrastructure/src/main/java/org/apache/rocketmq/eventbridge/infrastructure/trace/ZipkinTraceStrategy.java
copy
adapter/rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/impl/network/NetworkServiceAPIImpl.java
=>
infrastructure/src/main/java/org/apache/rocketmq/eventbridge/infrastructure/validate/AuthValidation.java
(60%)
create mode 100644
infrastructure/src/main/java/org/apache/rocketmq/eventbridge/infrastructure/validate/DefaultAuthValidation.java
create mode 100644
infrastructure/src/main/java/org/apache/rocketmq/eventbridge/infrastructure/validate/spi/ServiceLifecycle.java
create mode 100644
infrastructure/src/main/java/org/apache/rocketmq/eventbridge/infrastructure/validate/spi/ValidationServiceFactory.java
create mode 100644
infrastructure/src/main/java/org/apache/rocketmq/eventbridge/infrastructure/validate/spi/ValidationServiceLoader.java
copy
adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/annotations/WebLog.java
=>
infrastructure/src/main/java/org/apache/rocketmq/eventbridge/infrastructure/validate/spi/annotation/SingletonSPI.java
(84%)
copy
common/src/main/java/org/apache/rocketmq/eventbridge/tools/pattern/PatternType.java
=>
infrastructure/src/main/java/org/apache/rocketmq/eventbridge/infrastructure/validate/spi/typed/TypedSPI.java
(65%)
create mode 100644
infrastructure/src/main/java/org/apache/rocketmq/eventbridge/infrastructure/validate/spi/typed/TypedSPIRegistry.java
copy
adapter/persistence/src/main/resources/db/migration/V3__change_target_transform_type.sql
=>
infrastructure/src/main/resources/META-INF/services/org.apache.rocketmq.eventbridge.infrastructure.validate.AuthValidation
(87%)
copy
common/src/main/java/org/apache/rocketmq/eventbridge/config/AppConfig.java =>
start/src/main/java/org/apache/rocketmq/eventbridge/config/H2ServerConfig.java
(52%)
create mode 100644
start/src/main/java/org/apache/rocketmq/eventbridge/filter/ValidateFilter.java
copy {adapter/rpc => supports/eventbridge-connect-file}/README.md (100%)
copy supports/{connect-eventbridge-transform =>
eventbridge-connect-file}/pom.xml (92%)
copy
adapter/rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/config/RpcConfiguration.java
=>
supports/eventbridge-connect-file/src/main/java/org/apache/rocketmq/connect/sink/FileConstant.java
(51%)
create mode 100644
supports/eventbridge-connect-file/src/main/java/org/apache/rocketmq/connect/sink/FileSinkTask.java
create mode 100644
supports/eventbridge-connect-file/src/test/java/org/apache/rocketmq/connect/FileSinkTaskTest.java
copy {adapter/rpc => supports/eventbridge-connect-standard}/README.md (100%)
copy supports/{connect-eventbridge-transform =>
eventbridge-connect-standard}/pom.xml (92%)
copy
adapter/rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/config/RpcConfiguration.java
=>
supports/eventbridge-connect-standard/src/main/java/org/apache/rocketmq/connect/sink/StandardConstant.java
(51%)
create mode 100644
supports/eventbridge-connect-standard/src/main/java/org/apache/rocketmq/connect/sink/StandardSinkTask.java
copy {adapter/api => test/demo}/pom.xml (90%)
create mode 100644
test/demo/src/main/java/org/apache/rocketmq/eventbridge/demo/DefaultDemo.java
copy {adapter/api =>
test/demo}/src/test/java/org/apache/rocketmq/eventbridge/adapter/api/controller/ApiDestinationDTOControllerTest.java
(99%)
copy {adapter/api =>
test/demo}/src/test/java/org/apache/rocketmq/eventbridge/adapter/api/controller/ConnectionControllerTest.java
(100%)
copy {adapter/api =>
test/demo}/src/test/java/org/apache/rocketmq/eventbridge/adapter/api/converter/EventConverterAdapterTest.java
(100%)
copy {adapter/api =>
test/demo}/src/test/java/org/apache/rocketmq/eventbridge/adapter/api/converter/EventTargetConverterTest.java
(96%)
copy {adapter/api =>
test/demo}/src/test/java/org/apache/rocketmq/eventbridge/adapter/api/converter/EventTargetDTOConverterTest.java
(96%)
copy {adapter/api =>
test/demo}/src/test/java/org/apache/rocketmq/eventbridge/adapter/api/handler/EventDataHandlerTest.java
(100%)
copy {adapter => test}/pom.xml (88%)
