- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 34 for TopologyManager (0.47 sec)
-
pkg/kubelet/cm/internal_container_lifecycle.go
} // Implements InternalContainerLifecycle interface. type internalContainerLifecycleImpl struct { cpuManager cpumanager.Manager memoryManager memorymanager.Manager topologyManager topologymanager.Manager } func (i *internalContainerLifecycleImpl) PreStartContainer(pod *v1.Pod, container *v1.Container, containerID string) error { if i.cpuManager != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 10 06:43:12 UTC 2023 - 1.8K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/policy_options_test.go
t.Run(testCase.description, func(t *testing.T) { topoMgrPolicy := topologymanager.NewNonePolicy() if testCase.topoMgrPolicy == topologymanager.PolicySingleNumaNode { topoMgrPolicy = topologymanager.NewSingleNumaNodePolicy(&topologymanager.NUMAInfo{}, topologymanager.PolicyOptions{}) } topoMgrStore := topologymanager.NewFakeManagerWithPolicy(topoMgrPolicy)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 5.9K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/policy.go
// GetTopologyHints implements the topologymanager.HintProvider Interface // and is consulted to achieve NUMA aware resource alignment among this // and other resource controllers. GetTopologyHints(s state.State, pod *v1.Pod, container *v1.Container) map[string][]topologymanager.TopologyHint // GetPodTopologyHints implements the topologymanager.HintProvider Interface
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 03 16:26:09 UTC 2023 - 1.8K bytes - Viewed (0) -
pkg/kubelet/cm/container_manager_windows.go
nodeConfig: nodeConfig, cadvisorInterface: cadvisorInterface, } cm.topologyManager = topologymanager.NewFakeManager() 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 }
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/memorymanager/policy_none.go
} // GetTopologyHints implements the topologymanager.HintProvider Interface // and is consulted to achieve NUMA aware resource alignment among this // and other resource controllers. func (p *none) GetTopologyHints(s state.State, pod *v1.Pod, container *v1.Container) map[string][]topologymanager.TopologyHint { return nil } // GetPodTopologyHints implements the topologymanager.HintProvider Interface
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 05 17:52:25 UTC 2021 - 2.2K bytes - Viewed (0) -
pkg/kubelet/cm/topologymanager/scope.go
// It would be better to implement this function in topologymanager instead of scope // but topologymanager do not track mapping anymore func (s *scope) AddContainer(pod *v1.Pod, container *v1.Container, containerID string) { s.mutex.Lock() defer s.mutex.Unlock() s.podMap.Add(string(pod.UID), container.Name, containerID) } // It would be better to implement this function in topologymanager instead of scope
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/cpumanager/fake_cpu_manager.go
klog.InfoS("Get container topology hints") return map[string][]topologymanager.TopologyHint{} } func (m *fakeManager) GetPodTopologyHints(pod *v1.Pod) map[string][]topologymanager.TopologyHint { klog.InfoS("Get pod topology hints") return map[string][]topologymanager.TopologyHint{} } func (m *fakeManager) State() state.Reader {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 03 16:26:09 UTC 2023 - 2.9K bytes - Viewed (0) -
pkg/kubelet/cm/memorymanager/policy.go
// GetTopologyHints implements the topologymanager.HintProvider Interface // and is consulted to achieve NUMA aware resource alignment among this // and other resource controllers. GetTopologyHints(s state.State, pod *v1.Pod, container *v1.Container) map[string][]topologymanager.TopologyHint // GetPodTopologyHints implements the topologymanager.HintProvider Interface
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 05 17:52:25 UTC 2021 - 1.8K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/policy_options.go
if opts.AlignBySocket { // Not compatible with topology manager single-numa-node policy option. if topologyManager.GetPolicy().Name() == topologymanager.PolicySingleNumaNode { return fmt.Errorf("Topolgy manager %s policy is incompatible with CPUManager %s policy option", topologymanager.PolicySingleNumaNode, AlignBySocketOption) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 27 13:02:15 UTC 2023 - 5.1K bytes - Viewed (0) -
pkg/kubelet/cm/memorymanager/fake_memory_manager.go
klog.InfoS("Get Topology Hints", "pod", klog.KObj(pod), "containerName", container.Name) return map[string][]topologymanager.TopologyHint{} } func (m *fakeManager) GetPodTopologyHints(pod *v1.Pod) map[string][]topologymanager.TopologyHint { klog.InfoS("Get Pod Topology Hints", "pod", klog.KObj(pod)) return map[string][]topologymanager.TopologyHint{} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 27 13:02:15 UTC 2023 - 3.1K bytes - Viewed (0)