plugin

Documentation

Index

• type NUMACellDevicePlugin
  • func (dpi *NUMACellDevicePlugin) Allocate(ctx context.Context, r *pluginapi.AllocateRequest) (*pluginapi.AllocateResponse, error)
  • func (NUMACellDevicePlugin) GetDevicePluginOptions(context.Context, *pluginapi.Empty) (*pluginapi.DevicePluginOptions, error)
  • func (NUMACellDevicePlugin) GetPreferredAllocation(context.Context, *pluginapi.PreferredAllocationRequest) (*pluginapi.PreferredAllocationResponse, error)
  • func (dpi *NUMACellDevicePlugin) ListAndWatch(e *pluginapi.Empty, s pluginapi.DevicePlugin_ListAndWatchServer) error
  • func (NUMACellDevicePlugin) PreStartContainer(context.Context, *pluginapi.PreStartContainerRequest) (*pluginapi.PreStartContainerResponse, error)
• type NUMACellLister
  • func NewNUMACellLister(topoInfo *topology.Info, deviceCount int) NUMACellLister
  • func (ncl NUMACellLister) Discover(pluginListCh chan dpm.PluginNameList)
  • func (ncl NUMACellLister) GetResourceNamespace() string
  • func (ncl NUMACellLister) NewPlugin(deviceID string) dpm.PluginInterface

Types

type NUMACellDevicePlugin

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

NUMACellDevicePlugin is an implementation of DevicePlugin that is capable of exposing devices to containers.

func (*NUMACellDevicePlugin) Allocate

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

Allocate allocates a set of devices to be used by container runtime environment.

func (NUMACellDevicePlugin) GetDevicePluginOptions

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

GetDevicePluginOptions returns options to be communicated with Device Manager

func (NUMACellDevicePlugin) GetPreferredAllocation

func (NUMACellDevicePlugin) GetPreferredAllocation(context.Context, *pluginapi.PreferredAllocationRequest) (*pluginapi.PreferredAllocationResponse, error)

GetPreferredAllocation returns a preferred set of devices to allocate from a list of available ones. The resulting preferred allocation is not guaranteed to be the allocation ultimately performed by the devicemanager. It is only designed to help the devicemanager make a more informed allocation decision when possible.

func (*NUMACellDevicePlugin) ListAndWatch

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

ListAndWatch sends gRPC stream of devices.

func (NUMACellDevicePlugin) PreStartContainer

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

PreStartContainer is called, if indicated by Device Plugin during registeration phase, before each container start. Device plugin can run device specific operations such as reseting the device before making devices available to the container

type NUMACellLister

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

NUMACellLister is the object responsible for discovering initial pool of devices and their allocation.

func NewNUMACellLister

func NewNUMACellLister(topoInfo *topology.Info, deviceCount int) NUMACellLister

func (NUMACellLister) Discover

func (ncl NUMACellLister) Discover(pluginListCh chan dpm.PluginNameList)

Discovery discovers all NUMA cells within the system.

func (NUMACellLister) GetResourceNamespace

func (ncl NUMACellLister) GetResourceNamespace() string

func (NUMACellLister) NewPlugin

func (ncl NUMACellLister) NewPlugin(deviceID string) dpm.PluginInterface

NewPlugin initializes new device plugin with NUMACell specific attributes.