controller

Documentation

Index

• func CreateDAG(file string) error
• func MoveDAG(oldDAGPath, newDAGPath string) error
• type DAGController
  • func NewDAGController(d *dag.DAG) *DAGController
  • func (dc *DAGController) DeleteDAG() error
  • func (dc *DAGController) GetLastStatus() (*models.Status, error)
  • func (dc *DAGController) GetRecentStatuses(n int) []*models.StatusFile
  • func (dc *DAGController) GetStatus() (*models.Status, error)
  • func (dc *DAGController) GetStatusByRequestId(requestId string) (*models.Status, error)
  • func (dc *DAGController) Restart(bin string, workDir string) error
  • func (dc *DAGController) Retry(binPath string, workDir string, reqId string) (err error)
  • func (dc *DAGController) Start(binPath string, workDir string, params string) error
  • func (dc *DAGController) StartAsync(binPath string, workDir string, params string)
  • func (dc *DAGController) Stop() error
  • func (dc *DAGController) UpdateDAGSpec(value string) error
  • func (dc *DAGController) UpdateStatus(status *models.Status) error
• type DAGStatus
• type DAGStatusReader
  • func NewDAGStatusReader() *DAGStatusReader
  • func (dr *DAGStatusReader) ReadAllStatus(DAGsDir string) (statuses []*DAGStatus, errs []string, err error)
  • func (dr *DAGStatusReader) ReadStatus(dagLocation string, loadMetadataOnly bool) (*DAGStatus, error)
• type GrepResult
  • func GrepDAG(dir string, pattern string) (ret []*GrepResult, errs []string, err error)

Functions

func CreateDAG

func CreateDAG(file string) error

CreateDAG creates a new DAG.

func MoveDAG

func MoveDAG(oldDAGPath, newDAGPath string) error

MoveDAG moves the DAG file.

Types

type DAGController

type DAGController struct {
	*dag.DAG
}

DAGController is a object to interact with a DAG.

func NewDAGController

func NewDAGController(d *dag.DAG) *DAGController

func (*DAGController) DeleteDAG

func (dc *DAGController) DeleteDAG() error

func (*DAGController) GetLastStatus

func (dc *DAGController) GetLastStatus() (*models.Status, error)

func (*DAGController) GetRecentStatuses

func (dc *DAGController) GetRecentStatuses(n int) []*models.StatusFile

func (*DAGController) GetStatus

func (dc *DAGController) GetStatus() (*models.Status, error)

func (*DAGController) GetStatusByRequestId

func (dc *DAGController) GetStatusByRequestId(requestId string) (*models.Status, error)

func (*DAGController) Restart

func (dc *DAGController) Restart(bin string, workDir string) error

func (*DAGController) Retry

func (dc *DAGController) Retry(binPath string, workDir string, reqId string) (err error)

func (*DAGController) Start

func (dc *DAGController) Start(binPath string, workDir string, params string) error

func (*DAGController) StartAsync

func (dc *DAGController) StartAsync(binPath string, workDir string, params string)

func (*DAGController) Stop

func (dc *DAGController) Stop() error

func (*DAGController) UpdateDAGSpec

func (dc *DAGController) UpdateDAGSpec(value string) error

func (*DAGController) UpdateStatus

func (dc *DAGController) UpdateStatus(status *models.Status) error

type DAGStatus

type DAGStatus struct {
	File      string
	Dir       string
	DAG       *dag.DAG
	Status    *models.Status
	Suspended bool
	Error     error
	ErrorT    *string
}

DAGStatus is the struct to contain DAGStatus spec and status.

type DAGStatusReader

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

DAGStatusReader is the struct to read DAGStatus.

func NewDAGStatusReader

func NewDAGStatusReader() *DAGStatusReader

func (*DAGStatusReader) ReadAllStatus

func (dr *DAGStatusReader) ReadAllStatus(DAGsDir string) (statuses []*DAGStatus, errs []string, err error)

ReadAllStatus reads all DAGStatus

func (*DAGStatusReader) ReadStatus

func (dr *DAGStatusReader) ReadStatus(dagLocation string, loadMetadataOnly bool) (*DAGStatus, error)

ReadStatus loads DAG from config file.

type GrepResult

type GrepResult struct {
	Name    string
	DAG     *dag.DAG
	Matches []*grep.Match
}

GrepResult is a result of grep.

func GrepDAG

func GrepDAG(dir string, pattern string) (ret []*GrepResult, errs []string, err error)

GrepDAG returns all DAGs that contain the given string.