lifecycle

Documentation

Index

• type Cache
  • func NewCache(cfg *config.Config, prom *metrics.Collector) Cache
• type ExecutionIDNotFound
  • func (e ExecutionIDNotFound) Error() string
• type Job

Types

type Cache

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 metrics.Results)
	Config() config.Config
	// Has return true if the executionId is known
	Has(node string, executionId string) bool
}

Cache interface

func NewCache

func NewCache(cfg *config.Config, prom *metrics.Collector) Cache

NewCache get a new cache

type ExecutionIDNotFound

type ExecutionIDNotFound struct {
	Err error
}

ExecutionIDNotFound custom error

func (ExecutionIDNotFound) Error

func (e ExecutionIDNotFound) Error() string

type Job

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

Job interface