pipeline

Documentation

Index

• type Controller
  • func NewPipelineController(schedulerName string, nodeStore cache.Store, pi informer.Informer, ...) *Controller
  • func (c *Controller) AsyncRun(ctx context.Context) error
  • func (c *Controller) Debug(log logger.Logger)
  • func (c *Controller) Run(ctx context.Context) error
  • func (c *Controller) SetPipelinePicker(picker algorithm.PipelinePicker)
  • func (c *Controller) UpdateStepCallback(old, new *pipeline.Step)

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) AsyncRun

func (c *Controller) AsyncRun(ctx context.Context) error

func (*Controller) Debug

func (c *Controller) Debug(log logger.Logger)

func (*Controller) Run

func (c *Controller) Run(ctx context.Context) error

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