Documentation
¶
Index ¶
Constants ¶
const (
AppWrapperFinalizer = "workload.codeflare.dev/finalizer"
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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 ¶ added in v0.22.0
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) SetupWithManager ¶ added in v0.22.0
func (r *NodeHealthMonitor) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
type SlackClusterQueueMonitor ¶ added in v0.26.0
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) SetupWithManager ¶ added in v0.26.0
func (r *SlackClusterQueueMonitor) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
Source Files