Versions in this module Expand all Collapse all v1 v1.16.3 Oct 23, 2019 Changes in this version + type ActivePodsFunc func() []*v1.Pod + type DeviceRunContainerOptions struct + Annotations []kubecontainer.Annotation + Devices []kubecontainer.DeviceInfo + Envs []kubecontainer.EnvVar + Mounts []kubecontainer.Mount + type Manager interface + Allocate func(node *schedulernodeinfo.NodeInfo, attrs *lifecycle.PodAdmitAttributes) error + GetCapacity func() (v1.ResourceList, v1.ResourceList, []string) + GetDeviceRunContainerOptions func(pod *v1.Pod, container *v1.Container) (*DeviceRunContainerOptions, error) + GetDevices func(podUID, containerName string) []*podresourcesapi.ContainerDevices + GetTopologyHints func(pod v1.Pod, container v1.Container) map[string][]topologymanager.TopologyHint + GetWatcherHandler func() cache.PluginHandler + ShouldResetExtendedResourceCapacity func() bool + Start func(activePods ActivePodsFunc, sourcesReady config.SourcesReady) error + Stop func() error + type ManagerImpl struct + func NewManagerImpl(numaNodeInfo cputopology.NUMANodeInfo, ...) (*ManagerImpl, error) + func (m *ManagerImpl) Allocate(node *schedulernodeinfo.NodeInfo, attrs *lifecycle.PodAdmitAttributes) error + func (m *ManagerImpl) DeRegisterPlugin(pluginName string) + func (m *ManagerImpl) GetCapacity() (v1.ResourceList, v1.ResourceList, []string) + func (m *ManagerImpl) GetDeviceRunContainerOptions(pod *v1.Pod, container *v1.Container) (*DeviceRunContainerOptions, error) + func (m *ManagerImpl) GetDevices(podUID, containerName string) []*podresourcesapi.ContainerDevices + func (m *ManagerImpl) GetTopologyHints(pod v1.Pod, container v1.Container) map[string][]topologymanager.TopologyHint + func (m *ManagerImpl) GetWatcherHandler() cache.PluginHandler + func (m *ManagerImpl) Register(ctx context.Context, r *pluginapi.RegisterRequest) (*pluginapi.Empty, error) + func (m *ManagerImpl) RegisterPlugin(pluginName string, endpoint string, versions []string) error + func (m *ManagerImpl) ShouldResetExtendedResourceCapacity() bool + func (m *ManagerImpl) Start(activePods ActivePodsFunc, sourcesReady config.SourcesReady) error + func (m *ManagerImpl) Stop() error + func (m *ManagerImpl) ValidatePlugin(pluginName string, endpoint string, versions []string, ...) error + type ManagerStub struct + func NewManagerStub() (*ManagerStub, error) + func (h *ManagerStub) Allocate(node *schedulernodeinfo.NodeInfo, attrs *lifecycle.PodAdmitAttributes) error + func (h *ManagerStub) GetCapacity() (v1.ResourceList, v1.ResourceList, []string) + func (h *ManagerStub) GetDeviceRunContainerOptions(pod *v1.Pod, container *v1.Container) (*DeviceRunContainerOptions, error) + func (h *ManagerStub) GetDevices(_, _ string) []*podresourcesapi.ContainerDevices + func (h *ManagerStub) GetTopologyHints(pod v1.Pod, container v1.Container) map[string][]topologymanager.TopologyHint + func (h *ManagerStub) GetWatcherHandler() cache.PluginHandler + func (h *ManagerStub) ShouldResetExtendedResourceCapacity() bool + 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, name string, ...) *Stub + func (m *Stub) Allocate(ctx context.Context, r *pluginapi.AllocateRequest) (*pluginapi.AllocateResponse, error) + func (m *Stub) GetDevicePluginOptions(ctx context.Context, e *pluginapi.Empty) (*pluginapi.DevicePluginOptions, error) + func (m *Stub) GetInfo(ctx context.Context, req *watcherapi.InfoRequest) (*watcherapi.PluginInfo, error) + func (m *Stub) ListAndWatch(e *pluginapi.Empty, s pluginapi.DevicePlugin_ListAndWatchServer) error + func (m *Stub) NotifyRegistrationStatus(ctx context.Context, status *watcherapi.RegistrationStatus) (*watcherapi.RegistrationStatusResponse, error) + func (m *Stub) PreStartContainer(ctx context.Context, r *pluginapi.PreStartContainerRequest) (*pluginapi.PreStartContainerResponse, error) + func (m *Stub) Register(kubeletEndpoint, resourceName string, pluginSockDir string) error + func (m *Stub) SetAllocFunc(f stubAllocFunc) + func (m *Stub) Start() error + func (m *Stub) Stop() error + func (m *Stub) Update(devs []*pluginapi.Device)
Go to main page