Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Controller ¶
type Controller struct {
// contains filtered or unexported fields
}
PipelineTaskScheduler 调度器控制器
func NewPipelineController ¶
func NewPipelineController( schedulerName string, nodeStore cache.Store, pi informer.Informer, si step.Informer, ) *Controller
NewPipelineController pipeline controller
func (*Controller) Debug ¶
func (c *Controller) Debug(log logger.Logger)
func (*Controller) SetPipelinePicker ¶
func (c *Controller) SetPipelinePicker(picker algorithm.PipelinePicker)
SetPicker 设置Node挑选器
func (*Controller) UpdateStepCallback ¶
func (c *Controller) UpdateStepCallback(old, new *pipeline.Step)
step 如果完成后, 将状态记录到Pipeline上, 并删除step
Source Files
Click to show internal directories.
Click to hide internal directories.