controller

package
v0.0.0-...-c195362 Latest Latest
Warning

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

 Go to latest Published: May 21, 2025 License: Apache-2.0 Imports: 45 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type GPUNodeClassReconciler 

type GPUNodeClassReconciler struct {
	client.Client
	Scheme *runtime.Scheme
}

GPUNodeClassReconciler reconciles a GPUNodeClass object

func (*GPUNodeClassReconciler) Reconcile 

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

Reconcile GPU node classes

func (*GPUNodeClassReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

type GPUNodeReconciler 

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

GPUNodeReconciler reconciles a GPUNode object

func (*GPUNodeReconciler) CalculateVirtualCapacity 

func (r *GPUNodeReconciler) CalculateVirtualCapacity(node *tfv1.GPUNode, pool *tfv1.GPUPool) (resource.Quantity, resource.Quantity)

func (*GPUNodeReconciler) Reconcile 

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

Reconcile GPU nodes

func (*GPUNodeReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

type GPUPoolCompactionReconciler 

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

GPUPoolReconciler reconciles a GPUPool object

func (*GPUPoolCompactionReconciler) Reconcile 

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

func (*GPUPoolCompactionReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

type GPUPoolReconciler 

type GPUPoolReconciler struct {
	client.Client

	LastProcessedItems sync.Map

	Scheme   *runtime.Scheme
	Recorder record.EventRecorder
}

GPUPoolReconciler reconciles a GPUPool object

func (*GPUPoolReconciler) Reconcile 

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

Reconcile GPU pools

func (*GPUPoolReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

type GPUReconciler 

type GPUReconciler struct {
	client.Client
	Scheme *runtime.Scheme
}

GPUReconciler reconciles a GPU object

func (*GPUReconciler) Reconcile 

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

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.

func (*GPUReconciler) SetupWithManager 

func (r *GPUReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type NodeReconciler 

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

PodReconciler reconciles a Pod object

func (*NodeReconciler) Reconcile 

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

This reconcile loop only take effect on nodeSelector mode, while in AutoProvision mode, GPUNode will manage the K8S Node rather than reversed

func (*NodeReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

type PodReconciler 

type PodReconciler struct {
	client.Client
	Scheme *runtime.Scheme
}

PodReconciler reconciles a Pod object

func (*PodReconciler) Reconcile 

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

Add GPU connection for Pods using GPU

func (*PodReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

type SchedulingConfigTemplateReconciler 

type SchedulingConfigTemplateReconciler struct {
	client.Client
	Scheme *runtime.Scheme
}

SchedulingConfigTemplateReconciler reconciles a SchedulingConfigTemplate object

func (*SchedulingConfigTemplateReconciler) Reconcile 

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

When deleted, need check if any GPU pool is using this template, if so, add warning event and requeue When updated, trigger the re-scheduling

func (*SchedulingConfigTemplateReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

type TensorFusionClusterReconciler 

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

	LastProcessedItems sync.Map
}

TensorFusionClusterReconciler reconciles a TensorFusionCluster object

func (*TensorFusionClusterReconciler) Reconcile 

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

Reconcile a TensorFusionCluster object, create and monitor GPU Pool, managing cluster level component versions

func (*TensorFusionClusterReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

type TensorFusionConnectionReconciler 

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

TensorFusionConnectionReconciler reconciles a TensorFusionConnection object

func (*TensorFusionConnectionReconciler) Reconcile 

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

Add and monitor GPU worker Pod for a TensorFusionConnection

func (*TensorFusionConnectionReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

type TensorFusionWorkloadReconciler 

type TensorFusionWorkloadReconciler struct {
	client.Client
	Scheme    *runtime.Scheme
	Scheduler scheduler.Scheduler
	Recorder  record.EventRecorder
	GpuInfos  *[]config.GpuInfo
}

TensorFusionWorkloadReconciler reconciles a TensorFusionWorkload object

func (*TensorFusionWorkloadReconciler) Reconcile 

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

TensorFusionWorkload Reconciler

func (*TensorFusionWorkloadReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

type WorkloadProfileReconciler 

type WorkloadProfileReconciler struct {
	client.Client
	Scheme *runtime.Scheme
}

WorkloadProfileReconciler reconciles a WorkloadProfile object

func (*WorkloadProfileReconciler) Reconcile 

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

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state. TODO(user): Modify the Reconcile function to compare the state specified by the WorkloadProfile object against the actual cluster state, and then perform operations to make the cluster state reflect the state specified by the user.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.19.1/pkg/reconcile

func (*WorkloadProfileReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

Source Files

View all Source files

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.