controller

Documentation

Index

• type Controller
  • func New(cfg *config.Config) Controller
• type DAG
  • func FromConfig(file string) (*DAG, error)
  • func GetDAGs(dir string) (dags []*DAG, errs []string, err error)

Types

type Controller

type Controller interface {
	Stop() error
	Start(bin string, workDir string, params string) error
	Retry(bin string, workDir string, reqId string) error
	GetStatus() (*models.Status, error)
	GetLastStatus() (*models.Status, error)
	GetStatusByRequestId(requestId string) (*models.Status, error)
	GetStatusHist(n int) ([]*models.StatusFile, error)
	UpdateStatus(*models.Status) error
}

func New

func New(cfg *config.Config) Controller

type DAG

type DAG struct {
	File   string
	Dir    string
	Config *config.Config
	Status *models.Status
	Error  error
	ErrorT *string
}

func FromConfig

func FromConfig(file string) (*DAG, error)

func GetDAGs

func GetDAGs(dir string) (dags []*DAG, errs []string, err error)