scheduler

type Contract interface {
	Run(ctx context.Context)    // 运行调度器
	DispatchEvent(event *Event) // 分发事件

	ResultHandler(result *models.Result) // 调度结果处理
	// contains filtered or unexported methods
}

type Event struct {
	Type     int              // 事件类型
	Pipeline *models.Pipeline // 流水线
}

type Scheduler struct {
	EventsChan chan *Event                 // 事件通道
	ResultChan chan *models.Result         // 执行结果通道
	Plan       map[string]*models.Pipeline // 调度计划
	Running    map[string]*models.Pipeline // 正在运行的流水线
}