worker

type Group struct {
	Key  string
	Vals chan []byte
}

type JobWorker interface {
	Map(id int, input string, utils *Utilities) (outputs map[int]string, err error)
	Reduce(id int, inputs []string, utils *Utilities) (output string, err error)
}

type JobWorkerMerge interface {
	JobWorker
	ReduceMerge(inputs []string, args, secrets map[string]string, utils *Utilities) (output string, err error)
}

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

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