- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 117 for admitPV (0.18 sec)
-
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/update.go
scope.err(err, w, req) return } span.AddEvent("Conversion done") audit.LogRequestObject(req.Context(), obj, objGV, scope.Resource, scope.Subresource, scope.Serializer) admit = admission.WithAudit(admit) // if this object supports namespace info if objectMeta, err := meta.Accessor(obj); err == nil { // ensure namespace on the object is correct, or error if a conflicting namespace was set in the object
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 01 20:19:46 UTC 2023 - 11.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/delete.go
// timeout inside the parent context is lower than requestTimeoutUpperBound. ctx, cancel := context.WithTimeout(ctx, requestTimeoutUpperBound) defer cancel() ctx = request.WithNamespace(ctx, namespace) admit = admission.WithAudit(admit) outputMediaType, _, err := negotiation.NegotiateOutputMediaType(req, scope.Serializer, scope) if err != nil { scope.err(err, w, req) return } options := &metav1.DeleteOptions{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 01 10:00:32 UTC 2023 - 11.4K 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/endpoints/handlers/create.go
obj = scope.FieldManager.UpdateNoErrors(liveObj, obj, managerOrUserAgent(options.FieldManager, req.UserAgent())) admit = fieldmanager.NewManagedFieldsValidatingAdmissionController(admit) if mutatingAdmission, ok := admit.(admission.MutationInterface); ok && mutatingAdmission.Handles(admission.Create) { if err := mutatingAdmission.Admit(ctx, admissionAttributes, scope); err != nil { return nil, err } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 01 20:19:46 UTC 2023 - 10.1K bytes - Viewed (0) -
pkg/kubelet/cm/topologymanager/policy_best_effort.go
filteredHints := filterProvidersHints(providersHints) merger := NewHintMerger(p.numaInfo, filteredHints, p.Name(), p.opts) bestHint := merger.Merge() admit := p.canAdmitPodResult(&bestHint) return bestHint, admit
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 09 16:52:08 UTC 2022 - 1.5K bytes - Viewed (0) -
pkg/webhooks/validation/server/server_test.go
extraKeyConfig := makePilotConfig(t, 0, true, true) wh := createTestWebhook(t) cases := []struct { name string admit admitFunc in *kube.AdmissionRequest allowed bool }{ { name: "valid create", admit: wh.validate, in: &kube.AdmissionRequest{ Kind: metav1.GroupVersionKind{Kind: collections.Mock.Kind()}, Object: runtime.RawExtension{Raw: valid},
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 01 01:34:15 UTC 2023 - 9.6K bytes - Viewed (0) -
istioctl/pkg/checkinject/checkinject_test.go
"testdata/check-inject/rev-16-injector.yaml", "testdata/check-inject/never-match-injector.yaml", } var whs []admitv1.MutatingWebhookConfiguration for _, whName := range whFiles { file, err := os.ReadFile(whName) if err != nil { t.Fatal(err) } var wh *admitv1.MutatingWebhookConfiguration if err := yaml.Unmarshal(file, &wh); err != nil { t.Fatal(err) } whs = append(whs, *wh) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 15 15:02:17 UTC 2023 - 10.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/audit.go
// of attribute into the audit event. Attributes passed to the Admit and // Validate function must be instance of privateAnnotationsGetter or // AnnotationsGetter, otherwise an error is returned. func WithAudit(i Interface) Interface { if i == nil { return i } return &auditHandler{Interface: i} } func (handler *auditHandler) Admit(ctx context.Context, a Attributes, o ObjectInterfaces) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 29 00:03:53 UTC 2022 - 2.8K 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) -
pkg/kubelet/cm/admission/errors.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jul 08 21:15:37 UTC 2021 - 1.4K bytes - Viewed (0)