mlu

Documentation

Index

• type CambriconDevicePlugin
  • func NewCambriconDevicePlugin(o Options) *CambriconDevicePlugin
  • func (m *CambriconDevicePlugin) Allocate(ctx context.Context, reqs *pluginapi.AllocateRequest) (*pluginapi.AllocateResponse, error)
  • func (m *CambriconDevicePlugin) GetDevicePluginOptions(context.Context, *pluginapi.Empty) (*pluginapi.DevicePluginOptions, error)
  • func (m *CambriconDevicePlugin) GetDeviceUUIDByIndex(index uint) (uuid string, found bool)
  • func (m *CambriconDevicePlugin) GetPreferredAllocatedDeviceUUIDs(available []uint, required []uint, size int) ([]string, error)
  • func (m *CambriconDevicePlugin) GetPreferredAllocation(ctx context.Context, r *pluginapi.PreferredAllocationRequest) (*pluginapi.PreferredAllocationResponse, error)
  • func (m *CambriconDevicePlugin) ListAndWatch(e *pluginapi.Empty, s pluginapi.DevicePlugin_ListAndWatchServer) error
  • func (m *CambriconDevicePlugin) PreStartContainer(context.Context, *pluginapi.PreStartContainerRequest) (*pluginapi.PreStartContainerResponse, error)
  • func (m *CambriconDevicePlugin) PrepareResponse(uuids []string) pluginapi.ContainerAllocateResponse
  • func (m *CambriconDevicePlugin) Register(kubeletEndpoint, resourceName string) error
  • func (m *CambriconDevicePlugin) Serve() error
  • func (m *CambriconDevicePlugin) Start() error
  • func (m *CambriconDevicePlugin) Stop() error
• type Options
  • func ParseFlags() Options

Types

type CambriconDevicePlugin

type CambriconDevicePlugin struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

CambriconDevicePlugin implements the Kubernetes device plugin API

func NewCambriconDevicePlugin

func NewCambriconDevicePlugin(o Options) *CambriconDevicePlugin

NewCambriconDevicePlugin returns an initialized CambriconDevicePlugin

func (*CambriconDevicePlugin) Allocate

func (m *CambriconDevicePlugin) Allocate(ctx context.Context, reqs *pluginapi.AllocateRequest) (*pluginapi.AllocateResponse, error)

Allocate which return list of devices.

func (*CambriconDevicePlugin) GetDevicePluginOptions

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

func (*CambriconDevicePlugin) GetDeviceUUIDByIndex

func (m *CambriconDevicePlugin) GetDeviceUUIDByIndex(index uint) (uuid string, found bool)

func (*CambriconDevicePlugin) GetPreferredAllocatedDeviceUUIDs

func (m *CambriconDevicePlugin) GetPreferredAllocatedDeviceUUIDs(available []uint, required []uint, size int) ([]string, error)

func (*CambriconDevicePlugin) GetPreferredAllocation

func (m *CambriconDevicePlugin) GetPreferredAllocation(ctx context.Context, r *pluginapi.PreferredAllocationRequest) (*pluginapi.PreferredAllocationResponse, error)

func (*CambriconDevicePlugin) ListAndWatch

func (m *CambriconDevicePlugin) ListAndWatch(e *pluginapi.Empty, s pluginapi.DevicePlugin_ListAndWatchServer) error

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

func (*CambriconDevicePlugin) PreStartContainer

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

func (*CambriconDevicePlugin) PrepareResponse

func (m *CambriconDevicePlugin) PrepareResponse(uuids []string) pluginapi.ContainerAllocateResponse

func (*CambriconDevicePlugin) Register

func (m *CambriconDevicePlugin) Register(kubeletEndpoint, resourceName string) error

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

func (*CambriconDevicePlugin) Serve

func (m *CambriconDevicePlugin) Serve() error

Serve starts the gRPC server and register the device plugin to Kubelet

func (*CambriconDevicePlugin) Start

func (m *CambriconDevicePlugin) Start() error

Start starts the gRPC server of the device plugin

func (*CambriconDevicePlugin) Stop

func (m *CambriconDevicePlugin) Stop() error

Stop stops the gRPC server

type Options

type Options struct {
	Mode               string `` /* 156-byte string literal not displayed */
	MLULinkPolicy      string `` /* 142-byte string literal not displayed */
	VirtualizationNum  uint   `` /* 158-byte string literal not displayed */
	DisableHealthCheck bool   `long:"disable-health-check" description:"disable MLU health check"`
	NodeName           string `long:"node-name" description:"host node name" env:"NODE_NAME"`
	EnableConsole      bool   `long:"enable-console" description:"enable UART console device(/dev/ttyMS) in container"`
	EnableDeviceType   bool   `long:"enable-device-type" description:"enable device registration with type info"`
	CnmonPath          string `long:"cnmon-path" description:"host cnmon path"`
}

func ParseFlags

func ParseFlags() Options