- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 125 for unstructured (0.38 sec)
-
operator/pkg/verifier/verifier.go
err := visitor.Visit(func(info *resource.Info, err error) error { if err != nil { return err } content, err := runtime.DefaultUnstructuredConverter.ToUnstructured(info.Object) if err != nil { return err } un := &unstructured.Unstructured{Object: content} kind := un.GetKind() name := un.GetName() namespace := un.GetNamespace() kinds := resourceKinds(un) if namespace == "" {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 19:23:44 UTC 2024 - 15K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/test/integration/ratcheting_test.go
) return func(new, old *unstructured.Unstructured) { _ = strategy.ValidateUpdate(context.TODO(), new, old) }, nil } // Recursively walks the provided directory and parses the YAML files into // unstructured objects. If there are more than one object in a single file, // they are all added to the returned slice. func loadObjects(dir string) []*unstructured.Unstructured { result := []*unstructured.Unstructured{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 28 08:48:22 UTC 2024 - 59.5K bytes - Viewed (0) -
pkg/kube/controllers/common.go
// IsNil works around comparing generic types func IsNil[O ComparableObject](o O) bool { var t O return o == t } // UnstructuredToGVR extracts the GVR of an unstructured resource. This is useful when using dynamic // clients. func UnstructuredToGVR(u unstructured.Unstructured) (schema.GroupVersionResource, error) { res := schema.GroupVersionResource{} gv, err := schema.ParseGroupVersion(u.GetAPIVersion()) if err != nil { return res, err
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 11 08:27:29 UTC 2024 - 8.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/mutating/dispatcher.go
} var newVersionedObject runtime.Object if _, ok := attr.VersionedObject.(*unstructured.Unstructured); ok { // Custom Resources don't have corresponding Go struct's. // They are represented as Unstructured. newVersionedObject = &unstructured.Unstructured{} } else { newVersionedObject, err = o.GetObjectCreater().New(attr.VersionedKind) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 28 08:48:22 UTC 2024 - 19.6K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/test/integration/fieldselector_test.go
shirtv1Client := dynamicClient.Resource(schema.GroupVersionResource{Group: crd.Spec.Group, Version: crd.Spec.Versions[0].Name, Resource: crd.Spec.Names.Plural}) for _, instance := range []string{shirtInstance1} { shirt := &unstructured.Unstructured{} if err := yaml.Unmarshal([]byte(instance), &shirt.Object); err != nil { t.Fatal(err) } _, err = shirtv1Client.Create(ctx, shirt, metav1.CreateOptions{}) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 06 15:53:03 UTC 2024 - 27K bytes - Viewed (0) -
tests/integration/pilot/mcs/discoverability/discoverability_test.go
Ports: ports, }, } u, err := runtime.DefaultUnstructuredConverter.ToUnstructured(serviceImport) if err != nil { panic(err) } // Create the ServiceImport. _, err = c.Dynamic().Resource(serviceImportGVR).Namespace(echos.Namespace.Name()).Create( context.TODO(), &unstructured.Unstructured{Object: u}, metav1.CreateOptions{}) if err != nil && !kerrors.IsAlreadyExists(err) { return err }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 17.9K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/cmd/server/options/options.go
"k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/v1beta1" "k8s.io/apiextensions-apiserver/pkg/apiserver" generatedopenapi "k8s.io/apiextensions-apiserver/pkg/generated/openapi" "k8s.io/apimachinery/pkg/apis/meta/v1/unstructured" utilerrors "k8s.io/apimachinery/pkg/util/errors" openapinamer "k8s.io/apiserver/pkg/endpoints/openapi" genericregistry "k8s.io/apiserver/pkg/registry/generic" genericapiserver "k8s.io/apiserver/pkg/server"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 17:57:37 UTC 2024 - 6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/rest_test.go
} func TestPatchCustomResource(t *testing.T) { testGV := schema.GroupVersion{Group: "mygroup.example.com", Version: "v1beta1"} scheme.AddKnownTypes(testGV, &unstructured.Unstructured{}) defaulter := runtime.ObjectDefaulter(scheme) original := &unstructured.Unstructured{ Object: map[string]interface{}{ "apiVersion": "mygroup.example.com/v1beta1", "kind": "Noxu", "metadata": map[string]interface{}{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 28 08:48:22 UTC 2024 - 41.8K bytes - Viewed (0) -
pkg/config/schema/kubeclient/common.go
options.FieldSelector = opts.FieldSelector options.LabelSelector = opts.LabelSelector return c.Dynamic().Resource(g).Namespace(opts.Namespace).Watch(context.Background(), options) }, }, &unstructured.Unstructured{}, cache.SharedIndexInformerOptions{ ResyncPeriod: 0, Indexers: cache.Indexers{cache.NamespaceIndex: cache.MetaNamespaceIndexFunc}, ObjectDescription: g.String(), }, )
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 16:38:40 UTC 2024 - 8.1K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/finalizer/crd_finalizer.go
listObj, err := crClient.List(ctx, nil) if err != nil { return false, err } if len(listObj.(*unstructured.UnstructuredList).Items) == 0 { return true, nil } klog.V(2).Infof("%s.%s waiting for %d items to be removed", crd.Status.AcceptedNames.Plural, crd.Spec.Group, len(listObj.(*unstructured.UnstructuredList).Items)) return false, nil }) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 12.6K bytes - Viewed (0)