Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for NewPolicyStatic (0.57 sec)

  1. pkg/kubelet/cm/memorymanager/policy_static.go

    	// because it is not reusable.
    	initContainersReusableMemory reusableMemory
    }
    
    var _ Policy = &staticPolicy{}
    
    // NewPolicyStatic returns new static policy instance
    func NewPolicyStatic(machineInfo *cadvisorapi.MachineInfo, reserved systemReservedMemory, affinity topologymanager.Store) (Policy, error) {
    	var totalSystemReserved uint64
    	for _, node := range reserved {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Nov 12 07:34:55 UTC 2023
    - 34K bytes
    - Viewed (0)
  2. pkg/kubelet/cm/memorymanager/memory_manager.go

    	case policyTypeStatic:
    		systemReserved, err := getSystemReservedMemory(machineInfo, nodeAllocatableReservation, reservedMemory)
    		if err != nil {
    			return nil, err
    		}
    
    		policy, err = NewPolicyStatic(machineInfo, systemReserved, affinity)
    		if err != nil {
    			return nil, err
    		}
    
    	default:
    		return nil, fmt.Errorf("unknown policy: \"%s\"", policyName)
    	}
    
    	manager := &manager{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 01 00:50:45 UTC 2023
    - 17.1K bytes
    - Viewed (0)
  3. pkg/kubelet/cm/memorymanager/memory_manager_test.go

    func returnPolicyByName(testCase testMemoryManager) Policy {
    	switch testCase.policyName {
    	case policyTypeMock:
    		return &mockPolicy{
    			err: fmt.Errorf("fake reg error"),
    		}
    	case policyTypeStatic:
    		policy, _ := NewPolicyStatic(&testCase.machineInfo, testCase.reserved, topologymanager.NewFakeManager())
    		return policy
    	case policyTypeNone:
    		return NewPolicyNone()
    	}
    	return nil
    }
    
    type mockPolicy struct {
    	err error
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 05 13:01:40 UTC 2023
    - 70.2K bytes
    - Viewed (0)
  4. pkg/kubelet/cm/memorymanager/policy_static_test.go

    	manager := topologymanager.NewFakeManager()
    	if hint != nil {
    		manager = topologymanager.NewFakeManagerWithHint(hint)
    	}
    
    	p, err := NewPolicyStatic(testCase.machineInfo, testCase.systemReserved, manager)
    	if err != nil {
    		return nil, nil, err
    	}
    	if initContainersReusableMemory != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Sep 17 05:49:15 UTC 2023
    - 100.4K bytes
    - Viewed (0)
Back to top