work

type MsgJobFailed struct {
	Unit  stage.Unit
	Error error
}

type MsgJobSucceeded struct {
	Unit   stage.Unit
	Worker Worker
}

type MsgScheduleNextJob struct{}

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

type Result struct {
	PartialFilesWritten store.FileInfos
	Error               error
}

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

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

type Worker interface {
	ID() string
	Work(ctx context.Context, unit stage.Unit, workRange *block.Range, moduleNames []string, upstream *response.Stream) loop.Cmd // *Result
}

type WorkerFactory = func(logger *zap.Logger) Worker

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

type WorkerState int

type WorkerStatus struct {
	State  WorkerState
	Worker Worker
}