Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 62 for TopologyManager (0.29 sec)

  1. 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)
  2. 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)
  3. 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)
  4. pkg/kubelet/cm/devicemanager/topology_hints.go

    	"k8s.io/kubernetes/pkg/kubelet/cm/topologymanager"
    	"k8s.io/kubernetes/pkg/kubelet/cm/topologymanager/bitmask"
    )
    
    // GetTopologyHints implements the TopologyManager HintProvider Interface which
    // ensures the Device Manager is consulted when Topology Aware Hints for each
    // container are created.
    func (m *ManagerImpl) GetTopologyHints(pod *v1.Pod, container *v1.Container) map[string][]topologymanager.TopologyHint {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jan 27 02:10:25 UTC 2024
    - 9.9K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. pkg/kubelet/cm/devicemanager/topology_hints_test.go

    	"k8s.io/kubernetes/pkg/kubelet/cm/topologymanager"
    	"k8s.io/kubernetes/pkg/kubelet/cm/topologymanager/bitmask"
    )
    
    type mockAffinityStore struct {
    	hint topologymanager.TopologyHint
    }
    
    func (m *mockAffinityStore) GetAffinity(podUID string, containerName string) topologymanager.TopologyHint {
    	return m.hint
    }
    
    func (m *mockAffinityStore) GetPolicy() topologymanager.Policy {
    	return nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 27 13:02:15 UTC 2023
    - 47.5K bytes
    - Viewed (0)
  10. 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)
Back to top