- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 117 for admitPV (0.15 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
pkg/kubelet/sysctl/allowlist_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 27 22:58:54 UTC 2023 - 3.6K bytes - Viewed (0) -
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) -
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) -
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)