Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for AddHintProvider (0.27 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
Back to top