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" ] "[eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/utils/ParamType.java]" -- "[eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/db/service/impl/EventMeshMonitorServiceImpl.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/utils/RSAUtils.java]" -- "[eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/service/job/JobInfoBizService.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/JobState.java]" -- "[eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/config/MybatisPlusConfig.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/service/position/impl/MysqlPositionHandler.java]" -- "[eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/AdminServerProperties.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/service/position/impl/HttpPositionHandler.java]" -- "[eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/db/mapper/EventMeshMonitorMapper.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/db/service/EventMeshMonitorService.java]" -- "[eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/HttpServer.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/service/position/impl/MysqlPositionHandler.java]" -- "[eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/service/position/impl/HttpPositionHandler.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/EventMeshTcp2Client.java]" -- "[eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/AbstractTCPServer.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/source/table/RdbTableMgr.java]" -- "[eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/sink/connector/CanalSinkCheckConnector.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/service/position/impl/HttpPositionHandler.java]" -- "[eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/db/service/impl/EventMeshTaskInfoServiceImpl.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/utils/RSAUtils.java]" -- "[eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/db/DruidDataSource.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/response/CreateTaskResponse.java]" -- "[eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/response/BaseRemoteResponse.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/constants/AdminServerConstants.java]" -- "[eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/ExampleAdminServer.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/response/HttpResponseResult.java]" -- "[eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/constants/AdminServerConstants.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/service/task/TaskBizService.java]" -- "[eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/AdminServerProperties.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/monitor/Monitor.java]" -- "[eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/monitor/AbstractConnectorMonitor.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/push/SessionPusher.java]" -- "[eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/processor/HelloProcessor.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util/Utils.java]" -- "[eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/processor/MessageTransferProcessor.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/utils/Base64.java]" -- "[eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/db/service/EventMeshMonitorService.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/response/QueryTaskInfoResponse.java]" -- "[eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/db/service/EventMeshMonitorService.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/utils/RSAUtils.java]" -- "[eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/pojo/BinlogPosition.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/sink/connector/CanalSinkIncrementConnector.java]" -- "[eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/rdb/canal/CanalSourceIncrementConfig.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[eventmesh-runtime-v2/src/main/java/org/apache/eventmesh/runtime/util/RuntimeUtils.java]" -- "[eventmesh-runtime-v2/src/main/java/org/apache/eventmesh/runtime/service/monitor/MonitorService.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/service/monitor/MonitorBizService.java]" -- "[eventmesh-admin-server/conf/eventmesh.sql]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/rdb/canal/mysql/MySQLTableDef.java]" -- "[eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/rdb/canal/CanalSourceIncrementConfig.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/sink/connector/CanalSinkFullConnector.java]" -- "[eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/rdb/canal/CanalSinkIncrementConfig.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/source/connector/CanalSourceCheckConnector.java]" -- "[eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/rdb/canal/CanalSourceCheckConfig.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/utils/EncryptUtil.java]" -- "[eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/service/job/JobInfoBizService.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/db/service/impl/EventMeshTaskInfoServiceImpl.java]" -- "[eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/constants/AdminServerConstants.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/request/TaskBachRequest.java]" -- "[eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/handler/impl/ReportJobRequestHandler.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/handler/impl/ReportVerifyHandler.java]" -- "[eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/handler/impl/ReportJobRequestHandler.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/response/CreateTaskResponse.java]" -- "[eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/utils/RSAUtils.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/service/position/IRecordPositionHandler.java]" -- "[eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/db/DruidDataSource.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/service/task/TaskBizService.java]" -- "[eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/db/service/impl/EventMeshMonitorServiceImpl.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/source/EntryParser.java]" -- "[eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/interceptor/SqlBuilderLoadInterceptor.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/response/CreateTaskResponse.java]" -- "[eventmesh-admin-server/conf/log4j2.xml]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/response/HttpResponseResult.java]" -- "[eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/pojo/TaskDetail.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/source/connector/CanalFullProducer.java]" -- "[eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/source/EntryParser.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[eventmesh-connectors/eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/source/protocol/impl/CloudEventProtocol.java]" -- "[eventmesh-connectors/eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/sink/handler/impl/CommonHttpSinkHandler.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/db/service/impl/EventMeshTaskInfoServiceImpl.java]" -- "[eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/db/service/EventMeshMonitorService.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/response/QueryTaskMonitorResponse.java]" -- "[eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/response/HttpResponseResult.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/handler/impl/ReportJobRequestHandler.java]" -- "[eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/AdminServerProperties.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/service/position/IRecordPositionHandler.java]" -- "[eventmesh-admin-server/conf/log4j2.xml]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/datasource/DataSourceType.java]" -- "[eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/datasource/DataSourceDriverType.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/service/position/impl/MysqlPositionHandler.java]" -- "[eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/pojo/BinlogPosition.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/service/position/IRecordPositionHandler.java]" -- "[eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/handler/impl/ReportJobRequestHandler.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[eventmesh-connectors/eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/sink/handler/HttpDeliveryStrategy.java]" -- "[eventmesh-connectors/eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/sink/HttpSinkConnector.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/rdb/canal/JobRdbFullPosition.java]" -- "[eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/rdb/canal/CanalSourceFullConfig.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[eventmesh-meta/eventmesh-meta-raft/src/main/java/org/apache/eventmesh/meta/raft/serialize/EventMeshSerializerFactory.java]" -- "[eventmesh-meta/eventmesh-meta-raft/src/main/java/org/apache/eventmesh/meta/raft/serialize/EventMeshHessianSerializer.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/handler/impl/ReportJobRequestHandler.java]" -- "[eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/db/entity/EventMeshWeredisPosition.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; }