Documentation ¶
Index ¶
- func GetPreV04DagStatusText(status DagStatus) string
- func GetPreV04JobStatusText(status JobStatus) string
- type Dag
- func (dag *Dag) CreateJob(name string, task func() (map[string]string, error)) (*Job, error)
- func (dag *Dag) GetJob(name string) (*Job, error)
- func (dag *Dag) GetJobEdges() ([]Edge, error)
- func (dag *Dag) GetJobs() ([]JobBasics, error)
- func (dag *Dag) JobExists(name string) bool
- func (dag *Dag) Run() error
- func (dag *Dag) ShowJobStatuses() error
- type DagStatus
- type Edge
- type Hooks
- type Job
- type JobBasics
- type JobStatus
- type Logger
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetPreV04DagStatusText ¶ added in v0.4.0
GetPreV04DagStatusText returns the text status code from < v0.4.0. !!!! DO NOT USE THESE IN NEW CODE. !!!! It returns the empty string if the code is unknown.
func GetPreV04JobStatusText ¶ added in v0.4.0
GetPreV04JobStatusText returns the text status code from < v0.4.0. !!!! DO NOT USE THESE IN NEW CODE. !!!! It returns the empty string if the code is unknown.
Types ¶
type Dag ¶
type Dag struct { ID string Name string Jobs map[string]*Job JobsOrder []string Status DagStatus CreatedTs time.Time StartedTs time.Time FinishedTs time.Time Logger Logger // contains filtered or unexported fields }
Dag represents directed acyclic graph
func (*Dag) GetJobEdges ¶
GetJobEdges returns a list of job names
func (*Dag) ShowJobStatuses ¶
type Hooks ¶
type Hooks struct { DagCreated func(dag *Dag) DagStarted func(dag *Dag) DagFinishedSuccess func(dag *Dag) DagFinishedFailed func(dag *Dag) JobCreated func(job *Job) JobStarted func(job *Job) JobFinishedSuccess func(job *Job) JobFinishedFailed func(job *Job) }
Hooks define what happens on certain events like DAG start or JOB finished with error
type Job ¶
type Job struct { ID string Name string DagID string ParentJobs []*Job ChildJobs []*Job Status JobStatus CreatedTs time.Time StartedTs time.Time FinishedTs time.Time Data map[string]string Responses map[string]string Logger Logger Mu sync.RWMutex // contains filtered or unexported fields }
type JobStatus ¶ added in v0.4.0
type JobStatus string
const ( JobStatusNotStarted JobStatus = "JobStatusNotStarted" JobStatusRunning JobStatus = "JobStatusRunning" JobStatusFinishedSuccess JobStatus = "JobStatusFinishedSuccess" JobStatusFinishedConditionNotMet JobStatus = "JobStatusFinishedConditionNotMet" JobStatusFinishedWithSoftError JobStatus = "JobStatusFinishedWithSoftError" JobStatusFinishedWithErrorAsItHasParentsHaveErrors JobStatus = "JobStatusFinishedWithErrorAsItHasParentsHaveErrors" JobStatusFinishedWithError JobStatus = "JobStatusFinishedWithError" )
Click to show internal directories.
Click to hide internal directories.