Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 45 for NewAttributesRecord (0.43 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top