job

Documentation

Index

• func ConstructWorkloadFor(ctx context.Context, client client.Client, job *batchv1.Job, ...) (*kueue.Workload, error)
• func SetupIndexes(indexer client.FieldIndexer) error
• type JobReconciler
  • func NewReconciler(scheme *runtime.Scheme, client client.Client, record record.EventRecorder, ...) *JobReconciler
  • func (r *JobReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *JobReconciler) SetupWithManager(mgr ctrl.Manager) error
• type Option
  • func WithManageJobsWithoutQueueName(f bool) Option

Functions

func ConstructWorkloadFor

func ConstructWorkloadFor(ctx context.Context, client client.Client,
	job *batchv1.Job, scheme *runtime.Scheme) (*kueue.Workload, error)

func SetupIndexes

func SetupIndexes(indexer client.FieldIndexer) error

Types

type JobReconciler

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

JobReconciler reconciles a Job object

func NewReconciler

func NewReconciler(
	scheme *runtime.Scheme,
	client client.Client,
	record record.EventRecorder,
	opts ...Option) *JobReconciler

func (*JobReconciler) Reconcile

func (r *JobReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*JobReconciler) SetupWithManager

func (r *JobReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager. It indexes workloads based on the owning jobs.

type Option

type Option func(*options)

Option configures the reconciler.

func WithManageJobsWithoutQueueName

func WithManageJobsWithoutQueueName(f bool) Option

WithManageJobsWithoutQueueName indicates if the controller should reconcile jobs that don't set the queue name annotation.