Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 22 for TopologyManager (0.43 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/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)
  3. 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)
  4. 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)
  5. 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)
  6. pkg/kubelet/cm/cpumanager/topology_hints_test.go

    	"k8s.io/kubernetes/pkg/kubelet/cm/topologymanager"
    	"k8s.io/kubernetes/pkg/kubelet/cm/topologymanager/bitmask"
    	"k8s.io/utils/cpuset"
    )
    
    type testCase struct {
    	name          string
    	pod           v1.Pod
    	container     v1.Container
    	assignments   state.ContainerCPUAssignments
    	defaultCPUSet cpuset.CPUSet
    	expectedHints []topologymanager.TopologyHint
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 19K bytes
    - Viewed (0)
  7. pkg/kubelet/cm/memorymanager/policy_static.go

    }
    
    func regenerateHints(pod *v1.Pod, ctn *v1.Container, ctnBlocks []state.Block, reqRsrc map[v1.ResourceName]uint64) map[string][]topologymanager.TopologyHint {
    	hints := map[string][]topologymanager.TopologyHint{}
    	for resourceName := range reqRsrc {
    		hints[string(resourceName)] = []topologymanager.TopologyHint{}
    	}
    
    	if len(ctnBlocks) != len(reqRsrc) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Nov 12 07:34:55 UTC 2023
    - 34K bytes
    - Viewed (0)
  8. pkg/kubelet/cm/devicemanager/types.go

    	// the node has been recreated.
    	ShouldResetExtendedResourceCapacity() bool
    
    	// TopologyManager HintProvider provider indicates the Device Manager implements the Topology Manager Interface
    	// and is consulted to make Topology aware resource alignments
    	GetTopologyHints(pod *v1.Pod, container *v1.Container) map[string][]topologymanager.TopologyHint
    
    	// TopologyManager HintProvider provider indicates the Device Manager implements the Topology Manager Interface
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 27 13:02:15 UTC 2023
    - 5K bytes
    - Viewed (0)
  9. pkg/kubelet/cm/cpumanager/policy_static_test.go

    	pkgfeatures "k8s.io/kubernetes/pkg/features"
    	"k8s.io/kubernetes/pkg/kubelet/cm/cpumanager/state"
    	"k8s.io/kubernetes/pkg/kubelet/cm/cpumanager/topology"
    	"k8s.io/kubernetes/pkg/kubelet/cm/topologymanager"
    	"k8s.io/kubernetes/pkg/kubelet/cm/topologymanager/bitmask"
    	"k8s.io/utils/cpuset"
    )
    
    type staticPolicyTest struct {
    	description     string
    	topo            *topology.CPUTopology
    	numReservedCPUs int
    	reservedCPUs    *cpuset.CPUSet
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 40.8K bytes
    - Viewed (0)
  10. pkg/kubelet/cm/cpumanager/policy_static.go

    	"k8s.io/kubernetes/pkg/features"
    	"k8s.io/kubernetes/pkg/kubelet/cm/cpumanager/state"
    	"k8s.io/kubernetes/pkg/kubelet/cm/cpumanager/topology"
    	"k8s.io/kubernetes/pkg/kubelet/cm/topologymanager"
    	"k8s.io/kubernetes/pkg/kubelet/cm/topologymanager/bitmask"
    	"k8s.io/kubernetes/pkg/kubelet/metrics"
    	"k8s.io/kubernetes/pkg/kubelet/types"
    	"k8s.io/utils/cpuset"
    )
    
    const (
    
    	// PolicyStatic is the name of the static policy.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Oct 06 13:16:15 UTC 2023
    - 28.8K bytes
    - Viewed (0)
Back to top