pipeline

package

v1.0.3 Latest Latest Go to latest Published: Jul 28, 2023 License: GPL-3.0 Imports: 4 Imported by: 1

Details

View Source

const (
	StateNotRun  = State("NotRun")
	StateRunning = State("Running")
	StateDone    = State("Done")
	StateFail    = State("Fail")
)

View Source

var (
	NotRunInstance  = &NotRunStep{}
	RunningInstance = &RunningStep{}
	DoneInstance    = &DoneStep{}
	FailInstance    = &FailStep{}
)

func GetJob(path string) (*model.Job, error)

GetJob 根据文件获取job信息

func GetJobFromReader(reader io.Reader) (*model.Job, error)

GetJobFromReader 根据流获取Job 信息

func GetJobFromYaml(yamlStr string) (*model.Job, error)

type DoneStep struct {
}

DoneStep 完成状态

type FailStep struct {
}

FailStep 失败状态

type IStepState interface {
	// contains filtered or unexported methods
}

type NotRunStep struct {
}

NotRunStep 未开始状态

type RunningStep struct {
}

RunningStep 运行中状态

func NewRunningStep() *RunningStep

type State string

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

func InitialStepStateMachine() *StepMachine

func (s *StepMachine) Run()

func (s *StepMachine) State() State