runner

type CancelRequest struct {
	Step *pipeline.Step
}

type ConnectRequest struct {
	Step              *pipeline.Step
	Stdin             io.Reader
	Stdout            io.Writer
	Stderr            io.Writer
	Tty               bool
	TerminalSizeQueue TerminalSizeQueue
}

type LogRequest struct {
	Step *pipeline.Step
}

type RunRequest struct {
	RunnerParams map[string]string   // runner 运行需要的参数
	RunParams    map[string]string   // step 运行需要的参数
	Mount        *pipeline.MountData // 挂载文件
	Step         *pipeline.Step      // 具体step
}

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

type Runner interface {
	// 执行Step, 执行过后的关联信息保存在Status的Response里面
	Run(context.Context, *RunRequest, *RunResponse)
	// 连接到该执行环境
	Connect(context.Context, *ConnectRequest) error
	// 取消Step的执行
	Cancel(context.Context, *CancelRequest)
}

type TerminalSize struct {
	Width  uint16
	Height uint16
}

type TerminalSizeQueue interface {
	// Next returns the new terminal size after the terminal has been resized. It returns nil when
	// monitoring has been stopped.
	Next() *TerminalSize
}

type UpdateStepCallback func(*pipeline.Step)