- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 25 for NewAttributesRecord (0.27 sec)
-
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) -
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) -
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) -
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) -
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/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) -
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)