engine

Jul 14, 2024

Changes in this version

+ type DAGStatus struct

+ DAG *dag.DAG

+ Dir string

+ Error error

+ ErrorT *string

+ File string

+ Status *model.Status

+ Suspended bool

type Engine

+ func New(args *NewEngineArgs) Engine

+ GetStatusByRequestID func(dg *dag.DAG, reqID string) (*model.Status, error)

+ type NewEngineArgs struct

+ DataStore persistence.DataStores

+ Executable string

+ WorkDir string

Sep 10, 2023

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