v1

Documentation

Index

• func RegisterJobGeneratingHandler(ctx context.Context, controller JobController, apply apply.Apply, ...)
• func RegisterJobStatusHandler(ctx context.Context, controller JobController, condition condition.Cond, ...)
• type Interface
  • func New(controllerFactory controller.SharedControllerFactory) Interface
• type JobCache
• type JobClient
• type JobController
• type JobGeneratingHandler
• type JobStatusHandler

Functions

func RegisterJobGeneratingHandler

func RegisterJobGeneratingHandler(ctx context.Context, controller JobController, apply apply.Apply,
	condition condition.Cond, name string, handler JobGeneratingHandler, opts *generic.GeneratingHandlerOptions)

RegisterJobGeneratingHandler configures a JobController to execute a JobGeneratingHandler for every events observed, passing the returned objects to the provided apply.Apply. If a non-empty condition is provided, it will be updated in the status conditions for every handler execution

func RegisterJobStatusHandler

func RegisterJobStatusHandler(ctx context.Context, controller JobController, condition condition.Cond, name string, handler JobStatusHandler)

RegisterJobStatusHandler configures a JobController to execute a JobStatusHandler for every events observed. If a non-empty condition is provided, it will be updated in the status conditions for every handler execution

Types

type Interface

type Interface interface {
	Job() JobController
}

func New

func New(controllerFactory controller.SharedControllerFactory) Interface

type JobCache

type JobCache interface {
	generic.CacheInterface[*v1.Job]
}

JobCache interface for retrieving Job resources in memory.

type JobClient

type JobClient interface {
	generic.ClientInterface[*v1.Job, *v1.JobList]
}

JobClient interface for managing Job resources in Kubernetes.

type JobController

type JobController interface {
	generic.ControllerInterface[*v1.Job, *v1.JobList]
}

JobController interface for managing Job resources.

type JobGeneratingHandler

type JobGeneratingHandler func(obj *v1.Job, status v1.JobStatus) ([]runtime.Object, v1.JobStatus, error)

JobGeneratingHandler is the top-level handler that is executed for every Job event. It extends JobStatusHandler by a returning a slice of child objects to be passed to apply.Apply

type JobStatusHandler

type JobStatusHandler func(obj *v1.Job, status v1.JobStatus) (v1.JobStatus, error)

JobStatusHandler is executed for every added or modified Job. Should return the new status to be updated