graph G { compound="true" rankdir="TB" bgcolor="white" fontname="Tahoma" node [ fixedsize="false" fontname="Tahoma" color="white" fillcolor="deepskyblue2" fontcolor="black" shape="box" style="filled" penwidth="1.0" ] edge [ fontname="Arial" color="#00688b" fontcolor="black" fontsize="12" arrowsize="0.5" penwidth="1.0" ] "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/EventTargetTrigger.java]" -- "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/EventRuleTransfer.java]" [label=" 5 ", penwidth="5", color="#00688bA5"]; "[domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/connection/ConnectionService.java]" -- "[domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/apidestination/ApiDestinationService.java]" [label=" 4 ", penwidth="4", color="#00688b93"]; "[adapter/persistence/src/main/resources/db/migration/V6__register_target_acs_eventbridge.sql]" -- "[adapter/persistence/src/main/resources/db/migration/V5__register_target_acs_dingtalk.sql]" [label=" 4 ", penwidth="4", color="#00688b93"]; "[adapter/persistence/src/main/resources/db/migration/V8__update_unique_key.sql]" -- "[adapter/persistence/src/main/resources/db/migration/V7__update_event_connection_table_structure.sql]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[domain/src/main/java/org/apache/rocketmq/eventbridge/domain/storage/EventDataRepository.java]" -- "[adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/impl/RocketMQEventDataRepository.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/common/CirculatorContext.java]" -- "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/EventTargetTrigger.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/persistence/src/main/resources/db/migration/V7__update_event_connection_table_structure.sql]" -- "[adapter/persistence/src/main/resources/db/migration/V5__register_target_acs_dingtalk.sql]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/persistence/src/main/resources/db/migration/V3__change_target_transform_type.sql]" -- "[adapter/persistence/src/main/resources/db/migration/V1__baseline.sql]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/persistence/src/main/resources/db/migration/V7__update_event_connection_table_structure.sql]" -- "[adapter/persistence/src/main/resources/db/migration/V3__change_target_transform_type.sql]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/persistence/src/main/resources/db/migration/V2__baseline.sql]" -- "[adapter/persistence/src/main/resources/db/migration/V5__register_target_acs_dingtalk.sql]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/persistence/src/main/resources/db/migration/V8__update_unique_key.sql]" -- "[adapter/persistence/src/main/resources/db/migration/V5__register_target_acs_dingtalk.sql]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/persistence/src/main/resources/db/migration/V2__baseline.sql]" -- "[adapter/persistence/src/main/resources/db/migration/V6__register_target_acs_eventbridge.sql]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/dto/apidestination/ListApiDestinationsRequest.java]" -- "[adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/controller/ApiDestinationController.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/persistence/src/main/resources/db/migration/V1__baseline.sql]" -- "[adapter/persistence/src/main/resources/db/migration/V6__register_target_acs_eventbridge.sql]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/persistence/src/main/resources/db/migration/V7__update_event_connection_table_structure.sql]" -- "[adapter/persistence/src/main/resources/db/migration/V6__register_target_acs_eventbridge.sql]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/service/TargetRunnerConfigOnDBObserver.java]" -- "[adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/RocketMQEventSubscriber.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/consumer/LocalMessageCache.java]" -- "[adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/consumer/LitePullConsumerImpl.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/persistence/src/main/resources/db/migration/V8__update_unique_key.sql]" -- "[adapter/persistence/src/main/resources/db/migration/V3__change_target_transform_type.sql]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/connection/ConnectionService.java]" -- "[adapter/persistence/src/main/resources/mybatis/EventConnectionMapper.xml]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/persistence/src/main/resources/db/migration/V3__change_target_transform_type.sql]" -- "[adapter/persistence/src/main/resources/db/migration/V6__register_target_acs_eventbridge.sql]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/RocketMQEventSubscriber.java]" -- "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/EventRuleTransfer.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/persistence/src/main/resources/db/migration/V7__update_event_connection_table_structure.sql]" -- "[adapter/persistence/src/main/resources/db/migration/V2__baseline.sql]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/persistence/src/main/resources/db/migration/V3__change_target_transform_type.sql]" -- "[adapter/persistence/src/main/resources/db/migration/V5__register_target_acs_dingtalk.sql]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/persistence/src/main/resources/db/migration/V3__change_target_transform_type.sql]" -- "[adapter/persistence/src/main/resources/db/migration/V2__baseline.sql]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/Runtime.java]" -- "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/EventTargetTrigger.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/Runtime.java]" -- "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/EventRuleTransfer.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/EventTargetTrigger.java]" -- "[adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/RocketMQEventSubscriber.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/persistence/src/main/resources/db/migration/V8__update_unique_key.sql]" -- "[adapter/persistence/src/main/resources/db/migration/V6__register_target_acs_eventbridge.sql]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/dto/apidestination/UpdateApiDestinationRequest.java]" -- "[adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/dto/apidestination/CreateApiDestinationRequest.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/persistence/src/main/resources/db/migration/V2__baseline.sql]" -- "[adapter/persistence/src/main/resources/db/migration/V1__baseline.sql]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/persistence/src/main/resources/db/migration/V8__update_unique_key.sql]" -- "[adapter/persistence/src/main/resources/db/migration/V1__baseline.sql]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/common/CirculatorContext.java]" -- "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/EventRuleTransfer.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/persistence/src/main/resources/db/migration/V1__baseline.sql]" -- "[adapter/persistence/src/main/resources/db/migration/V5__register_target_acs_dingtalk.sql]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/persistence/src/main/resources/db/migration/V7__update_event_connection_table_structure.sql]" -- "[adapter/persistence/src/main/resources/db/migration/V1__baseline.sql]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/persistence/src/main/resources/db/migration/V8__update_unique_key.sql]" -- "[adapter/persistence/src/main/resources/db/migration/V2__baseline.sql]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/controller/ConnectionController.java]" -- "[adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/dto/apidestination/ListApiDestinationsRequest.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/apidestination/ApiDestinationService.java]" -- "[adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/dto/connection/CreateConnectionRequest.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[domain/src/main/java/org/apache/rocketmq/eventbridge/domain/repository/ApiDestinationRepository.java]" -- "[domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/connection/ConnectionService.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/controller/ConnectionController.java]" -- "[domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/apidestination/ApiDestinationService.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/common/CirculatorContext.java]" -- "[adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/RocketMQEventSubscriber.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/connection/ConnectionService.java]" -- "[adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/dto/connection/CreateConnectionRequest.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[adapter/persistence/src/main/resources/mybatis/EventConnectionMapper.xml]" -- "[adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/connect/mybatis/mapper/EventConnectionMapper.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[infrastructure/src/main/java/org/apache/rocketmq/eventbridge/infrastructure/validate/DefaultAuthValidation.java]" -- "[adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/impl/RocketMQEventDataRepository.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/dto/connection/UpdateConnectionRequest.java]" -- "[adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/dto/connection/CreateConnectionRequest.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/consumer/ClientConfig.java]" -- "[adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/consumer/LocalMessageCache.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/impl/RocketMQEventDataRepository.java]" -- "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/EventRuleTransfer.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/dto/connection/UpdateConnectionRequest.java]" -- "[adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/dto/apidestination/CreateApiDestinationRequest.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[adapter/persistence/src/main/resources/mybatis/EventConnectionMapper.xml]" -- "[adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/apidestination/mybatis/mapper/EventApiDestinationMapper.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/EventBusListener.java]" -- "[adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/RocketMQEventSubscriber.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/controller/ApiDestinationController.java]" -- "[domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/connection/ConnectionService.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; }