jobrun

package
v0.5.0-beta Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 16, 2023 License: Apache-2.0 Imports: 14 Imported by: 0

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 IsFinishedStatus(sts string) bool

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 DAG

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

type Executor

type Executor interface {
	Setup(ctx context.Context) error
	DoOperation(ctx context.Context, step types.WorkflowJobStep) error
	Collect(ctx context.Context) error
	Teardown(ctx context.Context)
}

type Operator

type Operator interface {
	Do(ctx context.Context, param *Parameter) error
}

type Parameter

type Parameter struct {
	FlowID  string
	Workdir string
	Result  *ResultData
}

type ResultData

type ResultData struct {
	Result   sync.Map
	TempData sync.Map
}

type Runner

type Runner interface {
	Start(ctx context.Context) error
	Pause() error
	Resume() error
	Cancel() error
}

func NewRunner

func NewRunner(j *types.WorkflowJob, recorder metastore.ScheduledTaskRecorder) Runner

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL