Versions in this module Expand all Collapse all v0 v0.0.3 May 7, 2019 v0.0.2 May 7, 2019 Changes in this version + const MaxFilesCapacity + type Executor interface + Context func() context.Context + ID func() string + Init func(pipeline *Pipeline, name string) + Name func() string + Run func() + type FileWatch struct + func NewFileWatch() *FileWatch + func (fw *FileWatch) AddPath(path string) error + func (fw *FileWatch) Stop() + func (fw *FileWatch) Watching(ctx context.Context) <-chan string + type Pipeline struct + func NewPipeline() *Pipeline + func (pipeline *Pipeline) AddTask(e Executor, name string) + func (pipeline *Pipeline) Context() context.Context + func (pipeline *Pipeline) Done() <-chan struct{} + func (pipeline *Pipeline) Run() + func (pipeline *Pipeline) Stop() + func (pipeline *Pipeline) TearDown(name string, uuid uuid.UUID) + type Task struct + func (t *Task) Context() context.Context + func (t *Task) Done() <-chan struct{} + func (t *Task) ID() string + func (t *Task) Init(pipeline *Pipeline, name string) + func (t *Task) Name() string + func (t *Task) TearDown()