Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 117 for admitPV (0.15 sec)

  1. pkg/kubelet/eviction/eviction_manager_test.go

    			t.Errorf("Admit pod: %v, expected: %v, actual: %v", pod, expected[i], result.Admit)
    		}
    	}
    
    	manager.nodeConditions = []v1.NodeConditionType{v1.NodeMemoryPressure, v1.NodeDiskPressure}
    	expected = []bool{false, false, false}
    	for i, pod := range pods {
    		if result := manager.Admit(&lifecycle.PodAdmitAttributes{Pod: pod}); expected[i] != result.Admit {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 15 23:14:12 UTC 2024
    - 119.9K bytes
    - Viewed (0)
  2. pkg/kubelet/cm/topologymanager/topology_manager_test.go

    			},
    		}
    
    		podAttr := lifecycle.PodAdmitAttributes{
    			Pod: pod,
    		}
    
    		// Container scope Admit
    		ctnActual := ctnScopeManager.Admit(&podAttr)
    		if ctnActual.Admit != tc.expected {
    			t.Errorf("Error occurred, expected Admit in result to be %v got %v", tc.expected, ctnActual.Admit)
    		}
    		if !ctnActual.Admit && ctnActual.Reason != ErrorTopologyAffinity {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 11 13:04:32 UTC 2023
    - 13.8K bytes
    - Viewed (0)
  3. pkg/kubelet/nodeshutdown/nodeshutdown_manager.go

    }
    
    // managerStub is a fake node shutdown managerImpl .
    type managerStub struct{}
    
    // Admit returns a fake Pod admission which always returns true
    func (managerStub) Admit(attrs *lifecycle.PodAdmitAttributes) lifecycle.PodAdmitResult {
    	return lifecycle.PodAdmitResult{Admit: true}
    }
    
    // Start is a no-op always returning nil for non linux platforms.
    func (managerStub) Start() error {
    	return nil
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 24 09:20:34 UTC 2022
    - 2.3K bytes
    - Viewed (0)
  4. pkg/kubelet/cm/topologymanager/scope_pod.go

    			policy:           policy,
    			podMap:           containermap.NewContainerMap(),
    		},
    	}
    }
    
    func (s *podScope) Admit(pod *v1.Pod) lifecycle.PodAdmitResult {
    	bestHint, admit := s.calculateAffinity(pod)
    	klog.InfoS("Best TopologyHint", "bestHint", bestHint, "pod", klog.KObj(pod))
    	if !admit {
    		metrics.TopologyManagerAdmissionErrorsTotal.Inc()
    		return admission.GetPodAdmitResult(&TopologyAffinityError{})
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 14 14:44:24 UTC 2023
    - 2.6K bytes
    - Viewed (0)
  5. pkg/kubelet/sysctl/allowlist.go

    }
    
    // Admit checks that all sysctls given in pod's security context
    // are valid according to the allowlist.
    func (w *patternAllowlist) Admit(attrs *lifecycle.PodAdmitAttributes) lifecycle.PodAdmitResult {
    	pod := attrs.Pod
    	if pod.Spec.SecurityContext == nil || len(pod.Spec.SecurityContext.Sysctls) == 0 {
    		return lifecycle.PodAdmitResult{
    			Admit: true,
    		}
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Oct 27 22:58:54 UTC 2023
    - 4K bytes
    - Viewed (0)
  6. pkg/kubelet/cm/admission/errors_test.go

    			},
    			true,
    		},
    	}
    
    	for _, tc := range testCases {
    		h := GetPodAdmitResult(tc.Error)
    		if tc.Error == nil {
    			if !h.Admit {
    				t.Errorf("expected PodAdmitResult.Admit = true")
    			}
    			continue
    		}
    
    		if h.Admit {
    			t.Errorf("expected PodAdmitResult.Admit = false")
    		}
    
    		if tc.expectedAdmissionError {
    			err, ok := tc.Error.(*TestAdmissionError)
    			if !ok {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jul 08 21:15:37 UTC 2021
    - 1.8K bytes
    - Viewed (0)
  7. pkg/kubelet/sysctl/allowlist_test.go

    		status := w.Admit(attrs)
    		if status.Admit {
    			t.Errorf("expected to be rejected: %+v", test)
    		}
    	}
    
    	// test for: len(pod.Spec.SecurityContext.Sysctls) == 0
    	pod.Spec.SecurityContext.Sysctls = []v1.Sysctl{}
    	status := w.Admit(attrs)
    	if !status.Admit {
    		t.Errorf("expected to be allowlisted,got %+v", status)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Oct 27 22:58:54 UTC 2023
    - 3.6K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/admission/testing/helpers.go

    	admission admission.MutationInterface
    }
    
    // Admit reinvokes the admission handler and reports a test error if the admission handler performs
    // non-idempotent mutatations to the admission object.
    func (r *reinvoker) Admit(ctx context.Context, a admission.Attributes, o admission.ObjectInterfaces) error {
    	r.t.Helper()
    	outputs := []runtime.Object{}
    	for i := 0; i < 2; i++ {
    		err := r.admission.Admit(ctx, a, o)
    		if err != nil {
    			return err
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 12 15:48:03 UTC 2023
    - 2.7K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiserver/pkg/admission/metrics/metrics.go

    	extraLabels []string
    }
    
    // Admit performs a mutating admission control check and emit metrics.
    func (p pluginHandlerWithMetrics) Admit(ctx context.Context, a admission.Attributes, o admission.ObjectInterfaces) error {
    	mutatingHandler, ok := p.Interface.(admission.MutationInterface)
    	if !ok {
    		return nil
    	}
    
    	start := time.Now()
    	err := mutatingHandler.Admit(ctx, a, o)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jul 14 17:01:40 UTC 2023
    - 15.5K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiserver/pkg/endpoints/handlers/fieldmanager/admission_test.go

    	}
    }
    
    type mockAdmissionController struct {
    	admit func(ctx context.Context, a admission.Attributes, o admission.ObjectInterfaces) error
    }
    
    func (c *mockAdmissionController) Handles(operation admission.Operation) bool {
    	return true
    }
    
    func (c *mockAdmissionController) Admit(ctx context.Context, a admission.Attributes, o admission.ObjectInterfaces) error {
    	return c.admit(ctx, a, o)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jan 12 21:32:54 UTC 2023
    - 4.3K bytes
    - Viewed (0)
Back to top