This is an automated email from the ASF dual-hosted git repository.
shenlin pushed a change to branch runtimer
in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git
from d03c361 1.merge h2-migration and migration
new 9fbd32d feat:add runtime demo.
new c6d5b8d feat:add runtime demo.
new 7715cb4 feat:add runtime demo.
new b2ee9b2 feat:add runtime demo.
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
README.md | 217 +++------------------
.../adapter/api/controller/EventBusController.java | 2 +-
.../adapter/api/dto/bus/ListEventBusesRequest.java | 2 +-
.../adapter/persistence/FlywayConfig.java} | 39 ++--
.../MybatisEventTargetRunnerRepository.java | 3 -
.../migration/V5__register_target_acs_dingtalk.sql | 22 ++-
.../V6__register_target_acs_eventbridge.sql | 41 +++-
.../db/migration/V9__init_file_target_class.sql | 31 ++-
.../adapter/runtime/boot/EventRuleTransfer.java | 53 +++--
.../adapter/runtime/boot/EventTargetTrigger.java | 2 +-
.../runtime/config/RuntimeConfiguration.java | 8 +-
.../service/TargetRunnerConfigOnDBObserver.java | 17 +-
.../service/TargetRunnerConfigOnFileObserver.java | 2 +-
.../rocketmq/impl/RocketMQEventDataRepository.java | 10 +-
.../rocketmq/runtimer/RocketMQEventSubscriber.java | 12 +-
docs/CreateFileTarget.md | 51 +++++
docs/EventSource.md | 42 ++++
docs/cn/images/demo.png | Bin 0 -> 49258 bytes
.../domain/storage/EventDataRepository.java | 7 +
.../validate/DefaultAuthValidation.java | 2 +-
pom.xml | 12 ++
start/pom.xml | 4 +
.../java/org/apache/rocketmq/eventbridge/Main.java | 3 +-
start/src/main/resources/application.properties | 11 +-
.../README.md | 0
.../pom.xml | 4 +-
.../apache/rocketmq/connect/sink/FileConstant.java | 7 +-
.../rocketmq/connect/sink/FileSinkTask.java} | 39 +++-
.../apache/rocketmq/connect/FileSinkTaskTest.java} | 46 ++---
.../eventbridge-connect-standard}/README.md | 0
.../pom.xml | 4 +-
.../rocketmq/connect/sink/StandardConstant.java | 7 +-
.../rocketmq/connect/sink}/StandardSinkTask.java | 8 +-
{adapter/api => test/demo}/pom.xml | 13 +-
.../rocketmq/eventbridge/demo/DefaultDemo.java | 105 ++++++++++
.../ApiDestinationDTOControllerTest.java | 0
.../api/controller/ConnectionControllerTest.java | 0
.../api/converter/EventConverterAdapterTest.java | 0
.../api/converter/EventTargetConverterTest.java | 0
.../api/converter/EventTargetDTOConverterTest.java | 0
.../adapter/api/handler/EventDataHandlerTest.java | 0
{adapter => test}/pom.xml | 8 +-
42 files changed, 491 insertions(+), 343 deletions(-)
copy
adapter/{runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/common/OffsetManager.java
=>
persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/FlywayConfig.java}
(54%)
copy
common/src/main/java/org/apache/rocketmq/eventbridge/enums/props/Constants.java
=>
adapter/persistence/src/main/resources/db/migration/V9__init_file_target_class.sql
(59%)
create mode 100644 docs/CreateFileTarget.md
create mode 100644 docs/EventSource.md
create mode 100644 docs/cn/images/demo.png
rename supports/{connect-standard => eventbridge-connect-file}/README.md (100%)
copy supports/{connect-standard => eventbridge-connect-file}/pom.xml (98%)
copy
adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/trace/TraceConstants.java
=>
supports/eventbridge-connect-file/src/main/java/org/apache/rocketmq/connect/sink/FileConstant.java
(86%)
copy
supports/{connect-standard/src/main/java/org/apache/rocketmq/connect/StandardSinkTask.java
=>
eventbridge-connect-file/src/main/java/org/apache/rocketmq/connect/sink/FileSinkTask.java}
(53%)
copy
supports/{connect-standard/src/main/java/org/apache/rocketmq/connect/StandardSinkTask.java
=>
eventbridge-connect-file/src/test/java/org/apache/rocketmq/connect/FileSinkTaskTest.java}
(56%)
copy {adapter/rpc => supports/eventbridge-connect-standard}/README.md (100%)
rename supports/{connect-standard => eventbridge-connect-standard}/pom.xml
(98%)
copy
adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/hook/StartAndShutdown.java
=>
supports/eventbridge-connect-standard/src/main/java/org/apache/rocketmq/connect/sink/StandardConstant.java
(85%)
rename supports/{connect-standard/src/main/java/org/apache/rocketmq/connect =>
eventbridge-connect-standard/src/main/java/org/apache/rocketmq/connect/sink}/StandardSinkTask.java
(85%)
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
(100%)
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
(100%)
copy {adapter/api =>
test/demo}/src/test/java/org/apache/rocketmq/eventbridge/adapter/api/converter/EventTargetDTOConverterTest.java
(100%)
copy {adapter/api =>
test/demo}/src/test/java/org/apache/rocketmq/eventbridge/adapter/api/handler/EventDataHandlerTest.java
(100%)
copy {adapter => test}/pom.xml (84%)
