- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for AddHintProvider (0.34 sec)
-
pkg/kubelet/cm/topologymanager/fake_topology_manager.go
if m.hint == nil { return TopologyHint{} } return *m.hint } func (m *fakeManager) GetPolicy() Policy { return m.policy } func (m *fakeManager) AddHintProvider(h HintProvider) { klog.InfoS("AddHintProvider", "hintProvider", h) } func (m *fakeManager) AddContainer(pod *v1.Pod, container *v1.Container, containerID string) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 02 18:02:07 UTC 2022 - 2.3K bytes - Viewed (0) -
pkg/kubelet/cm/topologymanager/scope.go
// Scope interface for Topology Manager type Scope interface { Name() string GetPolicy() Policy Admit(pod *v1.Pod) lifecycle.PodAdmitResult // AddHintProvider adds a hint provider to manager to indicate the hint provider // wants to be consoluted with when making topology hints AddHintProvider(h HintProvider) // AddContainer adds pod to Manager for tracking AddContainer(pod *v1.Pod, container *v1.Container, containerID string)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 14 14:44:24 UTC 2023 - 5K bytes - Viewed (0) -
pkg/kubelet/cm/topologymanager/topology_manager.go
type Manager interface { // PodAdmitHandler is implemented by Manager lifecycle.PodAdmitHandler // AddHintProvider adds a hint provider to manager to indicate the hint provider // wants to be consulted with when making topology hints AddHintProvider(HintProvider) // AddContainer adds pod to Manager for tracking AddContainer(pod *v1.Pod, container *v1.Container, containerID string)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jul 15 12:43:16 UTC 2023 - 7.6K bytes - Viewed (0) -
pkg/kubelet/cm/container_manager_windows.go
klog.InfoS("Creating device plugin manager") cm.deviceManager, err = devicemanager.NewManagerImpl(nil, cm.topologyManager) if err != nil { return nil, err } cm.topologyManager.AddHintProvider(cm.deviceManager) return cm, nil } func (cm *containerManagerImpl) SystemCgroupsLimit() v1.ResourceList { return v1.ResourceList{} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 12 11:25:36 UTC 2023 - 8.7K bytes - Viewed (0) -
pkg/kubelet/cm/container_manager_linux.go
} klog.InfoS("Creating device plugin manager") cm.deviceManager, err = devicemanager.NewManagerImpl(machineInfo.Topology, cm.topologyManager) if err != nil { return nil, err } cm.topologyManager.AddHintProvider(cm.deviceManager) // Initialize DRA manager if utilfeature.DefaultFeatureGate.Enabled(kubefeatures.DynamicResourceAllocation) { klog.InfoS("Creating Dynamic Resource Allocation (DRA) manager")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:18:16 UTC 2024 - 35.1K bytes - Viewed (0) -
pkg/kubelet/cm/topologymanager/topology_manager_test.go
&mockHintProvider{}, }, }, } mngr := manager{} mngr.scope = NewContainerScope(NewNonePolicy()) for _, tc := range tcases { for _, hp := range tc.hp { mngr.AddHintProvider(hp) } if len(tc.hp) != len(mngr.scope.(*containerScope).hintProviders) { t.Errorf("error") } } } func TestAdmit(t *testing.T) { numaInfo := &NUMAInfo{ Nodes: []int{0, 1},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 11 13:04:32 UTC 2023 - 13.8K bytes - Viewed (0)