core

Documentation

Index

• func SetupControllers(mgr ctrl.Manager, qManager *queue.Manager, cc *cache.Cache) (string, error)
• type ClusterQueueReconciler
  • func NewClusterQueueReconciler(client client.Client, qMgr *queue.Manager, cache *cache.Cache) *ClusterQueueReconciler
  • func (r *ClusterQueueReconciler) Create(e event.CreateEvent) bool
  • func (r *ClusterQueueReconciler) Delete(e event.DeleteEvent) bool
  • func (r *ClusterQueueReconciler) Generic(e event.GenericEvent) bool
  • func (r *ClusterQueueReconciler) NotifyWorkloadUpdate(w *kueue.Workload)
  • func (r *ClusterQueueReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *ClusterQueueReconciler) SetupWithManager(mgr ctrl.Manager) error
  • func (r *ClusterQueueReconciler) Status(cq *kueue.ClusterQueue) (kueue.ClusterQueueStatus, error)
  • func (r *ClusterQueueReconciler) Update(e event.UpdateEvent) bool
• type QueueReconciler
  • func NewQueueReconciler(client client.Client, queues *queue.Manager) *QueueReconciler
  • func (r *QueueReconciler) Create(e event.CreateEvent) bool
  • func (r *QueueReconciler) Delete(e event.DeleteEvent) bool
  • func (r *QueueReconciler) Generic(e event.GenericEvent) bool
  • func (r *QueueReconciler) NotifyWorkloadUpdate(w *kueue.Workload)
  • func (r *QueueReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *QueueReconciler) SetupWithManager(mgr ctrl.Manager) error
  • func (r *QueueReconciler) Update(e event.UpdateEvent) bool
• type ResourceFlavorReconciler
  • func NewResourceFlavorReconciler(cache *cache.Cache) *ResourceFlavorReconciler
  • func (r *ResourceFlavorReconciler) Create(e event.CreateEvent) bool
  • func (r *ResourceFlavorReconciler) Delete(e event.DeleteEvent) bool
  • func (r *ResourceFlavorReconciler) Generic(e event.GenericEvent) bool
  • func (r *ResourceFlavorReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *ResourceFlavorReconciler) SetupWithManager(mgr ctrl.Manager) error
  • func (r *ResourceFlavorReconciler) Update(e event.UpdateEvent) bool
• type WorkloadReconciler
  • func NewWorkloadReconciler(client client.Client, queues *queue.Manager, cache *cache.Cache, ...) *WorkloadReconciler
  • func (r *WorkloadReconciler) Create(e event.CreateEvent) bool
  • func (r *WorkloadReconciler) Delete(e event.DeleteEvent) bool
  • func (r *WorkloadReconciler) Generic(e event.GenericEvent) bool
  • func (r *WorkloadReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *WorkloadReconciler) SetupWithManager(mgr ctrl.Manager) error
  • func (r *WorkloadReconciler) Update(e event.UpdateEvent) bool
• type WorkloadUpdateWatcher

Functions

func SetupControllers

func SetupControllers(mgr ctrl.Manager, qManager *queue.Manager, cc *cache.Cache) (string, error)

SetupControllers sets up the core controllers. It returns the name of the controller that failed to create and an error, if any.

Types

type ClusterQueueReconciler

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

ClusterQueueReconciler reconciles a ClusterQueue object

func NewClusterQueueReconciler

func NewClusterQueueReconciler(client client.Client, qMgr *queue.Manager, cache *cache.Cache) *ClusterQueueReconciler

func (*ClusterQueueReconciler) Create

func (r *ClusterQueueReconciler) Create(e event.CreateEvent) bool

func (*ClusterQueueReconciler) Delete

func (r *ClusterQueueReconciler) Delete(e event.DeleteEvent) bool

func (*ClusterQueueReconciler) Generic

func (r *ClusterQueueReconciler) Generic(e event.GenericEvent) bool

func (*ClusterQueueReconciler) NotifyWorkloadUpdate

func (r *ClusterQueueReconciler) NotifyWorkloadUpdate(w *kueue.Workload)

func (*ClusterQueueReconciler) Reconcile

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

func (*ClusterQueueReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

func (*ClusterQueueReconciler) Status

func (r *ClusterQueueReconciler) Status(cq *kueue.ClusterQueue) (kueue.ClusterQueueStatus, error)

func (*ClusterQueueReconciler) Update

func (r *ClusterQueueReconciler) Update(e event.UpdateEvent) bool

type QueueReconciler

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

QueueReconciler reconciles a Queue object

func NewQueueReconciler

func NewQueueReconciler(client client.Client, queues *queue.Manager) *QueueReconciler

func (*QueueReconciler) Create

func (r *QueueReconciler) Create(e event.CreateEvent) bool

func (*QueueReconciler) Delete

func (r *QueueReconciler) Delete(e event.DeleteEvent) bool

func (*QueueReconciler) Generic

func (r *QueueReconciler) Generic(e event.GenericEvent) bool

func (*QueueReconciler) NotifyWorkloadUpdate

func (r *QueueReconciler) NotifyWorkloadUpdate(w *kueue.Workload)

func (*QueueReconciler) Reconcile

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

func (*QueueReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

func (*QueueReconciler) Update

func (r *QueueReconciler) Update(e event.UpdateEvent) bool

type ResourceFlavorReconciler

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

ResourceFlavorReconciler reconciles a ResourceFlavor object

func NewResourceFlavorReconciler

func NewResourceFlavorReconciler(cache *cache.Cache) *ResourceFlavorReconciler

func (*ResourceFlavorReconciler) Create

func (r *ResourceFlavorReconciler) Create(e event.CreateEvent) bool

func (*ResourceFlavorReconciler) Delete

func (r *ResourceFlavorReconciler) Delete(e event.DeleteEvent) bool

func (*ResourceFlavorReconciler) Generic

func (r *ResourceFlavorReconciler) Generic(e event.GenericEvent) bool

func (*ResourceFlavorReconciler) Reconcile

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

func (*ResourceFlavorReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

func (*ResourceFlavorReconciler) Update

func (r *ResourceFlavorReconciler) Update(e event.UpdateEvent) bool

type WorkloadReconciler

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

WorkloadReconciler reconciles a Workload object

func NewWorkloadReconciler

func NewWorkloadReconciler(client client.Client, queues *queue.Manager, cache *cache.Cache, watchers ...WorkloadUpdateWatcher) *WorkloadReconciler

func (*WorkloadReconciler) Create

func (r *WorkloadReconciler) Create(e event.CreateEvent) bool

func (*WorkloadReconciler) Delete

func (r *WorkloadReconciler) Delete(e event.DeleteEvent) bool

func (*WorkloadReconciler) Generic

func (r *WorkloadReconciler) Generic(e event.GenericEvent) bool

func (*WorkloadReconciler) Reconcile

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

func (*WorkloadReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

func (*WorkloadReconciler) Update

func (r *WorkloadReconciler) Update(e event.UpdateEvent) bool

type WorkloadUpdateWatcher

type WorkloadUpdateWatcher interface {
	NotifyWorkloadUpdate(*kueue.Workload)
}