jobconfigcontroller

Documentation

Index

• func FilterJobs(items []*execution.Job, filterFunc FilterFunc) []*execution.Job
• func IsJobConfigStatusEqual(orig, updated *execution.JobConfig) (bool, error)
• func ToJobReferences(items []*execution.Job) []execution.JobReference
• type Context
  • func NewContext(context controllercontext.Context) *Context
  • func NewContextWithRecorder(context controllercontext.Context, recorder record.EventRecorder) *Context
  • func (c *Context) GetHasSynced() []cache.InformerSynced
• type Controller
  • func NewController(ctrlContext controllercontext.Context, concurrency *configv1alpha1.Concurrency) (*Controller, error)
  • func (c *Controller) GetHealth() controllermanager.HealthStatus
  • func (c *Controller) Run(ctx context.Context) error
  • func (c *Controller) Shutdown(ctx context.Context)
• type Factory
  • func NewFactory() *Factory
  • func (f *Factory) Name() string
  • func (f *Factory) New(ctrlContext controllercontext.Context, ...) (controllermanager.Controller, error)
• type FilterFunc
• type InformerWorker
  • func NewInformerWorker(ctrlContext *Context) *InformerWorker
  • func (w *InformerWorker) WorkerName() string
• type Reconciler
  • func NewReconciler(ctrlContext *Context, concurrency *configv1alpha1.Concurrency) *Reconciler
  • func (w *Reconciler) Concurrency() int
  • func (w *Reconciler) MaxRequeues() int
  • func (w *Reconciler) Name() string
  • func (w *Reconciler) SyncOne(ctx context.Context, namespace, name string, _ int) error

Functions

func FilterJobs

func FilterJobs(items []*execution.Job, filterFunc FilterFunc) []*execution.Job

FilterJobs filters a list of Job.

func IsJobConfigStatusEqual

func IsJobConfigStatusEqual(orig, updated *execution.JobConfig) (bool, error)

IsJobConfigStatusEqual returns true if the JobConfigStatus is not equal for a JobConfig.

func ToJobReferences

func ToJobReferences(items []*execution.Job) []execution.JobReference

ToJobReferences converts a list of Jobs to a list of JobReferences.

Types

type Context

type Context struct {
	controllercontext.Context
	// contains filtered or unexported fields
}

Context extends the common controllercontext.Context.

func NewContext

func NewContext(context controllercontext.Context) *Context

func NewContextWithRecorder

func NewContextWithRecorder(context controllercontext.Context, recorder record.EventRecorder) *Context

func (*Context) GetHasSynced

func (c *Context) GetHasSynced() []cache.InformerSynced

type Controller

type Controller struct {
	*Context
	// contains filtered or unexported fields
}

Controller is responsible for reconciling the status of JobConfigs from their downstream Jobs.

func NewController

func NewController(
	ctrlContext controllercontext.Context,
	concurrency *configv1alpha1.Concurrency,
) (*Controller, error)

func (*Controller) GetHealth

func (c *Controller) GetHealth() controllermanager.HealthStatus

func (*Controller) Run

func (c *Controller) Run(ctx context.Context) error

func (*Controller) Shutdown

func (c *Controller) Shutdown(ctx context.Context)

type Factory

type Factory struct{}

func NewFactory

func NewFactory() *Factory

func (*Factory) Name

func (f *Factory) Name() string

func (*Factory) New

func (f *Factory) New(
	ctrlContext controllercontext.Context,
	concurrencySpec *configv1alpha1.ExecutionControllerConcurrencySpec,
) (controllermanager.Controller, error)

type FilterFunc

type FilterFunc func(*execution.Job) bool

type InformerWorker

type InformerWorker struct {
	*Context
}

InformerWorker receives events from the informer and enqueues work to be done for the controller.

func NewInformerWorker

func NewInformerWorker(ctrlContext *Context) *InformerWorker

func (*InformerWorker) WorkerName

func (w *InformerWorker) WorkerName() string

type Reconciler

type Reconciler struct {
	*Context
	// contains filtered or unexported fields
}

func NewReconciler

func NewReconciler(ctrlContext *Context, concurrency *configv1alpha1.Concurrency) *Reconciler

func (*Reconciler) Concurrency

func (w *Reconciler) Concurrency() int

func (*Reconciler) MaxRequeues

func (w *Reconciler) MaxRequeues() int

func (*Reconciler) Name

func (w *Reconciler) Name() string

func (*Reconciler) SyncOne

func (w *Reconciler) SyncOne(ctx context.Context, namespace, name string, _ int) error