k8s-device-plugin

Feb 26, 2021

Changes in this version

+ const DeviceIDStrategyIndex

+ const DeviceIDStrategyUUID

+ func GetMigCapabilityDevicePaths() (map[string]string, error)

+ func GetMigDeviceNodePaths(parent *nvml.Device, mig *nvml.Device) ([]string, error)

type Device

+ Index string

+ Paths []string

Feb 4, 2021

Changes in this version

+ type MIGCapableDevices struct

+ func NewMIGCapableDevices() *MIGCapableDevices

+ func (devices *MIGCapableDevices) AssertAllMigEnabledDevicesAreValid() error

+ func (devices *MIGCapableDevices) GetAllMigDevices() ([]*nvml.Device, error)

+ func (devices *MIGCapableDevices) GetDevicesWithMigDisabled() ([]*nvml.Device, error)

+ func (devices *MIGCapableDevices) GetDevicesWithMigEnabled() ([]*nvml.Device, error)

Sep 22, 2020

Changes in this version

+ const DeviceListStrategyEnvvar

+ const DeviceListStrategyVolumeMounts

+ const MigStrategyMixed

+ const MigStrategyNone

+ const MigStrategySingle

+ type MigDeviceManager struct

+ func NewMigDeviceManager(strategy MigStrategy, resource string) *MigDeviceManager

+ func (m *MigDeviceManager) CheckHealth(stop <-chan interface{}, devices []*Device, unhealthy chan<- *Device)

+ func (m *MigDeviceManager) Devices() []*Device

+ type MigStrategy interface

+ GetPlugins func() []*NvidiaDevicePlugin

+ MatchesResource func(mig *nvml.Device, resource string) bool

+ func NewMigStrategy(strategy string) (MigStrategy, error)

+ type MigStrategyResourceSet map[string]struct

type NvidiaDevicePlugin

+ func (m *NvidiaDevicePlugin) GetPreferredAllocation(ctx context.Context, r *pluginapi.PreferredAllocationRequest) (*pluginapi.PreferredAllocationResponse, error)

Apr 6, 2020

Changes in this version

+ type Device struct

+ Path string

+ type GpuDeviceManager struct

+ func NewGpuDeviceManager() *GpuDeviceManager

+ func (g *GpuDeviceManager) CheckHealth(stop <-chan interface{}, devices []*Device, unhealthy chan<- *Device)

+ func (g *GpuDeviceManager) Devices() []*Device

+ type ResourceManager interface

+ CheckHealth func(stop <-chan interface{}, devices []*Device, unhealthy chan<- *Device)

+ Devices func() []*Device

Mar 16, 2019

Changes in this version

+ type NvidiaDevicePlugin struct

+ func NewNvidiaDevicePlugin() *NvidiaDevicePlugin

+ func (m *NvidiaDevicePlugin) Allocate(ctx context.Context, reqs *pluginapi.AllocateRequest) (*pluginapi.AllocateResponse, error)

+ func (m *NvidiaDevicePlugin) GetDevicePluginOptions(context.Context, *pluginapi.Empty) (*pluginapi.DevicePluginOptions, error)

+ func (m *NvidiaDevicePlugin) ListAndWatch(e *pluginapi.Empty, s pluginapi.DevicePlugin_ListAndWatchServer) error

+ func (m *NvidiaDevicePlugin) PreStartContainer(context.Context, *pluginapi.PreStartContainerRequest) (*pluginapi.PreStartContainerResponse, error)

+ func (m *NvidiaDevicePlugin) Register(kubeletEndpoint, resourceName string) error

+ func (m *NvidiaDevicePlugin) Serve() error

+ func (m *NvidiaDevicePlugin) Start() error

+ func (m *NvidiaDevicePlugin) Stop() error