workflow

Documentation

Index

• Constants
• type CronHandler
  • func (c *CronHandler) Register(wf *types.WorkflowSpec) error
  • func (c *CronHandler) Start(ctx context.Context)
  • func (c *CronHandler) Unregister(wfID string)
• type JobAttr
• type Manager
  • func NewManager(entryMgr dentry.Manager, docMgr document.Manager, notify *notify.Notify, ...) (Manager, error)

Constants

const (
	BuildInWorkflowSummary = "buildin.summary"
	BuildInWorkflowIngest  = "buildin.ingest"
	BuildInWorkflowWebpack = "buildin.webpack"
)

Types

type CronHandler

type CronHandler struct {
	*cron.Cron
	// contains filtered or unexported fields
}

func (*CronHandler) Register

func (c *CronHandler) Register(wf *types.WorkflowSpec) error

func (*CronHandler) Start

func (c *CronHandler) Start(ctx context.Context)

func (*CronHandler) Unregister

func (c *CronHandler) Unregister(wfID string)

type JobAttr

type JobAttr struct {
	JobID   string
	Reason  string
	Queue   string
	Timeout time.Duration
}

type Manager

type Manager interface {
	Start(stopCh chan struct{})

	ListWorkflows(ctx context.Context) ([]*types.WorkflowSpec, error)
	GetWorkflow(ctx context.Context, wfId string) (*types.WorkflowSpec, error)
	CreateWorkflow(ctx context.Context, spec *types.WorkflowSpec) (*types.WorkflowSpec, error)
	UpdateWorkflow(ctx context.Context, spec *types.WorkflowSpec) (*types.WorkflowSpec, error)
	DeleteWorkflow(ctx context.Context, wfId string) error
	ListJobs(ctx context.Context, wfId string) ([]*types.WorkflowJob, error)
	GetJob(ctx context.Context, wfId string, jobID string) (*types.WorkflowJob, error)

	TriggerWorkflow(ctx context.Context, wfId string, tgt types.WorkflowTarget, attr JobAttr) (*types.WorkflowJob, error)
	PauseWorkflowJob(ctx context.Context, jobId string) error
	ResumeWorkflowJob(ctx context.Context, jobId string) error
	CancelWorkflowJob(ctx context.Context, jobId string) error
}

func NewManager

func NewManager(entryMgr dentry.Manager, docMgr document.Manager, notify *notify.Notify, recorder metastore.ScheduledTaskRecorder, cfg config.Loader) (Manager, error)