pipeline

type BaseJob struct {
	Id         string            `json:"jobID"`
	Name       string            `json:"name"`       // step名字，不同run的不同step，必须拥有不同名字
	Command    string            `json:"command"`    // 区别于step，是替换后的，可以直接运行
	Parameters map[string]string `json:"parameters"` // 区别于step，是替换后的，可以直接运行
	Artifacts  schema.Artifacts  `json:"artifacts"`  // 区别于step，是替换后的，可以直接运行
	Env        map[string]string `json:"env"`
	StartTime  string            `json:"startTime"`
	EndTime    string            `json:"endTime"`
	Status     schema.JobStatus  `json:"status"`
	Deps       string            `json:"deps"`
	Message    string            `json:"message"`
}

type BaseWorkflow struct {
	Name   string                 `json:"name,omitempty"`
	RunID  string                 `json:"runId,omitempty"`
	Desc   string                 `json:"desc,omitempty"`
	Entry  string                 `json:"entry,omitempty"`
	Params map[string]interface{} `json:"params,omitempty"`
	Extra  map[string]string      `json:"extra,omitempty"` // 可以存放一些ID，fsId，userId等
	Source schema.WorkflowSource  `json:"-"`               // Yaml string
	// contains filtered or unexported fields
}

type CacheCalculator interface {

	// 计算第一层 fingerprint
	CalculateFirstFingerprint() (fingerprint string, err error)

	// 计算 第二层 fingerprint
	CalculateSecondFingerprint() (fingerprint string, err error)
	// contains filtered or unexported methods
}

type DictParam struct {
	Type    string
	Default interface{}
}

type Job interface {
	Job() BaseJob
	Update(cmd string, params map[string]string, envs map[string]string, artifacts *schema.Artifacts) error
	Validate() error
	Start() (string, error)
	Stop() error
	Check() (schema.JobStatus, error)
	Watch(chan WorkflowEvent) error
	Started() bool
	Succeeded() bool
	Failed() bool
	Terminated() bool
	Skipped() bool
	NotEnded() bool
}

type LocalJob struct {
	BaseJob
	Pid string
}

type PaddleFlowJob struct {
	BaseJob
	Image string
}

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

type StatusToSteps struct {
	SucceededSteps  map[string]*Step
	FailedSteps     map[string]*Step
	TerminatedSteps map[string]*Step
	CanelledSteps   map[string]*Step
	SkippedSteps    map[string]*Step

	// runtime 已经向 step的 ready channel 发送了数据, 同时 Step 尚未处于终态
	SubmittedSteps map[string]*Step

	// runtime 还未向 step 的 ready channel 发送数据， 同时 Step 也未处于终态
	UnsubmittedSteps map[string]*Step
}

type Step struct {
	CacheRunID string
	// contains filtered or unexported fields
}

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

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

type WfEventType string

type WfEventValue string

type Workflow struct {
	BaseWorkflow
	// contains filtered or unexported fields
}

type WorkflowCallbacks struct {
	GetJobCb      func(runID string, stepName string) (schema.JobView, error)
	UpdateRunCb   func(string, interface{}) bool
	LogCacheCb    func(req schema.LogRunCacheRequest) (string, error)
	ListCacheCb   func(firstFp, fsID, step, yamlPath string) ([]models.RunCache, error)
	LogArtifactCb func(req schema.LogRunArtifactRequest) error
}

type WorkflowEvent struct {
	Type    WfEventType
	Event   WfEventValue
	Message string
	Extra   map[string]interface{}
}

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