device_manager

Documentation

Index

• Constants
• type DeviceController
  • func NewDeviceController(host string, maxDevices int) *DeviceController
  • func (c *DeviceController) Run(stop chan struct{}) error
• type GenericDevice
• type GenericDevicePlugin
  • func NewGenericDevicePlugin(deviceName string, devicePath string, maxDevices int) *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(ctx context.Context, e *pluginapi.Empty) (*pluginapi.DevicePluginOptions, error)
  • func (dpi *GenericDevicePlugin) ListAndWatch(e *pluginapi.Empty, s pluginapi.DevicePlugin_ListAndWatchServer) error
  • func (dpi *GenericDevicePlugin) PreStartContainer(ctx context.Context, in *pluginapi.PreStartContainerRequest) (*pluginapi.PreStartContainerResponse, error)
  • func (dpi *GenericDevicePlugin) Register() error
  • func (dpi *GenericDevicePlugin) Start(stop chan struct{}) error
  • func (dpi *GenericDevicePlugin) Stop() error

Constants

const (
	KVMPath = "/dev/kvm"
	KVMName = "kvm"
	TunPath = "/dev/net/tun"
	TunName = "tun"
)

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

Types

type DeviceController

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

func NewDeviceController

func NewDeviceController(host string, maxDevices int) *DeviceController

func (*DeviceController) Run

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

type GenericDevice

type GenericDevice interface {
	Start(chan struct{}) error
	GetDevicePath() string
	GetDeviceName() string
}

type GenericDevicePlugin

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

func NewGenericDevicePlugin

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

func (*GenericDevicePlugin) Allocate

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

func (*GenericDevicePlugin) GetDeviceName

func (dpi *GenericDevicePlugin) GetDeviceName() string

func (*GenericDevicePlugin) GetDevicePath

func (dpi *GenericDevicePlugin) GetDevicePath() string

func (*GenericDevicePlugin) GetDevicePluginOptions

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

func (*GenericDevicePlugin) ListAndWatch

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

func (*GenericDevicePlugin) PreStartContainer

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

func (*GenericDevicePlugin) Register

func (dpi *GenericDevicePlugin) Register() error

Register registers the device plugin for the given resourceName with Kubelet.

func (*GenericDevicePlugin) Start

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

Start starts the gRPC server of the device plugin

func (*GenericDevicePlugin) Stop

func (dpi *GenericDevicePlugin) Stop() error

Stop stops the gRPC server