k8s

type K8s interface {
	// GetPendingRanges returns the ranges for start and end for the given chunkSize which can be parallelized.
	GetPendingRanges(dataset, table string, chunkSize int64) ([]Range, error)
	// CreateJob creates a job in the given namespace within the k8s cluster.
	CreateJob(r Range) error
}

type Range struct {
	From int64
	To   int64
}