Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 16 for TopologyManager (0.19 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. pkg/kubelet/cm/container_manager_linux.go

    	// Interface for CPU affinity management.
    	cpuManager cpumanager.Manager
    	// Interface for memory affinity management.
    	memoryManager memorymanager.Manager
    	// Interface for Topology resource co-ordination
    	topologyManager topologymanager.Manager
    	// Interface for Dynamic Resource Allocation management.
    	draManager dra.Manager
    }
    
    type features struct {
    	cpuHardcapping bool
    }
    
    var _ ContainerManager = &containerManagerImpl{}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 10:18:16 UTC 2024
    - 35.1K bytes
    - Viewed (0)
  8. pkg/kubelet/cm/memorymanager/memory_manager.go

    	State() state.Reader
    
    	// GetTopologyHints implements the topologymanager.HintProvider Interface
    	// and is consulted to achieve NUMA aware resource alignment among this
    	// and other resource controllers.
    	GetTopologyHints(*v1.Pod, *v1.Container) map[string][]topologymanager.TopologyHint
    
    	// GetPodTopologyHints implements the topologymanager.HintProvider Interface
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 01 00:50:45 UTC 2023
    - 17.1K bytes
    - Viewed (1)
  9. pkg/kubelet/cm/cpumanager/cpu_manager.go

    	State() state.Reader
    
    	// GetTopologyHints implements the topologymanager.HintProvider Interface
    	// and is consulted to achieve NUMA aware resource alignment among this
    	// and other resource controllers.
    	GetTopologyHints(*v1.Pod, *v1.Container) map[string][]topologymanager.TopologyHint
    
    	// GetExclusiveCPUs implements the podresources.CPUsProvider interface to provide
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 03 16:26:09 UTC 2023
    - 19.9K bytes
    - Viewed (2)
  10. pkg/kubelet/cm/cpumanager/cpu_manager_test.go

    	return p.err
    }
    
    func (p *mockPolicy) GetTopologyHints(s state.State, pod *v1.Pod, container *v1.Container) map[string][]topologymanager.TopologyHint {
    	return nil
    }
    
    func (p *mockPolicy) GetPodTopologyHints(s state.State, pod *v1.Pod) map[string][]topologymanager.TopologyHint {
    	return nil
    }
    
    func (p *mockPolicy) GetAllocatableCPUs(m state.State) cpuset.CPUSet {
    	return cpuset.New()
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Oct 06 13:16:15 UTC 2023
    - 42.9K bytes
    - Viewed (0)
Back to top