deviceplugin

Jan 3, 2018

Changes in this version

+ type ActivePodsFunc func() []*v1.Pod

+ type DeviceRunContainerOptions struct

+ Devices []kubecontainer.DeviceInfo

+ Envs []kubecontainer.EnvVar

+ Mounts []kubecontainer.Mount

+ type Manager interface

+ Allocate func(node *schedulercache.NodeInfo, attrs *lifecycle.PodAdmitAttributes) error

+ Devices func() map[string][]pluginapi.Device

+ GetCapacity func() (v1.ResourceList, []string)

+ GetDeviceRunContainerOptions func(pod *v1.Pod, container *v1.Container) *DeviceRunContainerOptions

+ Start func(activePods ActivePodsFunc, sourcesReady config.SourcesReady) error

+ Stop func() error

+ type ManagerImpl struct

+ func NewManagerImpl() (*ManagerImpl, error)

+ func (m *ManagerImpl) Allocate(node *schedulercache.NodeInfo, attrs *lifecycle.PodAdmitAttributes) error

+ func (m *ManagerImpl) Devices() map[string][]pluginapi.Device

+ func (m *ManagerImpl) GetCapacity() (v1.ResourceList, []string)

+ func (m *ManagerImpl) GetDeviceRunContainerOptions(pod *v1.Pod, container *v1.Container) *DeviceRunContainerOptions

+ func (m *ManagerImpl) Register(ctx context.Context, r *pluginapi.RegisterRequest) (*pluginapi.Empty, error)

+ func (m *ManagerImpl) Start(activePods ActivePodsFunc, sourcesReady config.SourcesReady) error

+ func (m *ManagerImpl) Stop() error

+ type ManagerStub struct

+ func NewManagerStub() (*ManagerStub, error)

+ func (h *ManagerStub) Allocate(node *schedulercache.NodeInfo, attrs *lifecycle.PodAdmitAttributes) error

+ func (h *ManagerStub) Devices() map[string][]pluginapi.Device

+ func (h *ManagerStub) GetCapacity() (v1.ResourceList, []string)

+ func (h *ManagerStub) GetDeviceRunContainerOptions(pod *v1.Pod, container *v1.Container) *DeviceRunContainerOptions

+ func (h *ManagerStub) Start(activePods ActivePodsFunc, sourcesReady config.SourcesReady) error

+ func (h *ManagerStub) Stop() error

+ type Stub struct

+ func NewDevicePluginStub(devs []*pluginapi.Device, socket string) *Stub

+ func (m *Stub) Allocate(ctx context.Context, r *pluginapi.AllocateRequest) (*pluginapi.AllocateResponse, error)

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

+ func (m *Stub) Register(kubeletEndpoint, resourceName string) error

+ func (m *Stub) Start() error

+ func (m *Stub) Stop() error

+ func (m *Stub) Update(devs []*pluginapi.Device)