- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 68 for admitPV (0.17 sec)
-
plugin/pkg/admission/podtolerationrestriction/admission_test.go
err = admissiontesting.WithReinvocationTesting(t, handler).Admit(context.TODO(), admission.NewAttributesRecord(pod, nil, api.Kind("Pod").WithVersion("version"), "testNamespace", namespace.ObjectMeta.Name, api.Resource("pods").WithVersion("version"), "", admission.Create, &metav1.CreateOptions{}, false, nil), nil) if test.admit && err != nil { t.Errorf("Test: %s, expected no error but got: %s", test.testName, err)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 16K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/namespace/lifecycle/admission_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 14.2K bytes - Viewed (0) -
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/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/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/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/admission/plugin/webhook/mutating/plugin_test.go
} b.ResetTimer() b.RunParallel(func(pb *testing.PB) { for pb.Next() { wh.Admit(context.TODO(), attr, objectInterfaces) } }) }) } } // TestAdmit tests that MutatingWebhook#Admit works as expected func TestAdmit(t *testing.T) { testServer := webhooktesting.NewTestServer(t) testServer.StartTLS() defer testServer.Close()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 06:06:52 UTC 2024 - 11K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/initializer/initializer_test.go
sf informers.SharedInformerFactory } func (self *WantExternalKubeInformerFactory) SetExternalKubeInformerFactory(sf informers.SharedInformerFactory) { self.sf = sf } func (self *WantExternalKubeInformerFactory) Admit(ctx context.Context, a admission.Attributes, o admission.ObjectInterfaces) error { return nil } func (self *WantExternalKubeInformerFactory) Handles(o admission.Operation) bool { return false }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 8.2K bytes - Viewed (0) -
plugin/pkg/admission/namespace/autoprovision/admission_test.go
if err != nil { t.Errorf("unexpected error initializing handler: %v", err) } informerFactory.Start(wait.NeverStop) pod := newPod(namespace) err = admissiontesting.WithReinvocationTesting(t, handler).Admit(context.TODO(), admission.NewAttributesRecord(&pod, nil, api.Kind("Pod").WithVersion("version"), pod.Namespace, pod.Name, api.Resource("pods").WithVersion("version"), "", admission.Create, &metav1.CreateOptions{}, false, nil), nil)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 7.5K bytes - Viewed (0)