controller

Documentation

Index

• func JobStatusChangedPredicate() predicate.Predicate
• type KaiwoJobReconciler
  • func (r *KaiwoJobReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *KaiwoJobReconciler) SetupWithManager(mgr ctrl.Manager) error
• type KaiwoQueueConfigReconciler
  • func (r *KaiwoQueueConfigReconciler) CreateTopology(ctx context.Context) error
  • func (r *KaiwoQueueConfigReconciler) EnsureKaiwoQueueConfig(ctx context.Context, kaiwoQueueConfigName string, clusterQueueName string, ...) error
  • func (r *KaiwoQueueConfigReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *KaiwoQueueConfigReconciler) SetupWithManager(mgr ctrl.Manager) error
  • func (r *KaiwoQueueConfigReconciler) SyncKueueResources(ctx context.Context, queueConfig *kaiwo.KaiwoQueueConfig) error
• type KaiwoServiceReconciler
  • func (r *KaiwoServiceReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *KaiwoServiceReconciler) SetupWithManager(mgr ctrl.Manager) error

Functions

func JobStatusChangedPredicate

func JobStatusChangedPredicate() predicate.Predicate

JobStatusChangedPredicate returns true only if Failed, Succeeded or the lengths of UncountedTerminatedPods.Failed / .Succeeded have changed.

Types

type KaiwoJobReconciler

type KaiwoJobReconciler struct {
	client.Client
	Scheme   *runtime.Scheme
	Recorder record.EventRecorder
}

KaiwoJobReconciler reconciles a KaiwoJob object

func (*KaiwoJobReconciler) Reconcile

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

func (*KaiwoJobReconciler) SetupWithManager

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

type KaiwoQueueConfigReconciler

type KaiwoQueueConfigReconciler struct {
	client.Client
	Scheme   *runtime.Scheme
	Recorder record.EventRecorder
}

KaiwoQueueConfigReconciler reconciles a KaiwoQueueConfig object

func (*KaiwoQueueConfigReconciler) CreateTopology

func (r *KaiwoQueueConfigReconciler) CreateTopology(ctx context.Context) error

func (*KaiwoQueueConfigReconciler) EnsureKaiwoQueueConfig

func (r *KaiwoQueueConfigReconciler) EnsureKaiwoQueueConfig(ctx context.Context, kaiwoQueueConfigName string, clusterQueueName string, cohort string) error

func (*KaiwoQueueConfigReconciler) Reconcile

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

func (*KaiwoQueueConfigReconciler) SetupWithManager

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

func (*KaiwoQueueConfigReconciler) SyncKueueResources

func (r *KaiwoQueueConfigReconciler) SyncKueueResources(ctx context.Context, queueConfig *kaiwo.KaiwoQueueConfig) error

type KaiwoServiceReconciler

type KaiwoServiceReconciler struct {
	client.Client
	Scheme   *runtime.Scheme
	Recorder record.EventRecorder
}

KaiwoServiceReconciler reconciles a KaiwoService object

func (*KaiwoServiceReconciler) Reconcile

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

func (*KaiwoServiceReconciler) SetupWithManager

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