Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 101 for unstructured (0.39 sec)

  1. istioctl/pkg/validate/validate.go

    )
    
    type validator struct{}
    
    func checkFields(un *unstructured.Unstructured) error {
    	var errs error
    	for key := range un.Object {
    		if _, ok := validFields[key]; !ok {
    			errs = multierror.Append(errs, fmt.Errorf("unknown field %q", key))
    		}
    	}
    	return errs
    }
    
    func (v *validator) validateResource(istioNamespace, defaultNamespace string, un *unstructured.Unstructured, writer io.Writer) (validation.Warning, error) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jan 22 17:58:52 UTC 2024
    - 15K bytes
    - Viewed (0)
  2. 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)
  3. pilot/pkg/serviceregistry/kube/controller/serviceimportcache.go

    		return nil
    	})
    }
    
    func (ic *serviceImportCacheImpl) onServiceImportEvent(_, obj controllers.Object, event model.Event) error {
    	si := controllers.Extract[*unstructured.Unstructured](obj)
    	if si == nil {
    		return nil
    	}
    
    	// We need a full push if the cluster VIP changes.
    	needsFullPush := false
    
    	// Get the updated MCS service.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Feb 28 16:41:38 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiextensions-apiserver/test/integration/subresources_test.go

    							},
    						},
    						Schema: fixtures.AllowAllSchema(),
    					},
    				},
    			},
    		},
    	}
    }
    
    func NewNoxuSubresourceInstance(namespace, name, version string) *unstructured.Unstructured {
    	return &unstructured.Unstructured{
    		Object: map[string]interface{}{
    			"apiVersion": fmt.Sprintf("mygroup.example.com/%s", version),
    			"kind":       "WishIHadChosenNoxu",
    			"metadata": map[string]interface{}{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 12 17:35:34 UTC 2024
    - 33.2K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/plugin/pkg/authenticator/token/oidc/oidc.go

    }
    
    func convertObjectToUnstructured(obj interface{}) (*unstructured.Unstructured, error) {
    	if obj == nil || reflect.ValueOf(obj).IsNil() {
    		return &unstructured.Unstructured{Object: nil}, nil
    	}
    	ret, err := runtime.DefaultUnstructuredConverter.ToUnstructured(obj)
    	if err != nil {
    		return nil, err
    	}
    	return &unstructured.Unstructured{Object: ret}, nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 09 19:29:33 UTC 2024
    - 37.9K bytes
    - Viewed (0)
  6. operator/pkg/helmreconciler/prune.go

    func (h *HelmReconciler) GetPrunedResources(revision string, includeClusterResources bool, componentName string) (
    	[]*unstructured.UnstructuredList, error,
    ) {
    	var usList []*unstructured.UnstructuredList
    	labels := make(map[string]string)
    	if revision != "" {
    		labels[label.IoIstioRev.Name] = revision
    	}
    	if componentName != "" {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 02 08:32:06 UTC 2024
    - 15.9K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/policy_test_context.go

    			if scheme.Recognizes(mapping.GroupVersionKind) {
    				continue
    			}
    			scheme.AddKnownTypeWithName(mapping.GroupVersionKind, &unstructured.Unstructured{})
    			scheme.AddKnownTypeWithName(mapping.GroupVersionKind.GroupVersion().WithKind(mapping.GroupVersionKind.Kind+"List"), &unstructured.UnstructuredList{})
    		}
    
    		return scheme, nil
    	}()
    	if err != nil {
    		return nil, nil, err
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 06 00:00:21 UTC 2024
    - 19K bytes
    - Viewed (0)
  8. operator/cmd/mesh/uninstall.go

    	}
    }
    
    // constructResourceListOutput is a helper function to construct the output of to be removed resources list
    func constructResourceListOutput(resourcesList []*unstructured.UnstructuredList, objectsList object.K8sObjects) (string, string) {
    	var items []unstructured.Unstructured
    	if objectsList != nil {
    		items = objectsList.UnstructuredItems()
    	}
    	for _, usList := range resourcesList {
    		items = append(items, usList.Items...)
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Mar 15 01:18:49 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  9. 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)
  10. 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)
Back to top