Documentation ¶
Index ¶
- Variables
- func Find(steps []dsl.Step, config dsl.FindConfig, passwords []string) []dsl.Step
- func MakeInputs(sources []string, tempFolder string) ([]core.Step, error)
- func MonitorResults(done chan<- bool, startedProcesses <-chan worker.ProcessStarted, ...)
- func Process(step dsl.ProcessConfig, in []dsl.Step, sProcesses chan<- worker.ProcessStarted, ...)
- func Run(args *core.Runargs)
- func RunPipeline(config core.Config, steps []core.Step, args *core.Runargs, ...)
- type DecompressEntry
Constants ¶
This section is empty.
Variables ¶
View Source
var DebugLogs = false
Functions ¶
func MonitorResults ¶
func MonitorResults(done chan<- bool, startedProcesses <-chan worker.ProcessStarted, endedTasks <-chan worker.TaskEnded)
func Process ¶
func Process(step dsl.ProcessConfig, in []dsl.Step, sProcesses chan<- worker.ProcessStarted, sTasks chan<- worker.TaskStarted, args *core.Runargs)
func RunPipeline ¶
func RunPipeline(config core.Config, steps []core.Step, args *core.Runargs, sProcesses chan<- worker.ProcessStarted, sTasks chan<- worker.TaskStarted)
Types ¶
type DecompressEntry ¶
Click to show internal directories.
Click to hide internal directories.