pipelines

package

v1.0.0 Latest Latest Go to latest Published: Jan 3, 2020 License: MIT Imports: 8 Imported by: 0

Details

This section is empty.

View Source

var DepMap = make(map[string]*Dep)

func BuildDepMap(m map[string]Line) (map[string]*Dep, error)

type Dep struct {
	ID    string
	Deps  []*Dep
	Deped []*Dep
}

func FindDeps(handler pipeline.Handler, depMap map[string]*Dep) ([]*Dep, error)

func (dep Dep) HasDepID(id string) ([]string, bool)

type Deps []*Dep

func (deps Deps) IDs() []string

type Line struct {
	Index   int              `json:"index"`
	ID      string           `json:"id"`
	Handler pipeline.Handler `json:"handler"`
}

type LineMap map[string]Line

func (m LineMap) GetHandlerOK(name string) (pipeline.Handler, bool)

type Lines struct {
	LineMap LineMap
	DepMap  map[string]*Dep
}

func InitLinesByConfs(confs []pipeConf) (*Lines, error)

func InitLinesByFile(confPath string) (*Lines, error)

func (l *Lines) AddByConfJSON(id, confJSON string) error

func (l *Lines) Delete(id string) error

func (l Lines) GetDep(id string) (*Dep, bool)

func (l Lines) GetHandlerOK(id string) (pipeline.Handler, bool)

func (l *Lines) UpdateByConfJSON(id, confJSON string) error