Documentation ¶
Index ¶
Constants ¶
View Source
const ( InitializingStatus = "initializing" RunningStatus = "running" SucceedStatus = "succeed" FailedStatus = "failed" ErrorStatus = "error" PausedStatus = "paused" CanceledStatus = "canceled" TriggerEvent = "flow.execute.trigger" ExecuteFinishEvent = "flow.execute.finish" ExecuteFailedEvent = "flow.execute.failed" ExecuteErrorEvent = "flow.execute.error" ExecutePauseEvent = "flow.execute.pause" ExecuteResumeEvent = "flow.execute.resume" ExecuteCancelEvent = "flow.execute.cancel" )
Variables ¶
View Source
var (
ExecutorNotFound = errors.New("executor not found")
)
Functions ¶
func IsFinishedStatus ¶
func RegisterExecutorBuilder ¶
func RegisterExecutorBuilder(name string, builder func(job *types.WorkflowJob) Executor)
Types ¶
type Controller ¶
type Controller struct {
// contains filtered or unexported fields
}
func NewJobController ¶
func NewJobController(recorder metastore.ScheduledTaskRecorder, notify *notify.Notify) *Controller
func (*Controller) CancelJob ¶
func (c *Controller) CancelJob(jID string) error
func (*Controller) PauseJob ¶
func (c *Controller) PauseJob(jID string) error
func (*Controller) ResumeJob ¶
func (c *Controller) ResumeJob(jID string) error
func (*Controller) Shutdown ¶
func (c *Controller) Shutdown() error
func (*Controller) TriggerJob ¶
func (c *Controller) TriggerJob(jID string, timeout time.Duration) error
type Parameter ¶
type Parameter struct { FlowID string Workdir string Result *ResultData }
Click to show internal directories.
Click to hide internal directories.