lifecycle

package
v1.4.5 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 16, 2024 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Controller added in v1.0.6

type Controller interface {
	NewExecution(nbrOrJobs int) 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
}

Controller interface

func NewController added in v1.0.6

func NewController(cfg *config.Config, prom *metrics.Collector) Controller

NewController get a new controller

type ExecutionIDNotFound

type ExecutionIDNotFound struct {
	Err error
}

ExecutionIDNotFound custom error

func (ExecutionIDNotFound) Error added in v1.0.0

func (e ExecutionIDNotFound) Error() string

func (ExecutionIDNotFound) Is added in v1.2.1

func (e ExecutionIDNotFound) Is(err error) bool

type Job

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

Job interface

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL