lifecycle

type Cache interface {
	NewExecution() string
	AllAdded(executionID string) error
	AddPod(job Job) error
	PodTerminated(executionID, node string, phase corev1.PodPhase) error
	ReportReceived(executionID, node string, processingError error, results map[string][]Result)
	Config() config.Config
}

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

type ExecutionIDNotFound error

type Job interface {
	Process()
	ID() string
	Node() string
}

type Result struct {
	Value  float64           `json:"value"`
	Labels map[string]string `json:"labels"`
}