exec

type AnalyzerOption func(*analyzerConfig)

type Error struct {
	// contains filtered or unexported fields
}

type Errors []Error

type Executable interface {
	ID() string
	Run(ctx context.Context) error
	Start(ctx context.Context) (WaitFn, error)
	RunWithOutput(ctx context.Context) ([]byte, error)
	RunStream(ctx context.Context, cb func([]byte)) error
	Command() string
}

type ExecutionStrategy string

type Executor interface {
	Start(ctx context.Context) error
	Add(executable Executable) error
}

type ExecutorOption func(*executor)

type Option func(*executable)

type OutputAnalyzer interface {
	Stdout() io.Writer
	Stderr() io.Writer

	// Detect scans the output for potential errors.
	// It uses a custom heuristics to detect issues.
	// It can result in a false positives.
	//
	// Note: Make sure that it is executed after Write
	//		 has finished to ensure proper detection.
	Detect() []error
}

type OutputAnalyzerHeuristic interface {
	Detect(input *bufio.Scanner) Errors
}

type WaitFn func() error