controller

package
v1.0.1 Latest Latest
Warning

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

 Go to latest Published: Dec 2, 2024 License: Apache-2.0 Imports: 43 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// SelectedNIMProfilesAnnotationKey is the annotation key for auto-selected model profiles
	SelectedNIMProfilesAnnotationKey = "nvidia.com/selected-profiles"

	// NIMCacheFinalizer is the finalizer annotation
	NIMCacheFinalizer = "finalizer.nimcache.apps.nvidia.com"

	// AllProfiles represents all profiles in the NIM manifest
	AllProfiles = "all"

	// NIMCacheRole is the name of the role for all NIMCache instances in the namespace
	NIMCacheRole = "nim-cache-role"

	// NIMCacheRoleBinding is the name of the rolebinding for all NIMCache instances in the namespace
	NIMCacheRoleBinding = "nim-cache-rolebinding"

	// NIMCacheServiceAccount is the name of the serviceaccount for all NIMCache instances in the namespace
	NIMCacheServiceAccount = "nim-cache-sa"

	// NIMCacheContainerName returns the name of the container used for NIM Cache operations.
	NIMCacheContainerName = "nim-cache-ctr"
)
View Source 
const (
	// NIMPipelineFinalizer is the finalizer annotation
	NIMPipelineFinalizer = "finalizer.nimpipeline.apps.nvidia.com"
)
View Source 
const NIMServiceFinalizer = "finalizer.nimservice.apps.nvidia.com"

NIMServiceFinalizer is the finalizer annotation

Variables

This section is empty.

Functions

This section is empty.

Types

type NIMCacheReconciler 

type NIMCacheReconciler struct {
	client.Client

	Platform platform.Platform
	// contains filtered or unexported fields
}

NIMCacheReconciler reconciles a NIMCache object

func NewNIMCacheReconciler 

func NewNIMCacheReconciler(client client.Client, scheme *runtime.Scheme, log logr.Logger, platform platform.Platform) *NIMCacheReconciler

NewNIMCacheReconciler creates a new reconciler for NIMCache with the given platform

func (*NIMCacheReconciler) GetClient 

func (r *NIMCacheReconciler) GetClient() client.Client

GetClient returns the client instance

func (*NIMCacheReconciler) GetEventRecorder 

func (r *NIMCacheReconciler) GetEventRecorder() record.EventRecorder

GetEventRecorder returns the event recorder

func (*NIMCacheReconciler) GetLogger 

func (r *NIMCacheReconciler) GetLogger() logr.Logger

GetLogger returns the logger of the reconciler

func (*NIMCacheReconciler) GetNodeGPUProducts 

func (r *NIMCacheReconciler) GetNodeGPUProducts(ctx context.Context) (map[string]string, error)

GetNodeGPUProducts retrieves the value of the "nvidia.com/gpu.product" label from all nodes in the cluster, filtering nodes where this label is not empty.

func (*NIMCacheReconciler) GetOrchestratorType added in v1.0.1 

func (r *NIMCacheReconciler) GetOrchestratorType() (k8sutil.OrchestratorType, error)

GetOrchestratorType returns the container platform type

func (*NIMCacheReconciler) GetRenderer 

func (r *NIMCacheReconciler) GetRenderer() render.Renderer

GetRenderer returns the renderer instance

func (*NIMCacheReconciler) GetScheme 

func (r *NIMCacheReconciler) GetScheme() *runtime.Scheme

GetScheme returns the scheme of the reconciler

func (*NIMCacheReconciler) GetUpdater 

func (r *NIMCacheReconciler) GetUpdater() conditions.Updater

GetUpdater returns the conditions updater instance

func (*NIMCacheReconciler) Reconcile 

func (r *NIMCacheReconciler) 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 NIMCache 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.18.2/pkg/reconcile

func (*NIMCacheReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

type NIMPipelineReconciler 

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

NIMPipelineReconciler reconciles a NIMPipeline object

func (*NIMPipelineReconciler) GetEventRecorder 

func (r *NIMPipelineReconciler) GetEventRecorder() record.EventRecorder

GetEventRecorder returns the event recorder

func (*NIMPipelineReconciler) Reconcile 

func (r *NIMPipelineReconciler) 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.

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

func (*NIMPipelineReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

type NIMServiceReconciler 

type NIMServiceReconciler struct {
	client.Client

	Config   *rest.Config
	Platform platform.Platform
	// contains filtered or unexported fields
}

NIMServiceReconciler reconciles a NIMService object

func NewNIMServiceReconciler 

func NewNIMServiceReconciler(client client.Client, scheme *runtime.Scheme, updater conditions.Updater, renderer render.Renderer, log logr.Logger, platform platform.Platform) *NIMServiceReconciler

NewNIMServiceReconciler creates a new reconciler for NIMService with the given platform

func (*NIMServiceReconciler) GetClient 

func (r *NIMServiceReconciler) GetClient() client.Client

GetClient returns the client instance

func (*NIMServiceReconciler) GetConfig 

func (r *NIMServiceReconciler) GetConfig() *rest.Config

GetConfig returns the rest config

func (*NIMServiceReconciler) GetEventRecorder 

func (r *NIMServiceReconciler) GetEventRecorder() record.EventRecorder

GetEventRecorder returns the event recorder

func (*NIMServiceReconciler) GetLogger 

func (r *NIMServiceReconciler) GetLogger() logr.Logger

GetLogger returns the logger of the reconciler

func (*NIMServiceReconciler) GetOrchestratorType added in v1.0.1 

func (r *NIMServiceReconciler) GetOrchestratorType() (k8sutil.OrchestratorType, error)

GetOrchestratorType returns the container platform type

func (*NIMServiceReconciler) GetRenderer 

func (r *NIMServiceReconciler) GetRenderer() render.Renderer

GetRenderer returns the renderer instance

func (*NIMServiceReconciler) GetScheme 

func (r *NIMServiceReconciler) GetScheme() *runtime.Scheme

GetScheme returns the scheme of the reconciler

func (*NIMServiceReconciler) GetUpdater 

func (r *NIMServiceReconciler) GetUpdater() conditions.Updater

GetUpdater returns the conditions updater instance

func (*NIMServiceReconciler) Reconcile 

func (r *NIMServiceReconciler) 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 NIMService 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.18.2/pkg/reconcile

func (*NIMServiceReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

Source Files

View all Source files

Directories

Path Synopsis
kserve
standalone

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.