core

package
v0.4.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 11, 2023 License: Apache-2.0 Imports: 28 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func SetupControllers 

func SetupControllers(mgr ctrl.Manager, qManager *queue.Manager, cc *cache.Cache, cfg *config.Configuration) (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,
	watchers ...ClusterQueueUpdateWatcher,
) *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) NotifyResourceFlavorUpdate added in v0.3.0 

func (r *ClusterQueueReconciler) NotifyResourceFlavorUpdate(oldRF, newRF *kueue.ResourceFlavor)

Updates are ignored since they have no impact on the ClusterQueue's readiness.

func (*ClusterQueueReconciler) NotifyWorkloadUpdate 

func (r *ClusterQueueReconciler) NotifyWorkloadUpdate(oldWl, newWl *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) Update 

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

type ClusterQueueUpdateWatcher added in v0.2.0 

type ClusterQueueUpdateWatcher interface {
	NotifyClusterQueueUpdate(*kueue.ClusterQueue, *kueue.ClusterQueue)
}

type LocalQueueReconciler added in v0.2.0 

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

LocalQueueReconciler reconciles a LocalQueue object

func NewLocalQueueReconciler added in v0.2.0 

func NewLocalQueueReconciler(client client.Client, queues *queue.Manager, cache *cache.Cache) *LocalQueueReconciler

func (*LocalQueueReconciler) Create added in v0.2.0 

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

func (*LocalQueueReconciler) Delete added in v0.2.0 

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

func (*LocalQueueReconciler) Generic added in v0.2.0 

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

func (*LocalQueueReconciler) NotifyWorkloadUpdate added in v0.2.0 

func (r *LocalQueueReconciler) NotifyWorkloadUpdate(oldWl, newWl *kueue.Workload)

func (*LocalQueueReconciler) Reconcile added in v0.2.0 

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

func (*LocalQueueReconciler) SetupWithManager added in v0.2.0 

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

SetupWithManager sets up the controller with the Manager.

func (*LocalQueueReconciler) Update added in v0.2.0 

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

func (*LocalQueueReconciler) UpdateStatusIfChanged added in v0.3.0 

func (r *LocalQueueReconciler) UpdateStatusIfChanged(
	ctx context.Context,
	queue *kueue.LocalQueue,
	conditionStatus metav1.ConditionStatus,
	reason, msg string,
) error

type Option added in v0.3.0 

type Option func(*options)

Option configures the reconciler.

func WithPodsReadyTimeout added in v0.3.0 

func WithPodsReadyTimeout(value *time.Duration) Option

WithPodsReadyTimeout indicates if the controller should interrupt startup of a workload if it exceeds the timeout to reach the PodsReady=True condition.

func WithWorkloadUpdateWatchers added in v0.3.0 

func WithWorkloadUpdateWatchers(value ...WorkloadUpdateWatcher) Option

WithWorkloadUpdateWatchers allows to specify the workload update watchers

type ResourceFlavorReconciler 

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

ResourceFlavorReconciler reconciles a ResourceFlavor object

func NewResourceFlavorReconciler 

func NewResourceFlavorReconciler(
	client client.Client,
	qMgr *queue.Manager,
	cache *cache.Cache,
) *ResourceFlavorReconciler

func (*ResourceFlavorReconciler) AddUpdateWatcher added in v0.3.0 

func (r *ResourceFlavorReconciler) AddUpdateWatcher(watchers ...ResourceFlavorUpdateWatcher)

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) NotifyClusterQueueUpdate added in v0.2.0 

func (r *ResourceFlavorReconciler) NotifyClusterQueueUpdate(oldCQ, newCQ *kueue.ClusterQueue)

NotifyClusterQueueUpdate will listen for the update/delete events of clusterQueues to help verifying whether resourceFlavors are no longer in use by clusterQueues. There're mainly two reasons for this, 1) a clusterQueue is deleted 2) a clusterQueue is updated with the resourceFlavors in use.

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 ResourceFlavorUpdateWatcher added in v0.3.0 

type ResourceFlavorUpdateWatcher interface {
	NotifyResourceFlavorUpdate(oldRF, newRF *kueue.ResourceFlavor)
}

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, opts ...Option) *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(oldWl, newWl *kueue.Workload)
}

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.