Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 125 for unstructured (0.38 sec)

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