pkg

Documentation

Index

• type MetricsServer
  • func NewMetricsServer(port int, deviceConfig VirtualDeviceConfig) *MetricsServer
  • func (s *MetricsServer) Start() error
  • func (s *MetricsServer) Stop() error
• type VirtualDeviceConfig
  • func GetVirtualDeviceConfig(path string) (*VirtualDeviceConfig, error)
  • func (vdc *VirtualDeviceConfig) Validate() error
• type VirtualDeviceManager
  • func NewVirtualDeviceManager(devConfig VirtualDeviceConfig) (*VirtualDeviceManager, error)
  • func (vdm *VirtualDeviceManager) Allocate(ctx context.Context, reqs *pluginapi.AllocateRequest) (*pluginapi.AllocateResponse, error)
  • func (vdm *VirtualDeviceManager) GetDevicePluginOptions(context.Context, *pluginapi.Empty) (*pluginapi.DevicePluginOptions, error)
  • func (vdm *VirtualDeviceManager) ListAndWatch(e *pluginapi.Empty, stream pluginapi.DevicePlugin_ListAndWatchServer) error
  • func (m *VirtualDeviceManager) PreStartContainer(context.Context, *pluginapi.PreStartContainerRequest) (*pluginapi.PreStartContainerResponse, error)
  • func (vdm *VirtualDeviceManager) Register() error
  • func (vdm *VirtualDeviceManager) Start() error
  • func (vdm *VirtualDeviceManager) Stop() error

Types

type MetricsServer

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

func NewMetricsServer

func NewMetricsServer(port int, deviceConfig VirtualDeviceConfig) *MetricsServer

func (*MetricsServer) Start

func (s *MetricsServer) Start() error

func (*MetricsServer) Stop

func (s *MetricsServer) Stop() error

type VirtualDeviceConfig

type VirtualDeviceConfig struct {
	ResourceName string `yaml:"resourceName"`
	SocketName   string `yaml:"socketName"`
	Count        int    `yaml:"count"`
}

func GetVirtualDeviceConfig

func GetVirtualDeviceConfig(path string) (*VirtualDeviceConfig, error)

func (*VirtualDeviceConfig) Validate

func (vdc *VirtualDeviceConfig) Validate() error

type VirtualDeviceManager

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

VirtualDeviceManager manages our virtual devices

func NewVirtualDeviceManager

func NewVirtualDeviceManager(devConfig VirtualDeviceConfig) (*VirtualDeviceManager, error)

func (*VirtualDeviceManager) Allocate

func (vdm *VirtualDeviceManager) Allocate(ctx context.Context, reqs *pluginapi.AllocateRequest) (*pluginapi.AllocateResponse, error)

Allocate devices

func (*VirtualDeviceManager) GetDevicePluginOptions

func (vdm *VirtualDeviceManager) GetDevicePluginOptions(context.Context, *pluginapi.Empty) (*pluginapi.DevicePluginOptions, error)

func (*VirtualDeviceManager) ListAndWatch

func (vdm *VirtualDeviceManager) ListAndWatch(e *pluginapi.Empty, stream pluginapi.DevicePlugin_ListAndWatchServer) error

ListAndWatch lists devices and update that list according to the health status

func (*VirtualDeviceManager) PreStartContainer

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

func (*VirtualDeviceManager) Register

func (vdm *VirtualDeviceManager) Register() error

Register with kubelet

func (*VirtualDeviceManager) Start

func (vdm *VirtualDeviceManager) Start() error

Start starts the gRPC server of the device plugin

func (*VirtualDeviceManager) Stop

func (vdm *VirtualDeviceManager) Stop() error

Stop stops the gRPC server