Versions in this module Expand all Collapse all v1 v1.9.7-beta.0 Mar 21, 2018 v1.9.0 Dec 14, 2017 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)