engine

Documentation

Index

• type Engine
• type Factory
  • func NewFactory(ds persistence.DataStoreFactory, cfg *config.Config) Factory

Types

type Engine

type Engine interface {
	CreateDAG(name string) (string, error)
	GetDAGSpec(id string) (string, error)
	Grep(pattern string) ([]*persistence.GrepResult, []string, error)
	Rename(oldDAGPath, newDAGPath string) error
	Stop(dag *dag.DAG) error
	StartAsync(dag *dag.DAG, params string)
	Start(dag *dag.DAG, params string) error
	Restart(dag *dag.DAG) error
	Retry(dag *dag.DAG, reqId string) error
	GetCurrentStatus(dag *dag.DAG) (*model.Status, error)
	GetStatusByRequestId(dag *dag.DAG, requestId string) (*model.Status, error)
	GetLatestStatus(dag *dag.DAG) (*model.Status, error)
	GetRecentHistory(dag *dag.DAG, n int) []*model.StatusFile
	UpdateStatus(dag *dag.DAG, status *model.Status) error
	UpdateDAG(id string, spec string) error
	DeleteDAG(name, loc string) error
	GetAllStatus() (statuses []*persistence.DAGStatus, errs []string, err error)
	GetStatus(dagLocation string) (*persistence.DAGStatus, error)
	IsSuspended(id string) bool
	ToggleSuspend(id string, suspend bool) error
}

type Factory

type Factory interface {
	Create() Engine
}

func NewFactory

func NewFactory(ds persistence.DataStoreFactory, cfg *config.Config) Factory