runner

type MapResult struct {
	Key  string
	Path string
}

type MapStage struct {
	ID         string
	Dir        string
	ResultsDir string
}

type Mapper interface {
	Map(context.Context, MapStage, []byte) ([]MapResult, error)
}

type MapperFunc func(context.Context, MapStage, []byte) ([]MapResult, error)

type Reducer interface {
	Reduce(key string, paths []string, out io.Writer) error
}

type ReducerFunc func(string, []string, io.Writer) error

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