Versions in this module Expand all Collapse all v0 v0.0.3 Sep 24, 2025 Changes in this version + const AttributeMediaExtensions + func BuildCDIDevices(kind, sanitizedClass, id string, annotations map[string]string, envVar string) (*cdispec.Spec, string, string, []*pluginapi.CDIDevice) + func EnsureNvmlInitialized() error + func ShutdownNvml() + func StartDevicePlugins(ctx context.Context, kubeConfig *rest.Config) error + func UpdateAllocationStatus(ctx context.Context, client versioned.Interface, ...) (*instav1.AllocationClaim, error) + func WriteCDISpecForResource(resourceName string, id string, annotations map[string]string, envVar string) (string, []*pluginapi.CDIDevice, error) + type EmulatedMigGpuDiscoverer struct + func (e *EmulatedMigGpuDiscoverer) Discover() (*instav1.NodeAccelerator, error) + type Manager struct + ResourceName string + func NewManager(resourceName string, resources instav1.DiscoveredNodeResources) *Manager + func (m *Manager) Start(ctx context.Context) + func (m *Manager) Updates() <-chan []*pluginapi.Device + type MigGpuDiscoverer interface + Discover func() (*instav1.NodeAccelerator, error) + type MigProfile struct + C int + CIEngProfileID int + CIProfileID int + G int + GB int + GIProfileID int + func NewMigProfile(giProfileID, ciProfileID, ciEngProfileID int, ...) *MigProfile + func (m MigProfile) Attributes() []string + func (m MigProfile) String() string + type RealMigGpuDiscoverer struct + func (r *RealMigGpuDiscoverer) Discover() (*instav1.NodeAccelerator, error) + type Registrar struct + ResourceName string + SocketPath string + func NewRegistrar(socketPath, resourceName string) *Registrar + func (r *Registrar) Start(ctx context.Context) + type Server struct + DynamicClient dynamic.Interface + EmulatedMode instav1.EmulatedMode + InstasliceClient instaclient.Interface + KubeClient kubernetes.Interface + Manager *Manager + NodeName string + SocketPath string + func NewServer(mgr *Manager, socketPath string, kubeConfig *rest.Config, ...) (*Server, error) + func (s *Server) Allocate(ctx context.Context, req *pluginapi.AllocateRequest) (*pluginapi.AllocateResponse, error) + func (s *Server) GetDevicePluginOptions(ctx context.Context, req *pluginapi.Empty) (*pluginapi.DevicePluginOptions, error) + func (s *Server) ListAndWatch(req *pluginapi.Empty, stream pluginapi.DevicePlugin_ListAndWatchServer) error + func (s *Server) PreStartContainer(ctx context.Context, req *pluginapi.PreStartContainerRequest) (*pluginapi.PreStartContainerResponse, error) + func (s *Server) Start(ctx context.Context) error
Go to main page