dispatcher

type Dispatcher struct {
	Channel         chan model2.QueueMessage
	CallbackChannel chan model2.StatusChangeMessage
	// contains filtered or unexported fields
}

type HttpDispatcher struct {
	Channel chan model2.QueueMessage
	// contains filtered or unexported fields
}

type IDispatcher interface {
	// DispatchNode 选择节点
	DispatchNode(job *model2.Job) *model2.Node
	// Register 节点注册
	Register(node *model2.Node)
	// UnRegister 节点注销
	UnRegister(node *model2.Node)

	// HealthcheckNode 节点心跳
	HealthcheckNode(node *model2.Node)

	// SendJob 发送任务
	SendJob(job *model2.JobDetail, node *model2.Node)

	// CancelJob 取消任务
	CancelJob(job *model2.JobDetail, node *model2.Node)

	// GetExecutor 根据节点获取执行器
	// TODO ... 这个方法设计的不好，分布式机构后应当用api代替
	GetExecutor(node *model2.Node) executor.IExecutor
}