scheduler

Documentation

Index

• Constants
• Variables
• type Sched
  • func (s *Sched) BatchDelete(ctx context.Context, actions []*spec.PipelineTask) (data interface{}, err error)
  • func (s *Sched) Cancel(ctx context.Context, action *spec.PipelineTask) (data interface{}, err error)
  • func (s *Sched) Create(ctx context.Context, action *spec.PipelineTask) (data interface{}, err error)
  • func (s *Sched) Exist(ctx context.Context, action *spec.PipelineTask) (created, started bool, err error)
  • func (s *Sched) GetTaskExecutor(executorType string, clusterName string, task *spec.PipelineTask) (bool, tasktypes.TaskExecutor, error)
  • func (s *Sched) Inspect(ctx context.Context, action *spec.PipelineTask) (apistructs.TaskInspect, error)
  • func (s *Sched) Kind() types.Kind
  • func (s *Sched) Name() types.Name
  • func (s *Sched) Remove(ctx context.Context, action *spec.PipelineTask) (data interface{}, err error)
  • func (s *Sched) Start(ctx context.Context, action *spec.PipelineTask) (data interface{}, err error)
  • func (s *Sched) Status(ctx context.Context, action *spec.PipelineTask) (desc apistructs.PipelineStatusDesc, err error)
  • func (s *Sched) Update(ctx context.Context, action *spec.PipelineTask) (interface{}, error)

Constants

const (
	OPTION_ADDR = "ADDR"
)

Variables

var Kind = types.Kind(spec.PipelineTaskExecutorKindScheduler)

Types

type Sched

type Sched struct {
	// contains filtered or unexported fields
}

func (*Sched) BatchDelete

func (s *Sched) BatchDelete(ctx context.Context, actions []*spec.PipelineTask) (data interface{}, err error)

func (*Sched) Cancel

func (s *Sched) Cancel(ctx context.Context, action *spec.PipelineTask) (data interface{}, err error)

func (*Sched) Create

func (s *Sched) Create(ctx context.Context, action *spec.PipelineTask) (data interface{}, err error)

func (*Sched) Exist

func (s *Sched) Exist(ctx context.Context, action *spec.PipelineTask) (created, started bool, err error)

Exist 返回 job 存在情况 created: 调用 create 成功，job 在 etcd 中已创建 started: 调用 start 成功，job 在 cluster 中已存在并开始执行

func (*Sched) GetTaskExecutor

func (s *Sched) GetTaskExecutor(executorType string, clusterName string, task *spec.PipelineTask) (bool, tasktypes.TaskExecutor, error)

GetTaskExecutor return bool, task exectuor, error, bool means should it be dispatch to scheduler

func (*Sched) Inspect

func (s *Sched) Inspect(ctx context.Context, action *spec.PipelineTask) (apistructs.TaskInspect, error)

func (*Sched) Kind

func (s *Sched) Kind() types.Kind

func (*Sched) Name

func (s *Sched) Name() types.Name

func (*Sched) Remove

func (s *Sched) Remove(ctx context.Context, action *spec.PipelineTask) (data interface{}, err error)

func (*Sched) Start

func (s *Sched) Start(ctx context.Context, action *spec.PipelineTask) (data interface{}, err error)

func (*Sched) Status

func (s *Sched) Status(ctx context.Context, action *spec.PipelineTask) (desc apistructs.PipelineStatusDesc, err error)

func (*Sched) Update

func (s *Sched) Update(ctx context.Context, action *spec.PipelineTask) (interface{}, error)