datasetworker

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

type DatasetWorkerConfig struct {
	Concurrency    int
	ExitOnComplete bool
	EnableScan     bool
	EnablePack     bool
	EnableDag      bool
	ExitOnError    bool
}

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