appwrapper

Documentation

Index

• Constants
• type AppWrapperReconciler
  • func (r *AppWrapperReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *AppWrapperReconciler) SetupWithManager(mgr ctrl.Manager) error
• type NodeHealthMonitor
  • func (r *NodeHealthMonitor) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *NodeHealthMonitor) SetupWithManager(mgr ctrl.Manager) error
• type SlackClusterQueueMonitor
  • func (r *SlackClusterQueueMonitor) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *SlackClusterQueueMonitor) SetupWithManager(mgr ctrl.Manager) error

Constants

const (
	AppWrapperFinalizer = "workload.codeflare.dev/finalizer"
)

Types

type AppWrapperReconciler

type AppWrapperReconciler struct {
	client.Client
	Recorder record.EventRecorder
	Scheme   *runtime.Scheme
	Config   *config.AppWrapperConfig
}

AppWrapperReconciler reconciles an appwrapper

func (*AppWrapperReconciler) Reconcile

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

Reconcile reconciles an appwrapper Please see aw-states for documentation of this method.

func (*AppWrapperReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type NodeHealthMonitor

type NodeHealthMonitor struct {
	client.Client
	Config *config.AppWrapperConfig
	Events chan event.GenericEvent // event channel for NodeHealthMonitor to trigger SlackClusterQueueMonitor
}

NodeHealthMonitor watches Nodes and maintains mappings of Nodes that have either been marked as Unschedulable or that have been labeled to indicate that they have resources that Autopilot has tainted as NoSchedule or NoExecute. This information is used to automate the maintenance of the lendingLimit of a designated slack ClusterQueue and to migrate running workloads away from NoExecute resources.

func (*NodeHealthMonitor) Reconcile

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

func (*NodeHealthMonitor) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type SlackClusterQueueMonitor

type SlackClusterQueueMonitor struct {
	client.Client
	Config *config.AppWrapperConfig
	Events chan event.GenericEvent // event channel for NodeHealthMonitor to trigger SlackClusterQueueMonitor
}

SlackClusterQueueMonitor uses the information gathered by the NodeHealthMonitor to adjust the lending limitLimits of a designated slack ClusterQueue

func (*SlackClusterQueueMonitor) Reconcile

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

func (*SlackClusterQueueMonitor) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.