jobqueuecontroller

type Context ¶

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

Context extends the common controllercontext.Context.

func NewContext(context controllercontext.Context) *Context

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

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

type Controller ¶

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

Controller is responsible for processing all Jobs to determine if they can be started, and if so, starts them in a deterministic order and safe from race conditions.

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 ¶

type Factory struct{}

func NewFactory() *Factory

func (f *Factory) Name() string

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

type IndependentReconciler ¶

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

IndependentReconciler reconciles independent Jobs that do not have any JobConfig.

func NewIndependentReconciler(
	ctrlContext *Context,
	concurrency *configv1alpha1.Concurrency,
	client JobControlInterface,
) *IndependentReconciler

func (r *IndependentReconciler) Concurrency() int

func (r *IndependentReconciler) MaxRequeues() int

func (r *IndependentReconciler) Name() string

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

type InformerWorker ¶

type InformerWorker struct {
	*Context
}

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

func NewInformerWorker(ctrlContext *Context) *InformerWorker

func (w *InformerWorker) WorkerName() string

type JobControl ¶

type JobControl struct {
	// contains filtered or unexported fields
}

JobControl is the default implementation of JobControlInterface.

func NewJobControl(client executionv1alpha1.ExecutionV1alpha1Interface, recorder record.EventRecorder) *JobControl

func (c *JobControl) RejectJob(ctx context.Context, rj *execution.Job, msg string) error

func (c *JobControl) StartJob(ctx context.Context, rj *execution.Job) error

type JobControlInterface ¶

type JobControlInterface interface {
	StartJob(ctx context.Context, rj *execution.Job) error
	RejectJob(ctx context.Context, rj *execution.Job, msg string) error
}

JobControlInterface is the client interface for the Controller.

type PerConfigReconciler ¶

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

PerConfigReconciler reconciles Jobs belonging to a JobConfig. It is guaranteed that no two routines will process Jobs belonging to the same JobConfig.

func NewPerConfigReconciler(
	ctrlContext *Context,
	concurrency *configv1alpha1.Concurrency,
	client JobControlInterface,
) *PerConfigReconciler

func (w *PerConfigReconciler) Concurrency() int

func (w *PerConfigReconciler) MaxRequeues() int

func (w *PerConfigReconciler) Name() string

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