checkFlow

开启异步协程处理http请求

store

JobManager&TaskManager

控制台发起check

注册校验的http handler

初始化tskMgrServer、初始化为slave、开始竞选leader、当选leader后开启jobMgrServer、在startJobMgr中注册TaskScheduler并开启异步协程scheduler

run、访问数据库、开始执行task的注册步骤并根据执行结果来决定下一步执行的任务

注册执行器

checkHandler接手开始处理该次请求，自己不是master的话就会执行转发操作、将相应的信息保存到loacljobrunner中、并注册其执行步骤、保存到数据库

根据不同的状态调用不同的处理函数，比如选择执行器并在新的进程中执行用户的程序。扭转task的状态机

异步协程开始scheduler调度

DB

check的步骤包括：proxy、conntest、check、query；其中check和query需要将请求发给jobexeplat来执行

通过taskmgrclient将请求送到该任务关联的execnode节点

process处理、生成或者重构migrate_job调用asyCheck、调用submittask、保存到数据库、根据taskname和注册的flow生成函数生成具体的task、初始化task的执行步骤、保存到数据库

ExecNode

load

反射调用

注册不同命令的handler并开启异步协程开始消费chan中的数据、并将数据交给handler处理。收到tskmsgchan中的数据时将其交给对应的task的cmdchan

run、访问数据库、开始执行task的注册步骤并更改task的状态扭转

NewDtsPlatform

注册check flow的生成函数

初始化node的管理数据结构并启动节点、初始化etcd并创建接收taskmanager命令的两个chan：tskmsgchan和ctrlmsgchan

执行步骤为prepare，前端不同的任务类型产生不同的任务：如check，到resource/dts/d_mysql/r_mysql/check目录下读取job.json文件\"check\