device_manager

package
v1.7.1 Latest Latest
Warning

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

 Go to latest Published: Feb 20, 2026 License: Apache-2.0 Imports: 33 Imported by: 5

Documentation

Overview

Package device_manager is a generated GoMock package.

Package device_manager is a generated GoMock package.

Index

Constants

View Source 
const (
	DeviceNamespace = "devices.kubevirt.io"
)

Variables

This section is empty.

Functions

func IsChanClosed added in v0.36.0 

func IsChanClosed(ch <-chan struct{}) bool

func SocketPath added in v0.16.0 

func SocketPath(deviceName string) string

Types

type Device added in v0.51.0 

type Device interface {
	Start(stop <-chan struct{}) error
	ListAndWatch(*pluginapi.Empty, pluginapi.DevicePlugin_ListAndWatchServer) error
	PreStartContainer(context.Context, *pluginapi.PreStartContainerRequest) (*pluginapi.PreStartContainerResponse, error)
	Allocate(context.Context, *pluginapi.AllocateRequest) (*pluginapi.AllocateResponse, error)
	GetDeviceName() string
	GetInitialized() bool
}

func PermanentHostDevicePlugins added in v0.51.0 

func PermanentHostDevicePlugins(maxDevices int, permissions string) []Device

type DeviceController 

type DeviceController struct {
	// contains filtered or unexported fields
}

func NewDeviceController 

func NewDeviceController(
	host string,
	maxDevices int,
	permissions string,
	permanentPlugins []Device,
	clusterConfig *virtconfig.ClusterConfig,
	clientset k8scli.CoreV1Interface,
) *DeviceController

func (*DeviceController) Initialized added in v0.33.0 

func (c *DeviceController) Initialized() bool

func (*DeviceController) NodeHasDevice added in v0.29.0 

func (c *DeviceController) NodeHasDevice(devicePath string) bool

func (*DeviceController) RefreshMediatedDeviceTypes added in v0.58.2 

func (c *DeviceController) RefreshMediatedDeviceTypes()

func (*DeviceController) Run 

func (c *DeviceController) Run(stop chan struct{})

type DeviceControllerInterface added in v0.40.0 

type DeviceControllerInterface interface {
	Initialized() bool
	RefreshMediatedDeviceTypes()
}

type DeviceHandler added in v0.36.0 

type DeviceHandler interface {
	GetDeviceIOMMUGroup(basepath string, pciAddress string) (string, error)
	GetDeviceDriver(basepath string, pciAddress string) (string, error)
	GetDeviceNumaNode(basepath string, pciAddress string) (numaNode int)
	GetDevicePCIID(basepath string, pciAddress string) (string, error)
	GetMdevParentPCIAddr(mdevUUID string) (string, error)
	CreateMDEVType(mdevType string, parentID string) error
	RemoveMDEVType(mdevUUID string) error
	ReadMDEVAvailableInstances(mdevType string, parentID string) (int, error)
}

type DevicePluginBase added in v1.3.0 

type DevicePluginBase struct {
	// contains filtered or unexported fields
}

func (*DevicePluginBase) Allocate added in v1.3.0 

func (dpi *DevicePluginBase) Allocate(ctx context.Context, r *pluginapi.AllocateRequest) (*pluginapi.AllocateResponse, error)

func (*DevicePluginBase) GetDeviceName added in v1.3.0 

func (dpi *DevicePluginBase) GetDeviceName() string

func (*DevicePluginBase) GetDevicePluginOptions added in v1.3.0 

func (dpi *DevicePluginBase) GetDevicePluginOptions(_ context.Context, _ *pluginapi.Empty) (*pluginapi.DevicePluginOptions, error)

func (*DevicePluginBase) GetInitialized added in v1.3.0 

func (dpi *DevicePluginBase) GetInitialized() bool

func (*DevicePluginBase) ListAndWatch added in v1.3.0 

func (dpi *DevicePluginBase) ListAndWatch(_ *pluginapi.Empty, s pluginapi.DevicePlugin_ListAndWatchServer) error

func (*DevicePluginBase) PreStartContainer added in v1.3.0 

func (dpi *DevicePluginBase) PreStartContainer(_ context.Context, _ *pluginapi.PreStartContainerRequest) (*pluginapi.PreStartContainerResponse, error)

type DeviceUtilsHandler added in v0.36.0 

type DeviceUtilsHandler struct{}

func (*DeviceUtilsHandler) CreateMDEVType added in v0.45.0 

func (h *DeviceUtilsHandler) CreateMDEVType(mdevType string, parentID string) error

func (*DeviceUtilsHandler) GetDeviceDriver added in v0.36.0 

func (h *DeviceUtilsHandler) GetDeviceDriver(basepath string, pciAddress string) (string, error)

gets device driver

func (*DeviceUtilsHandler) GetDeviceIOMMUGroup added in v0.36.0 

func (h *DeviceUtilsHandler) GetDeviceIOMMUGroup(basepath string, pciAddress string) (string, error)

getDeviceIOMMUGroup gets devices iommu_group e.g. /sys/bus/pci/devices/0000\:65\:00.0/iommu_group -> ../../../../../kernel/iommu_groups/45

func (*DeviceUtilsHandler) GetDeviceNumaNode added in v0.36.0 

func (h *DeviceUtilsHandler) GetDeviceNumaNode(basepath string, pciAddress string) (numaNode int)

func (*DeviceUtilsHandler) GetDevicePCIID added in v0.36.0 

func (h *DeviceUtilsHandler) GetDevicePCIID(basepath string, pciAddress string) (string, error)

func (*DeviceUtilsHandler) GetMdevParentPCIAddr added in v0.36.0 

func (h *DeviceUtilsHandler) GetMdevParentPCIAddr(mdevUUID string) (string, error)

/sys/class/mdev_bus/0000:00:03.0/53764d0e-85a0-42b4-af5c-2046b460b1dc

func (*DeviceUtilsHandler) ReadMDEVAvailableInstances added in v0.45.0 

func (h *DeviceUtilsHandler) ReadMDEVAvailableInstances(mdevType string, parentID string) (int, error)

func (*DeviceUtilsHandler) RemoveMDEVType added in v0.45.0 

func (h *DeviceUtilsHandler) RemoveMDEVType(mdevUUID string) error

type GenericDevicePlugin 

type GenericDevicePlugin struct {
	// contains filtered or unexported fields
}

func NewGenericDevicePlugin 

func NewGenericDevicePlugin(deviceName string, devicePath string, maxDevices int, permissions string, preOpen bool) *GenericDevicePlugin

func (*GenericDevicePlugin) Allocate 

func (dpi *GenericDevicePlugin) Allocate(ctx context.Context, r *pluginapi.AllocateRequest) (*pluginapi.AllocateResponse, error)

func (*GenericDevicePlugin) GetDeviceName added in v0.8.0 

func (dpi *GenericDevicePlugin) GetDeviceName() string

func (*GenericDevicePlugin) GetDevicePluginOptions 

func (dpi *GenericDevicePlugin) GetDevicePluginOptions(_ context.Context, _ *pluginapi.Empty) (*pluginapi.DevicePluginOptions, error)

func (*GenericDevicePlugin) GetInitialized added in v0.33.0 

func (dpi *GenericDevicePlugin) GetInitialized() bool

func (*GenericDevicePlugin) ListAndWatch 

func (dpi *GenericDevicePlugin) ListAndWatch(e *pluginapi.Empty, s pluginapi.DevicePlugin_ListAndWatchServer) error

func (*GenericDevicePlugin) PreStartContainer 

func (dpi *GenericDevicePlugin) PreStartContainer(_ context.Context, _ *pluginapi.PreStartContainerRequest) (*pluginapi.PreStartContainerResponse, error)

func (*GenericDevicePlugin) Start 

func (dpi *GenericDevicePlugin) Start(stop <-chan struct{}) (err error)

Start starts the device plugin

type LocalDevices added in v1.1.0 

type LocalDevices struct {
	// contains filtered or unexported fields
}

type MDEV added in v0.36.0 

type MDEV struct {
	UUID string
	// contains filtered or unexported fields
}

type MDEVTypesManager added in v0.45.0 

type MDEVTypesManager struct {
	// contains filtered or unexported fields
}

func NewMDEVTypesManager added in v0.45.0 

func NewMDEVTypesManager() *MDEVTypesManager

type MediatedDevicePlugin added in v0.36.0 

type MediatedDevicePlugin struct {
	*DevicePluginBase
	// contains filtered or unexported fields
}

func NewMediatedDevicePlugin added in v0.36.0 

func NewMediatedDevicePlugin(mdevs []*MDEV, resourceName string) *MediatedDevicePlugin

func (*MediatedDevicePlugin) Allocate added in v0.36.0 

func (dpi *MediatedDevicePlugin) Allocate(_ context.Context, r *pluginapi.AllocateRequest) (*pluginapi.AllocateResponse, error)

func (*MediatedDevicePlugin) HealthCheck added in v1.3.0 

func (dpi *MediatedDevicePlugin) HealthCheck() error

func (*MediatedDevicePlugin) Start added in v0.36.0 

func (dpi *MediatedDevicePlugin) Start(stop <-chan struct{}) (err error)

type MockDeviceHandler added in v0.36.0 

type MockDeviceHandler struct {
	// contains filtered or unexported fields
}

MockDeviceHandler is a mock of DeviceHandler interface.

func NewMockDeviceHandler added in v0.36.0 

func NewMockDeviceHandler(ctrl *gomock.Controller) *MockDeviceHandler

NewMockDeviceHandler creates a new mock instance.

func (*MockDeviceHandler) CreateMDEVType added in v0.45.0 

func (m *MockDeviceHandler) CreateMDEVType(mdevType, parentID string) error

CreateMDEVType mocks base method.

func (*MockDeviceHandler) EXPECT added in v0.36.0 

func (m *MockDeviceHandler) EXPECT() *MockDeviceHandlerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockDeviceHandler) GetDeviceDriver added in v0.36.0 

func (m *MockDeviceHandler) GetDeviceDriver(basepath, pciAddress string) (string, error)

GetDeviceDriver mocks base method.

func (*MockDeviceHandler) GetDeviceIOMMUGroup added in v0.36.0 

func (m *MockDeviceHandler) GetDeviceIOMMUGroup(basepath, pciAddress string) (string, error)

GetDeviceIOMMUGroup mocks base method.

func (*MockDeviceHandler) GetDeviceNumaNode added in v0.36.0 

func (m *MockDeviceHandler) GetDeviceNumaNode(basepath, pciAddress string) int

GetDeviceNumaNode mocks base method.

func (*MockDeviceHandler) GetDevicePCIID added in v0.36.0 

func (m *MockDeviceHandler) GetDevicePCIID(basepath, pciAddress string) (string, error)

GetDevicePCIID mocks base method.

func (*MockDeviceHandler) GetMdevParentPCIAddr added in v0.36.0 

func (m *MockDeviceHandler) GetMdevParentPCIAddr(mdevUUID string) (string, error)

GetMdevParentPCIAddr mocks base method.

func (*MockDeviceHandler) ReadMDEVAvailableInstances added in v0.45.0 

func (m *MockDeviceHandler) ReadMDEVAvailableInstances(mdevType, parentID string) (int, error)

ReadMDEVAvailableInstances mocks base method.

func (*MockDeviceHandler) RemoveMDEVType added in v0.45.0 

func (m *MockDeviceHandler) RemoveMDEVType(mdevUUID string) error

RemoveMDEVType mocks base method.

type MockDeviceHandlerMockRecorder added in v1.6.0 

type MockDeviceHandlerMockRecorder struct {
	// contains filtered or unexported fields
}

MockDeviceHandlerMockRecorder is the mock recorder for MockDeviceHandler.

func (*MockDeviceHandlerMockRecorder) CreateMDEVType added in v1.6.0 

func (mr *MockDeviceHandlerMockRecorder) CreateMDEVType(mdevType, parentID any) *gomock.Call

CreateMDEVType indicates an expected call of CreateMDEVType.

func (*MockDeviceHandlerMockRecorder) GetDeviceDriver added in v1.6.0 

func (mr *MockDeviceHandlerMockRecorder) GetDeviceDriver(basepath, pciAddress any) *gomock.Call

GetDeviceDriver indicates an expected call of GetDeviceDriver.

func (*MockDeviceHandlerMockRecorder) GetDeviceIOMMUGroup added in v1.6.0 

func (mr *MockDeviceHandlerMockRecorder) GetDeviceIOMMUGroup(basepath, pciAddress any) *gomock.Call

GetDeviceIOMMUGroup indicates an expected call of GetDeviceIOMMUGroup.

func (*MockDeviceHandlerMockRecorder) GetDeviceNumaNode added in v1.6.0 

func (mr *MockDeviceHandlerMockRecorder) GetDeviceNumaNode(basepath, pciAddress any) *gomock.Call

GetDeviceNumaNode indicates an expected call of GetDeviceNumaNode.

func (*MockDeviceHandlerMockRecorder) GetDevicePCIID added in v1.6.0 

func (mr *MockDeviceHandlerMockRecorder) GetDevicePCIID(basepath, pciAddress any) *gomock.Call

GetDevicePCIID indicates an expected call of GetDevicePCIID.

func (*MockDeviceHandlerMockRecorder) GetMdevParentPCIAddr added in v1.6.0 

func (mr *MockDeviceHandlerMockRecorder) GetMdevParentPCIAddr(mdevUUID any) *gomock.Call

GetMdevParentPCIAddr indicates an expected call of GetMdevParentPCIAddr.

func (*MockDeviceHandlerMockRecorder) ReadMDEVAvailableInstances added in v1.6.0 

func (mr *MockDeviceHandlerMockRecorder) ReadMDEVAvailableInstances(mdevType, parentID any) *gomock.Call

ReadMDEVAvailableInstances indicates an expected call of ReadMDEVAvailableInstances.

func (*MockDeviceHandlerMockRecorder) RemoveMDEVType added in v1.6.0 

func (mr *MockDeviceHandlerMockRecorder) RemoveMDEVType(mdevUUID any) *gomock.Call

RemoveMDEVType indicates an expected call of RemoveMDEVType.

type MockPermissionManager added in v1.5.1 

type MockPermissionManager struct {
	// contains filtered or unexported fields
}

MockPermissionManager is a mock of PermissionManager interface.

func NewMockPermissionManager added in v1.5.1 

func NewMockPermissionManager(ctrl *gomock.Controller) *MockPermissionManager

NewMockPermissionManager creates a new mock instance.

func (*MockPermissionManager) ChownAtNoFollow added in v1.5.1 

func (m *MockPermissionManager) ChownAtNoFollow(path *safepath.Path, uid, gid int) error

ChownAtNoFollow mocks base method.

func (*MockPermissionManager) EXPECT added in v1.5.1 

func (m *MockPermissionManager) EXPECT() *MockPermissionManagerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

type MockPermissionManagerMockRecorder added in v1.6.0 

type MockPermissionManagerMockRecorder struct {
	// contains filtered or unexported fields
}

MockPermissionManagerMockRecorder is the mock recorder for MockPermissionManager.

func (*MockPermissionManagerMockRecorder) ChownAtNoFollow added in v1.6.0 

func (mr *MockPermissionManagerMockRecorder) ChownAtNoFollow(path, uid, gid any) *gomock.Call

ChownAtNoFollow indicates an expected call of ChownAtNoFollow.

type PCIDevice added in v0.36.0 

type PCIDevice struct {
	// contains filtered or unexported fields
}

type PCIDevicePlugin added in v0.36.0 

type PCIDevicePlugin struct {
	*DevicePluginBase
	// contains filtered or unexported fields
}

func NewPCIDevicePlugin added in v0.36.0 

func NewPCIDevicePlugin(pciDevices []*PCIDevice, resourceName string) *PCIDevicePlugin

func (*PCIDevicePlugin) Allocate added in v0.36.0 

func (dpi *PCIDevicePlugin) Allocate(_ context.Context, r *pluginapi.AllocateRequest) (*pluginapi.AllocateResponse, error)

func (*PCIDevicePlugin) Start added in v0.36.0 

func (dpi *PCIDevicePlugin) Start(stop <-chan struct{}) (err error)

type PermissionManager added in v1.5.1 

type PermissionManager interface {
	ChownAtNoFollow(path *safepath.Path, uid, gid int) error
}

func NewPermissionManager added in v1.5.1 

func NewPermissionManager() PermissionManager

type PluginDevices added in v1.1.0 

type PluginDevices struct {
	ID string

	Devices []*USBDevice
	// contains filtered or unexported fields
}

type SocketDevicePlugin added in v1.0.0 

type SocketDevicePlugin struct {
	*DevicePluginBase
	// contains filtered or unexported fields
}

func NewSocketDevicePlugin added in v1.0.0 

func NewSocketDevicePlugin(socketName, socketDir, socket string, maxDevices int, executor selinux.Executor, p PermissionManager) (*SocketDevicePlugin, error)

func (*SocketDevicePlugin) Allocate added in v1.0.0 

func (dpi *SocketDevicePlugin) Allocate(ctx context.Context, r *pluginapi.AllocateRequest) (*pluginapi.AllocateResponse, error)

func (*SocketDevicePlugin) Start added in v1.0.0 

func (dpi *SocketDevicePlugin) Start(stop <-chan struct{}) (err error)

type USBDevice added in v1.1.0 

type USBDevice struct {
	Name         string
	Manufacturer string
	Vendor       int
	Product      int
	BCD          int
	Bus          int
	DeviceNumber int
	Serial       string
	DevicePath   string
}

The sysfs metadata wrapper for the USB devices

func (*USBDevice) GetID added in v1.1.0 

func (dev *USBDevice) GetID() string

The uniqueness in the system comes from bus and device number but having the vendor:product information can help a lot. Not all usb devices provide or export a serial number.

type USBDevicePlugin added in v1.1.0 

type USBDevicePlugin struct {
	*DevicePluginBase
	// contains filtered or unexported fields
}

The actual plugin

func NewUSBDevicePlugin added in v1.1.0 

func NewUSBDevicePlugin(resourceName string, pluginDevices []*PluginDevices) *USBDevicePlugin

func (*USBDevicePlugin) Allocate added in v1.1.0 

func (plugin *USBDevicePlugin) Allocate(_ context.Context, allocRequest *pluginapi.AllocateRequest) (*pluginapi.AllocateResponse, error)

Interface to allocate requested Device, exported by ListAndWatch

func (*USBDevicePlugin) FindDevice added in v1.1.0 

func (plugin *USBDevicePlugin) FindDevice(pluginDeviceID string) *PluginDevices

func (*USBDevicePlugin) FindDeviceByUSBID added in v1.1.0 

func (plugin *USBDevicePlugin) FindDeviceByUSBID(usbID string) *PluginDevices

func (*USBDevicePlugin) GetDeviceName added in v1.1.0 

func (plugin *USBDevicePlugin) GetDeviceName() string

func (*USBDevicePlugin) GetInitialized added in v1.1.0 

func (plugin *USBDevicePlugin) GetInitialized() bool

func (*USBDevicePlugin) ListAndWatch added in v1.1.0 

func (plugin *USBDevicePlugin) ListAndWatch(_ *pluginapi.Empty, lws pluginapi.DevicePlugin_ListAndWatchServer) error

Interface to expose Devices: IDs, health and Topology

func (*USBDevicePlugin) Start added in v1.1.0 

func (plugin *USBDevicePlugin) Start(stop <-chan struct{}) error

Source Files

View all Source files

Directories

Path Synopsis
deviceplugin
v1beta1

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.