analyzer

type Config struct {
	Args       []string         `yaml:"args"`
	Cmd        string           `yaml:"cmd"`
	Globs      []string         `yaml:"globs"`
	Launcher   Launcher         `yaml:"-"`
	ReaderOpts anyio.ReaderOpts `yaml:"-"`
	Shaper     string           `yaml:"shaper"`
	StdoutPath string           `yaml:"stdout"`
	StderrPath string           `yaml:"stderr"`
	// WorkDir if set uses the provided directory as the working directory for
	// the launched analyzer process. Normally a temporary directory is created
	// then deleted when the process is complete. If WorkDir is set the working
	// directory will not be deleted.
	WorkDir string `yaml:"workdir"`
}

type Interface interface {
	zio.ReadCloser
	BytesRead() int64
	RecordsRead() int64
	WarningHandler(zio.Warner)
}

type Launcher func(context.Context, string, io.Reader) (ProcessWaiter, error)

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

type ProcessExitError struct {
	Args   []string
	Err    *exec.ExitError
	Path   string
	Stderr []byte
	Stdout []byte
}

type ProcessWaiter interface {
	// Wait waits for a running process to exit, returning any errors that
	// occur.
	Wait() error
}