- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 45 for NewAttributesRecord (0.43 sec)
-
plugin/pkg/admission/network/denyserviceexternalips/admission_test.go
if tc.oldSvc == nil { op = admission.Create opt = &metav1.CreateOptions{} } else { op = admission.Update opt = &metav1.UpdateOptions{} } attrs := admission.NewAttributesRecord( tc.newSvc, // new object tc.oldSvc, // old object core.Kind("Service").WithVersion("version"), tc.newSvc.Namespace, tc.newSvc.Name, corev1.Resource("services").WithVersion("version"),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Dec 14 05:36:44 UTC 2021 - 3K bytes - Viewed (0) -
plugin/pkg/admission/storage/storageobjectinuseprotection/admission_test.go
pvWithFinalizer.Namespace, }, } for _, test := range tests { t.Run(test.name, func(t *testing.T) { ctrl := newPlugin() obj := test.object.DeepCopyObject() attrs := admission.NewAttributesRecord( obj, // new object obj.DeepCopyObject(), // old object, copy to be sure it's not modified schema.GroupVersionKind{}, test.namespace, "foo", test.resource,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 14 00:05:53 UTC 2023 - 3.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/delete.go
span.AddEvent("About to delete object from database") wasDeleted := true userInfo, _ := request.UserFrom(ctx) staticAdmissionAttrs := admission.NewAttributesRecord(nil, nil, scope.Kind, namespace, name, scope.Resource, scope.Subresource, admission.Delete, options, dryrun.IsDryRun(options.DryRun), userInfo) result, err := finisher.FinishRequest(ctx, func() (runtime.Object, error) {
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/endpoints/handlers/fieldmanager/admission_test.go
mutatedEntries := []metav1.ManagedFieldsEntry{mutated} obj := &v1.ConfigMap{} obj.SetManagedFields(validEntries) wrap.admit = replaceManagedFields(mutatedEntries) attrs := admission.NewAttributesRecord(obj, obj, schema.GroupVersionKind{}, "default", "", schema.GroupVersionResource{}, "", admission.Update, nil, false, nil) if err := ac.(admission.MutationInterface).Admit(context.TODO(), attrs, nil); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jan 12 21:32:54 UTC 2023 - 4.3K bytes - Viewed (0) -
plugin/pkg/admission/storage/storageclass/setdefault/admission_test.go
ctrl.SetExternalKubeInformerFactory(informerFactory) for _, c := range test.classes { informerFactory.Storage().V1().StorageClasses().Informer().GetStore().Add(c) } attrs := admission.NewAttributesRecord( claim, // new object nil, // old object api.Kind("PersistentVolumeClaim").WithVersion("version"), claim.Namespace, claim.Name,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 19 04:00:48 UTC 2022 - 7.6K bytes - Viewed (0) -
plugin/pkg/admission/podtolerationrestriction/admission_test.go
pod := test.pod pod.Spec.Tolerations = test.podTolerations 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)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 16K bytes - Viewed (0) -
plugin/pkg/admission/storage/persistentvolume/resize/admission_test.go
fmt.Println("add storageclass error: ", err) } } for _, tc := range tests { operation := admission.Update operationOptions := &metav1.CreateOptions{} attributes := admission.NewAttributesRecord(tc.newObj, tc.oldObj, schema.GroupVersionKind{}, metav1.NamespaceDefault, "foo", tc.resource, tc.subresource, operation, operationOptions, false, nil) err := ctrl.Validate(context.TODO(), attributes, nil)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Aug 21 13:31:28 UTC 2023 - 7.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/audit_test.go
a.AddAnnotation(k, v) } return h.validate } func (h fakeHandler) Handles(o Operation) bool { return h.handles } func attributes() Attributes { return NewAttributesRecord(nil, nil, schema.GroupVersionKind{}, "", "", schema.GroupVersionResource{}, "", "", nil, false, nil) } func TestWithAudit(t *testing.T) { var testCases = map[string]struct { admit error
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 03 16:16:51 UTC 2023 - 5.8K bytes - Viewed (0) -
plugin/pkg/admission/network/defaultingressclass/admission_test.go
} if testCase.classAnnotation != nil { ingress.Annotations = map[string]string{networkingv1beta1.AnnotationIngressClass: *testCase.classAnnotation} } attrs := admission.NewAttributesRecord( ingress, // new object nil, // old object api.Kind("Ingress").WithVersion("version"), ingress.Namespace, ingress.Name, networkingv1.Resource("ingresses").WithVersion("version"),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 04 13:12:32 UTC 2023 - 7.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/testing/testcase.go
Webhooks: webhooks, }) client := fakeclientset.NewSimpleClientset(objs...) informerFactory := informers.NewSharedInformerFactory(client, 0) return client, informerFactory } func newAttributesRecord(object metav1.Object, oldObject metav1.Object, kind schema.GroupVersionKind, namespace string, name string, resource string, labels map[string]string, dryRun bool) admission.Attributes { object.SetName(name)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 03 06:51:04 UTC 2023 - 47.6K bytes - Viewed (0)