v1

Documentation

Index

• func RegisterCronJobGeneratingHandler(ctx context.Context, controller CronJobController, apply apply.Apply, ...)
• func RegisterCronJobStatusHandler(ctx context.Context, controller CronJobController, condition condition.Cond, ...)
• func RegisterJobGeneratingHandler(ctx context.Context, controller JobController, apply apply.Apply, ...)
• func RegisterJobStatusHandler(ctx context.Context, controller JobController, condition condition.Cond, ...)
• type CronJobCache
• type CronJobClient
• type CronJobController
• type CronJobGeneratingHandler
• type CronJobStatusHandler
• type Interface
  • func New(controllerFactory controller.SharedControllerFactory) Interface
• type JobCache
• type JobClient
• type JobController
• type JobGeneratingHandler
• type JobStatusHandler

Functions

func RegisterCronJobGeneratingHandler

func RegisterCronJobGeneratingHandler(ctx context.Context, controller CronJobController, apply apply.Apply,
	condition condition.Cond, name string, handler CronJobGeneratingHandler, opts *generic.GeneratingHandlerOptions)

RegisterCronJobGeneratingHandler configures a CronJobController to execute a CronJobGeneratingHandler 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 RegisterCronJobStatusHandler

func RegisterCronJobStatusHandler(ctx context.Context, controller CronJobController, condition condition.Cond, name string, handler CronJobStatusHandler)

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

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 CronJobCache

type CronJobCache interface {
	generic.CacheInterface[*v1.CronJob]
}

CronJobCache interface for retrieving CronJob resources in memory.

type CronJobClient

type CronJobClient interface {
	generic.ClientInterface[*v1.CronJob, *v1.CronJobList]
}

CronJobClient interface for managing CronJob resources in Kubernetes.

type CronJobController

type CronJobController interface {
	generic.ControllerInterface[*v1.CronJob, *v1.CronJobList]
}

CronJobController interface for managing CronJob resources.

type CronJobGeneratingHandler

type CronJobGeneratingHandler func(obj *v1.CronJob, status v1.CronJobStatus) ([]runtime.Object, v1.CronJobStatus, error)

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

type CronJobStatusHandler

type CronJobStatusHandler func(obj *v1.CronJob, status v1.CronJobStatus) (v1.CronJobStatus, error)

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

type Interface

type Interface interface {
	CronJob() CronJobController
	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