devicepluginmanager

Documentation

Index

• type DevicePluginManager
  • func NewDevicePluginManager() *DevicePluginManager
  • func (m *DevicePluginManager) Allocate(ex *comtypes.ExtendedResource, deviceIds []string) (map[string]string, error)
  • func (m *DevicePluginManager) ListAndWatch(ex *comtypes.ExtendedResource) ([]*pluginapi.Device, error)
  • func (m *DevicePluginManager) PreStartContainer(ex *comtypes.ExtendedResource, deviceIds []string) error
• type ResourceManager
  • func NewResourceManager(devicePluginM *DevicePluginManager, ...) *ResourceManager
  • func (rm *ResourceManager) ApplyExtendedResources(ex *comtypes.ExtendedResource, taskID string) (map[string]string, error)
  • func (rm *ResourceManager) ReleaseExtendedResources(exName, taskID string) error

Types

type DevicePluginManager

type DevicePluginManager struct {
}

DevicePluginManager manager for device plugins

func NewDevicePluginManager

func NewDevicePluginManager() *DevicePluginManager

NewDevicePluginManager xxx new DevicePluginManager function

func (*DevicePluginManager) Allocate

func (m *DevicePluginManager) Allocate(ex *comtypes.ExtendedResource, deviceIds []string) (map[string]string, error)

Allocate xxx request deviceplugin to allocate extended resources before create container call the function

func (*DevicePluginManager) ListAndWatch

func (m *DevicePluginManager) ListAndWatch(ex *comtypes.ExtendedResource) ([]*pluginapi.Device, error)

ListAndWatch xxx request device plugin to listandwatch device list ids return deviceIds, examples: ["cpuset0","cpuset1","cpuset2"...]

func (*DevicePluginManager) PreStartContainer

func (m *DevicePluginManager) PreStartContainer(ex *comtypes.ExtendedResource, deviceIds []string) error

PreStartContainer xxx request deviceplugin to allocate extended resources before create container call the function

type ResourceManager

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

ResourceManager manager for extended resources

func NewResourceManager

func NewResourceManager(devicePluginM *DevicePluginManager,
	extendedResourceDriver *extendedresource.Driver) *ResourceManager

NewResourceManager create resource manager

func (*ResourceManager) ApplyExtendedResources

func (rm *ResourceManager) ApplyExtendedResources(
	ex *comtypes.ExtendedResource, taskID string) (map[string]string, error)

ApplyExtendedResources apply extended resource, records to file, and call device plugin return envs after device plugin Allocate

func (*ResourceManager) ReleaseExtendedResources

func (rm *ResourceManager) ReleaseExtendedResources(exName, taskID string) error

ReleaseExtendedResources release extended resource allocation in executor