Versions in this module Expand all Collapse all v1 v1.0.0 May 31, 2024 Changes in this version + type Engine interface + CreateDAG func(name string) (string, error) + DeleteDAG func(name, loc string) error + GetAllStatus func() (statuses []*persistence.DAGStatus, errs []string, err error) + GetCurrentStatus func(dag *dag.DAG) (*model.Status, error) + GetDAGSpec func(id string) (string, error) + GetLatestStatus func(dag *dag.DAG) (*model.Status, error) + GetRecentHistory func(dag *dag.DAG, n int) []*model.StatusFile + GetStatus func(dagLocation string) (*persistence.DAGStatus, error) + GetStatusByRequestId func(dag *dag.DAG, requestId string) (*model.Status, error) + Grep func(pattern string) ([]*persistence.GrepResult, []string, error) + IsSuspended func(id string) bool + Rename func(oldDAGPath, newDAGPath string) error + Restart func(dag *dag.DAG) error + Retry func(dag *dag.DAG, reqId string) error + Start func(dag *dag.DAG, params string) error + StartAsync func(dag *dag.DAG, params string) + Stop func(dag *dag.DAG) error + ToggleSuspend func(id string, suspend bool) error + UpdateDAG func(id string, spec string) error + UpdateStatus func(dag *dag.DAG, status *model.Status) error + type Factory interface + Create func() Engine + func NewFactory(ds persistence.DataStoreFactory, cfg *config.Config) Factory
Go to main page