runner

Documentation

Index

• type LogMode
• type Options
• type Printer
• type Result
  • func Run(ctx context.Context, client kubernetes.Interface, p Printer, opts Options) (Result, error)

Types

type LogMode

type LogMode string

const (
	LogModeAll    LogMode = "all"
	LogModeFailed LogMode = "failed"
	LogModeNone   LogMode = "none"
)

type Options

type Options struct {
	Namespace string
	Selector  string
	JobNames  []string
	Timeout   time.Duration
	LogMode   LogMode
}

type Printer

type Printer interface {
	Start(total int, namespace string, timeout time.Duration)
	UpdateJob(name string, status k8s.JobStatus, age time.Duration)
	PrintLogs(jobName string, status k8s.JobStatus, logs string)
	PrintSummary(failed, deleted int)
}

type Result

type Result struct {
	Failed   int
	Deleted  int
	TimedOut bool
}

func Run

func Run(ctx context.Context, client kubernetes.Interface, p Printer, opts Options) (Result, error)