controllers

package
v0.0.0-...-f314aa1 Latest Latest
Warning

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

 Go to latest Published: Mar 2, 2026 License: Apache-2.0 Imports: 77 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	DPUServiceCredentialRequestControllerName = "dpuservicecredentialrequestcontroller"
)
View Source 
const (

	// ServiceInterfaceInterfaceNameLabel label identifies a specific interface of a DPUService.
	ServiceInterfaceInterfaceNameLabel = "svc.dpu.nvidia.com/interface"
)

Variables

This section is empty.

Functions

func GetServiceVersionKeyToBFBVersionValue 

func GetServiceVersionKeyToBFBVersionValue() map[string]func(*provisioningv1.BFB) string

GetServiceVersionKeyToBFBVersionValue returns a map that defines the supported version matching in DPUDeployment Controller. In addition, it returns a boolean to indicate if the values are set correctly or are dummy. The key is the annotation we expect the chart author to define in the Chart.yaml -> annotations The value is the version found in a BFB object given as input that corresponds to the aforementioned key

func SetupCacheIndexers 

func SetupCacheIndexers(ctx context.Context, cache cache.Cache) error

func SetupIndexers 

func SetupIndexers(ctx context.Context, mgr ctrl.Manager) error

SetupIndexers initializes all field indexers required by the DPU service controllers

Types

type DPUDeploymentNodeReconciler 

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

DPUDeploymentNodeReconciler reconciles Node Objects that are affected by a DPUDeployment

func (*DPUDeploymentNodeReconciler) DPUDeploymentToNode 

func (r *DPUDeploymentNodeReconciler) DPUDeploymentToNode(ctx context.Context, o client.Object) []ctrl.Request

DPUDeploymentToNode maps DPUDeployments to corev1.Nodes via the provisioningv1.DPUNode that should be reconciled in order to add the initial label for in cluster DPUServices if that doesn't exist and also to cleanup the labels for terminating DPUDeployments.

func (*DPUDeploymentNodeReconciler) DPUNodeMaintenanceToNode 

func (r *DPUDeploymentNodeReconciler) DPUNodeMaintenanceToNode(ctx context.Context, o client.Object) []ctrl.Request

DPUNodeMaintenanceToNode maps DPUNodeMaintenance objects to the corev1.Node that they are referencing

func (*DPUDeploymentNodeReconciler) Reconcile 

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

func (*DPUDeploymentNodeReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

type DPUDeploymentReconciler 

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

DPUDeploymentReconciler reconciles a DPUDeployment object

func (*DPUDeploymentReconciler) BFBToDPUDeployment 

func (r *DPUDeploymentReconciler) BFBToDPUDeployment(ctx context.Context, o client.Object) []ctrl.Request

BFBToDPUDeployment returns the DPUDeployments associated with a BFB

func (*DPUDeploymentReconciler) DPUFlavorToDPUDeployment 

func (r *DPUDeploymentReconciler) DPUFlavorToDPUDeployment(ctx context.Context, o client.Object) []ctrl.Request

DPUFlavorToDPUDeployment returns the DPUDeployments associated with a DPUFlavor

func (*DPUDeploymentReconciler) DPUServiceConfigurationToDPUDeployment 

func (r *DPUDeploymentReconciler) DPUServiceConfigurationToDPUDeployment(ctx context.Context, o client.Object) []ctrl.Request

DPUServiceConfigurationToDPUDeployment returns the DPUDeployments associated with a DPUServiceConfiguration

func (*DPUDeploymentReconciler) DPUServiceTemplateToDPUDeployment 

func (r *DPUDeploymentReconciler) DPUServiceTemplateToDPUDeployment(ctx context.Context, o client.Object) []ctrl.Request

DPUServiceTemplateToDPUDeployment returns the DPUDeployments associated with a DPUServiceTemplate

func (*DPUDeploymentReconciler) Reconcile 

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

Reconcile reconciles changes in a DPUDeployment object

func (*DPUDeploymentReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

type DPUReadyReconciler 

type DPUReadyReconciler struct {
	client.Client
	Scheme *runtime.Scheme

	RemoteCache *dpucluster.RemoteCache

	// DisableDPUReadyTaints, if set to true, will disable the addition of DPU-ready taints to nodes.
	DisableDPUReadyTaints bool
	// contains filtered or unexported fields
}

func (*DPUReadyReconciler) Reconcile 

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

Reconcile handles the reconciliation of DPUNode objects for DPU readiness

func (*DPUReadyReconciler) SetupWithManager 

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

SetupWithManager configures the controller with the manager and sets up required indexes and predicates

func (*DPUReadyReconciler) WatchNodes 

func (r *DPUReadyReconciler) WatchNodes(ctx context.Context, c client.Client, cluster client.ObjectKey) (dpucluster.Watcher, error)

WatchNodes sets up watches for Node objects in DPU clusters to detect node condition changes such as those reported by node-problem-detector

func (*DPUReadyReconciler) WatchServiceChains 

func (r *DPUReadyReconciler) WatchServiceChains(ctx context.Context, c client.Client, cluster client.ObjectKey) (dpucluster.Watcher, error)

WatchServiceChains sets up watches for ServiceChain objects in DPU clusters

func (*DPUReadyReconciler) WatchServiceInterfaces 

func (r *DPUReadyReconciler) WatchServiceInterfaces(ctx context.Context, c client.Client, cluster client.ObjectKey) (dpucluster.Watcher, error)

WatchServiceInterfaces sets up watches for ServiceInterface objects in DPU clusters

func (*DPUReadyReconciler) WatchServicePods 

func (r *DPUReadyReconciler) WatchServicePods(ctx context.Context, c client.Client, cluster client.ObjectKey) (dpucluster.Watcher, error)

WatchServicePods sets up watches for service pods in DPU clusters that have a service id label

type DPUServiceCredentialRequestReconciler 

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

DPUServiceCredentialRequestReconciler reconciles a DPUServiceCredentialRequest object

func (*DPUServiceCredentialRequestReconciler) Reconcile 

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

func (*DPUServiceCredentialRequestReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

type DPUServiceReconciler 

type DPUServiceReconciler struct {
	client.Client
	Scheme      *runtime.Scheme
	RemoteCache *dpucluster.RemoteCache
	// contains filtered or unexported fields
}

DPUServiceReconciler reconciles a DPUService object

func (*DPUServiceReconciler) DPUClusterToDPUService 

func (r *DPUServiceReconciler) DPUClusterToDPUService(ctx context.Context, _ client.Object) []ctrl.Request

DPUClusterToDPUService ensures all DPUServices are updated each time there is an update to a DPUCluster.

func (*DPUServiceReconciler) Reconcile 

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

Reconcile reconciles changes in a DPUService.

func (*DPUServiceReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

func (*DPUServiceReconciler) WatchNodes 

func (r *DPUServiceReconciler) WatchNodes(_ context.Context, _ client.Client, _ client.ObjectKey) (dpucluster.Watcher, error)

WatchNodes sets up a watcher for corev1.Node objects in the DPU clusters.

type DPUServiceTemplateReconciler 

type DPUServiceTemplateReconciler struct {
	client.Client
	Scheme *runtime.Scheme
	// ChartHelper is used to do relevant operations on a chart
	ChartHelper utils.ChartHelper
	// contains filtered or unexported fields
}

DPUServiceTemplateReconciler reconciles a DPUServiceTemplate object

func (*DPUServiceTemplateReconciler) Reconcile 

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

Reconcile reconciles changes in a DPUServiceTemplate object

func (*DPUServiceTemplateReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

type TemplateDPUServiceConfigurationValuesParams 

type TemplateDPUServiceConfigurationValuesParams struct {
	// Name of the generated DPUService.
	Name string

	// Namespace of the generated DPUService.
	Namespace string
}

TemplateDPUServiceConfigurationValuesParams are the values that are made available to the template for the DPUService configuration.

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.