- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 25 for admitPV (0.19 sec)
-
istioctl/pkg/tag/generate_test.go
Name: "istio-sidecar-injector", Labels: map[string]string{label.IoIstioRev.Name: "default"}, }, Webhooks: []admitv1.MutatingWebhook{ { Name: fmt.Sprintf("namespace.%s", istioInjectionWebhookSuffix), ClientConfig: admitv1.WebhookClientConfig{ Service: &admitv1.ServiceReference{ Namespace: "default", Name: "istiod", }, CABundle: []byte("ca"), }, }, {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jan 16 17:43:49 UTC 2024 - 12.1K bytes - Viewed (0) -
plugin/pkg/admission/serviceaccount/admission_test.go
err := admissiontesting.WithReinvocationTesting(t, admit).Admit(context.TODO(), attrs, nil) if err == nil { t.Errorf("Expected error for missing service account, got none") } } func TestAutomountsAPIToken(t *testing.T) { admit := NewServiceAccount() informerFactory := informers.NewSharedInformerFactory(nil, controller.NoResyncPeriodFunc()) admit.SetExternalKubeInformerFactory(informerFactory)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 12 17:49:30 UTC 2024 - 36.9K bytes - Viewed (0) -
istioctl/pkg/tag/generate.go
return nil, err } if vwh == nil { return whConfig, nil } if whConfig.FailurePolicy == nil { whConfig.FailurePolicy = map[string]*admitv1.FailurePolicyType{} } for _, wh := range vwh.Webhooks { if wh.FailurePolicy != nil && *wh.FailurePolicy == admitv1.Fail { whConfig.FailurePolicy[wh.Name] = nil } else { whConfig.FailurePolicy[wh.Name] = wh.FailurePolicy } } return whConfig, nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jan 16 17:43:49 UTC 2024 - 13.2K bytes - Viewed (0) -
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) -
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) -
pkg/kubelet/eviction/eviction_manager.go
} return manager, manager } // Admit rejects a pod if its not safe to admit for node stability. func (m *managerImpl) Admit(attrs *lifecycle.PodAdmitAttributes) lifecycle.PodAdmitResult { m.RLock() defer m.RUnlock() if len(m.nodeConditions) == 0 { return lifecycle.PodAdmitResult{Admit: true} } // Admit Critical pods even under resource pressure since they are required for system stability.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 27 18:55:56 UTC 2024 - 24.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/mutating/dispatcher.go
admissionmetrics.Metrics.ObserveWebhook(ctx, hook.Name, time.Since(t), rejected, versionedAttr.Attributes, "admit", int(err.Status.ErrStatus.Code)) default: rejected = true
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 28 08:48:22 UTC 2024 - 19.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/patch.go
scope.Resource, scope.Subresource, admission.Update, patchToUpdateOptions(options), dryrun.IsDryRun(options.DryRun), userInfo, ) admit = fieldmanager.NewManagedFieldsValidatingAdmissionController(admit) mutatingAdmission, _ := admit.(admission.MutationInterface) createAuthorizerAttributes := authorizer.AttributesRecord{ User: userInfo, ResourceRequest: true,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 28 08:48:22 UTC 2024 - 28.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/accessors.go
// GetValidatingWebhook if the accessor contains a ValidatingWebhook, returns it and true, else returns false. GetValidatingWebhook() (*v1.ValidatingWebhook, bool) // GetType returns the type of the accessor (validate or admit) GetType() string } // NewMutatingWebhookAccessor creates an accessor for a MutatingWebhook. func NewMutatingWebhookAccessor(uid, configurationName string, h *v1.MutatingWebhook) WebhookAccessor {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 22:07:40 UTC 2024 - 12.4K bytes - Viewed (0)