Versions in this module Expand all Collapse all v1 v1.0.6 Nov 4, 2024 Changes in this version + type Client interface + CreateDAG func(id string) (string, error) + DeleteDAG func(id, loc string) error + GetAllStatus func() (statuses []*DAGStatus, errs []string, err error) + GetAllStatusPagination func(params dags.ListDagsParams) ([]*DAGStatus, *DagListPaginationSummaryResult, error) + GetCurrentStatus func(workflow *dag.DAG) (*model.Status, error) + GetDAGSpec func(id string) (string, error) + GetLatestStatus func(workflow *dag.DAG) (*model.Status, error) + GetRecentHistory func(workflow *dag.DAG, n int) []*model.StatusFile + GetStatus func(dagLocation string) (*DAGStatus, error) + GetStatusByRequestID func(workflow *dag.DAG, requestID string) (*model.Status, error) + GetTagList func() ([]string, []string, error) + Grep func(pattern string) ([]*persistence.GrepResult, []string, error) + IsSuspended func(id string) bool + Rename func(oldID, newID string) error + Restart func(workflow *dag.DAG, opts RestartOptions) error + Retry func(workflow *dag.DAG, requestID string) error + Start func(workflow *dag.DAG, opts StartOptions) error + StartAsync func(workflow *dag.DAG, opts StartOptions) + Stop func(workflow *dag.DAG) error + ToggleSuspend func(id string, suspend bool) error + UpdateDAG func(id string, spec string) error + UpdateStatus func(workflow *dag.DAG, status *model.Status) error + func New(dataStore persistence.DataStores, executable string, workDir string, ...) Client + type DAGStatus struct + DAG *dag.DAG + Dir string + Error error + ErrorT *string + File string + Status *model.Status + Suspended bool + type DagListPaginationSummaryResult struct + ErrorList []string + PageCount int + type RestartOptions struct + Quiet bool + type StartOptions struct + Params string + Quiet bool
Go to main page