Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 25 for NewAttributesRecord (0.27 sec)

  1. plugin/pkg/admission/admit/admission_test.go

    )
    
    func TestAdmissionNonNilAttribute(t *testing.T) {
    	handler := admissiontesting.WithReinvocationTesting(t, NewAlwaysAdmit().(*alwaysAdmit))
    	err := handler.Admit(context.TODO(), admission.NewAttributesRecord(nil, nil, api.Kind("kind").WithVersion("version"), "namespace", "name", api.Resource("resource").WithVersion("version"), "subresource", admission.Create, &metav1.CreateOptions{}, false, nil), nil)
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Aug 20 15:11:00 UTC 2019
    - 1.8K bytes
    - Viewed (0)
  2. plugin/pkg/admission/podnodeselector/admission_test.go

    		handler.clusterNodeSelectors[namespace.Name] = test.whitelist
    		pod.Spec = api.PodSpec{NodeSelector: test.podNodeSelector}
    
    		err := 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
    - 8K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. plugin/pkg/admission/nodetaint/admission_test.go

    			options:        &metav1.CreateOptions{},
    			expectedTaints: []api.Taint{notReadyTaint},
    		},
    	}
    	for _, tt := range tests {
    		t.Run(tt.name, func(t *testing.T) {
    			attributes := admission.NewAttributesRecord(&tt.node, &tt.oldNode, nodeKind, myNodeObj.Namespace, myNodeObj.Name, resource, "", tt.operation, tt.options, false, mynode)
    			c := NewPlugin()
    			err := c.Admit(context.TODO(), attributes, nil)
    			if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 06 04:56:21 UTC 2019
    - 3.1K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. plugin/pkg/admission/defaulttolerationseconds/admission_test.go

    							TolerationSeconds: genTolerationSeconds(700),
    						},
    					},
    				},
    			},
    		},
    	}
    
    	for _, test := range tests {
    		err := handler.Admit(context.TODO(), admission.NewAttributesRecord(&test.requestedPod, nil, api.Kind("Pod").WithVersion("version"), "foo", "name", api.Resource("pods").WithVersion("version"), "", "ignored", nil, false, nil), nil)
    		if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 06 04:56:21 UTC 2019
    - 8.8K bytes
    - Viewed (0)
  9. 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)
  10. 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)
Back to top