tasks

type Children struct {
	Sequential Sequential
	Parallel   Parallel
}

type Parallel Sequential //map[string]ProcessorNode

type Pipeline struct {
	Name  string
	Graph TaskGraph `json:"-"`

	Data interface{}
	Spec PipelineSpec
	// contains filtered or unexported fields
}

type PipelineSpec Children

type Processor struct {
	ID            string // the unique name for the processor
	Version       string // the semantic version of the processor if required
	Type          string // the category of the processor: either input, output, or transformation - nil means transform
	Configuration interface{}
}

type ProcessorNode struct {

	// The public name of the node
	Name string

	// Whether the node should receive the initial data specified in the pipeline. By default, this only gets enabled for the direct children of the root node.
	GetsInitialData bool

	// The assigned runID that this processor instance gets
	RunID string

	// ProcID is in .Processor.ID
	Processor Processor
	Children  Children
	// contains filtered or unexported fields
}

type Sequential []*ProcessorNode

type TaskGraph interface {
	graph.DirectedBuilder
}