Documentation
¶
Index ¶
- Constants
- func IsChanClosed(ch <-chan struct{}) bool
- func SocketPath(deviceName string) string
- type Device
- type DeviceController
- type DeviceControllerInterface
- type DeviceHandler
- type DeviceUtilsHandler
- func (h *DeviceUtilsHandler) CreateMDEVType(mdevType string, parentID string) error
- func (h *DeviceUtilsHandler) GetDeviceDriver(basepath string, pciAddress string) (string, error)
- func (h *DeviceUtilsHandler) GetDeviceIOMMUGroup(basepath string, pciAddress string) (string, error)
- func (h *DeviceUtilsHandler) GetDeviceNumaNode(basepath string, pciAddress string) (numaNode int)
- func (h *DeviceUtilsHandler) GetDevicePCIID(basepath string, pciAddress string) (string, error)
- func (h *DeviceUtilsHandler) GetMdevParentPCIAddr(mdevUUID string) (string, error)
- func (h *DeviceUtilsHandler) ReadMDEVAvailableInstances(mdevType string, parentID string) (int, error)
- func (h *DeviceUtilsHandler) RemoveMDEVType(mdevUUID string) error
- type GenericDevicePlugin
- func (dpi *GenericDevicePlugin) Allocate(ctx context.Context, r *pluginapi.AllocateRequest) (*pluginapi.AllocateResponse, error)
- func (dpi *GenericDevicePlugin) GetDeviceName() string
- func (dpi *GenericDevicePlugin) GetDevicePath() string
- func (dpi *GenericDevicePlugin) GetDevicePluginOptions(_ context.Context, _ *pluginapi.Empty) (*pluginapi.DevicePluginOptions, error)
- func (dpi *GenericDevicePlugin) GetInitialized() bool
- func (dpi *GenericDevicePlugin) ListAndWatch(e *pluginapi.Empty, s pluginapi.DevicePlugin_ListAndWatchServer) error
- func (dpi *GenericDevicePlugin) PreStartContainer(_ context.Context, _ *pluginapi.PreStartContainerRequest) (*pluginapi.PreStartContainerResponse, error)
- func (dpi *GenericDevicePlugin) Start(stop <-chan struct{}) (err error)
- type MDEV
- type MDEVTypesManager
- type MediatedDevicePlugin
- func (dpi *MediatedDevicePlugin) Allocate(_ context.Context, r *pluginapi.AllocateRequest) (*pluginapi.AllocateResponse, error)
- func (dpi *MediatedDevicePlugin) GetDeviceName() string
- func (dpi *MediatedDevicePlugin) GetDevicePath() string
- func (dpi *MediatedDevicePlugin) GetDevicePluginOptions(_ context.Context, _ *pluginapi.Empty) (*pluginapi.DevicePluginOptions, error)
- func (dpi *MediatedDevicePlugin) GetInitialized() bool
- func (dpi *MediatedDevicePlugin) ListAndWatch(_ *pluginapi.Empty, s pluginapi.DevicePlugin_ListAndWatchServer) error
- func (dpi *MediatedDevicePlugin) PreStartContainer(_ context.Context, _ *pluginapi.PreStartContainerRequest) (*pluginapi.PreStartContainerResponse, error)
- func (dpi *MediatedDevicePlugin) Start(stop <-chan struct{}) (err error)
- type MockDeviceHandler
- func (_m *MockDeviceHandler) CreateMDEVType(mdevType string, parentID string) error
- func (_m *MockDeviceHandler) EXPECT() *_MockDeviceHandlerRecorder
- func (_m *MockDeviceHandler) GetDeviceDriver(basepath string, pciAddress string) (string, error)
- func (_m *MockDeviceHandler) GetDeviceIOMMUGroup(basepath string, pciAddress string) (string, error)
- func (_m *MockDeviceHandler) GetDeviceNumaNode(basepath string, pciAddress string) int
- func (_m *MockDeviceHandler) GetDevicePCIID(basepath string, pciAddress string) (string, error)
- func (_m *MockDeviceHandler) GetMdevParentPCIAddr(mdevUUID string) (string, error)
- func (_m *MockDeviceHandler) ReadMDEVAvailableInstances(mdevType string, parentID string) (int, error)
- func (_m *MockDeviceHandler) RemoveMDEVType(mdevUUID string) error
- type PCIDevice
- type PCIDevicePlugin
- func (dpi *PCIDevicePlugin) Allocate(_ context.Context, r *pluginapi.AllocateRequest) (*pluginapi.AllocateResponse, error)
- func (dpi *PCIDevicePlugin) GetDeviceName() string
- func (dpi *PCIDevicePlugin) GetDevicePath() string
- func (dpi *PCIDevicePlugin) GetDevicePluginOptions(_ context.Context, _ *pluginapi.Empty) (*pluginapi.DevicePluginOptions, error)
- func (dpi *PCIDevicePlugin) GetInitialized() bool
- func (dpi *PCIDevicePlugin) ListAndWatch(_ *pluginapi.Empty, s pluginapi.DevicePlugin_ListAndWatchServer) error
- func (dpi *PCIDevicePlugin) PreStartContainer(_ context.Context, _ *pluginapi.PreStartContainerRequest) (*pluginapi.PreStartContainerResponse, error)
- func (dpi *PCIDevicePlugin) Start(stop <-chan struct{}) (err error)
Constants ¶
View Source
const (
DeviceNamespace = "devices.kubevirt.io"
)
View Source
const (
MDEV_RESOURCE_PREFIX = "MDEV_PCI_RESOURCE"
)
View Source
const (
PCI_RESOURCE_PREFIX = "PCI_RESOURCE"
)
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
Types ¶
type Device ¶ added in v0.51.0
type Device interface { Start(stop <-chan struct{}) (err error) GetDevicePath() string GetDeviceName() string GetInitialized() bool }
func PermanentHostDevicePlugins ¶ added in v0.51.0
type DeviceController ¶
type DeviceController struct {
// contains filtered or unexported fields
}
func NewDeviceController ¶
func NewDeviceController(host 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) RefreshMediatedDevicesTypes ¶ added in v0.49.0
func (c *DeviceController) RefreshMediatedDevicesTypes()
func (*DeviceController) Run ¶
func (c *DeviceController) Run(stop chan struct{}) error
type DeviceControllerInterface ¶ added in v0.40.0
type DeviceControllerInterface interface { Initialized() bool RefreshMediatedDevicesTypes() }
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) }
var Handler DeviceHandler
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 (*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) GetDevicePath ¶ added in v0.8.0
func (dpi *GenericDevicePlugin) GetDevicePath() 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 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 {
// 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) GetDeviceName ¶ added in v0.36.0
func (dpi *MediatedDevicePlugin) GetDeviceName() string
func (*MediatedDevicePlugin) GetDevicePath ¶ added in v0.36.0
func (dpi *MediatedDevicePlugin) GetDevicePath() string
func (*MediatedDevicePlugin) GetDevicePluginOptions ¶ added in v0.36.0
func (dpi *MediatedDevicePlugin) GetDevicePluginOptions(_ context.Context, _ *pluginapi.Empty) (*pluginapi.DevicePluginOptions, error)
func (*MediatedDevicePlugin) GetInitialized ¶ added in v0.36.0
func (dpi *MediatedDevicePlugin) GetInitialized() bool
func (*MediatedDevicePlugin) ListAndWatch ¶ added in v0.36.0
func (dpi *MediatedDevicePlugin) ListAndWatch(_ *pluginapi.Empty, s pluginapi.DevicePlugin_ListAndWatchServer) error
func (*MediatedDevicePlugin) PreStartContainer ¶ added in v0.36.0
func (dpi *MediatedDevicePlugin) PreStartContainer(_ context.Context, _ *pluginapi.PreStartContainerRequest) (*pluginapi.PreStartContainerResponse, error)
func (*MediatedDevicePlugin) Start ¶ added in v0.36.0
func (dpi *MediatedDevicePlugin) Start(stop <-chan struct{}) (err error)
Start starts the device plugin
type MockDeviceHandler ¶ added in v0.36.0
type MockDeviceHandler struct {
// contains filtered or unexported fields
}
Mock of DeviceHandler interface
func NewMockDeviceHandler ¶ added in v0.36.0
func NewMockDeviceHandler(ctrl *gomock.Controller) *MockDeviceHandler
func (*MockDeviceHandler) CreateMDEVType ¶ added in v0.45.0
func (_m *MockDeviceHandler) CreateMDEVType(mdevType string, parentID string) error
func (*MockDeviceHandler) EXPECT ¶ added in v0.36.0
func (_m *MockDeviceHandler) EXPECT() *_MockDeviceHandlerRecorder
func (*MockDeviceHandler) GetDeviceDriver ¶ added in v0.36.0
func (_m *MockDeviceHandler) GetDeviceDriver(basepath string, pciAddress string) (string, error)
func (*MockDeviceHandler) GetDeviceIOMMUGroup ¶ added in v0.36.0
func (_m *MockDeviceHandler) GetDeviceIOMMUGroup(basepath string, pciAddress string) (string, error)
func (*MockDeviceHandler) GetDeviceNumaNode ¶ added in v0.36.0
func (_m *MockDeviceHandler) GetDeviceNumaNode(basepath string, pciAddress string) int
func (*MockDeviceHandler) GetDevicePCIID ¶ added in v0.36.0
func (_m *MockDeviceHandler) GetDevicePCIID(basepath string, pciAddress string) (string, error)
func (*MockDeviceHandler) GetMdevParentPCIAddr ¶ added in v0.36.0
func (_m *MockDeviceHandler) GetMdevParentPCIAddr(mdevUUID string) (string, error)
func (*MockDeviceHandler) ReadMDEVAvailableInstances ¶ added in v0.45.0
func (_m *MockDeviceHandler) ReadMDEVAvailableInstances(mdevType string, parentID string) (int, error)
func (*MockDeviceHandler) RemoveMDEVType ¶ added in v0.45.0
func (_m *MockDeviceHandler) RemoveMDEVType(mdevUUID string) error
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 {
// 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) GetDeviceName ¶ added in v0.36.0
func (dpi *PCIDevicePlugin) GetDeviceName() string
func (*PCIDevicePlugin) GetDevicePath ¶ added in v0.36.0
func (dpi *PCIDevicePlugin) GetDevicePath() string
func (*PCIDevicePlugin) GetDevicePluginOptions ¶ added in v0.36.0
func (dpi *PCIDevicePlugin) GetDevicePluginOptions(_ context.Context, _ *pluginapi.Empty) (*pluginapi.DevicePluginOptions, error)
func (*PCIDevicePlugin) GetInitialized ¶ added in v0.36.0
func (dpi *PCIDevicePlugin) GetInitialized() bool
func (*PCIDevicePlugin) ListAndWatch ¶ added in v0.36.0
func (dpi *PCIDevicePlugin) ListAndWatch(_ *pluginapi.Empty, s pluginapi.DevicePlugin_ListAndWatchServer) error
func (*PCIDevicePlugin) PreStartContainer ¶ added in v0.36.0
func (dpi *PCIDevicePlugin) PreStartContainer(_ context.Context, _ *pluginapi.PreStartContainerRequest) (*pluginapi.PreStartContainerResponse, error)
func (*PCIDevicePlugin) Start ¶ added in v0.36.0
func (dpi *PCIDevicePlugin) Start(stop <-chan struct{}) (err error)
Start starts the device plugin
Source Files
¶
Click to show internal directories.
Click to hide internal directories.