k8s

Documentation

Index

• type K8s
  • func New(phren pkg.Phren, tlog pkg.TLog, hostname, dataset, table, namespace string) (K8s, error)
• type Range

Types

type 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
}

K8s is the interface for the k8s client

func New

func New(phren pkg.Phren, tlog pkg.TLog, hostname, dataset, table, namespace string) (K8s, error)

New returns a new instance of K8s

type Range

type Range struct {
	From int64
	To   int64
}