Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for toUnstructured (0.18 sec)

  1. pkg/api/testing/unstructured_test.go

    		t.Errorf("Object changed during JSON operations, diff: %v", cmp.Diff(item, unmarshalledObj))
    		return
    	}
    
    	newUnstr, err := runtime.DefaultUnstructuredConverter.ToUnstructured(item)
    	if err != nil {
    		t.Errorf("ToUnstructured failed: %v", err)
    		return
    	}
    
    	newObj := reflect.New(reflect.TypeOf(item).Elem()).Interface().(runtime.Object)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 21:48:10 UTC 2024
    - 16.9K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/validating/dispatcher.go

    	return errors.New("UnmarshalJSON unimplemented for wrappedParam")
    }
    
    func (w *wrappedParam) ToUnstructured() interface{} {
    	res, err := runtime.DefaultUnstructuredConverter.ToUnstructured(w.nested)
    
    	if err != nil {
    		return nil
    	}
    
    	metaRes, err := runtime.DefaultUnstructuredConverter.ToUnstructured(&w.TypeMeta)
    	if err != nil {
    		return nil
    	}
    
    	for k, v := range metaRes {
    		res[k] = v
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 06 00:00:21 UTC 2024
    - 14.4K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apimachinery/pkg/apis/meta/v1/time.go

    func (t Time) MarshalCBOR() ([]byte, error) {
    	if t.IsZero() {
    		return cbor.Marshal(nil)
    	}
    
    	return cbor.Marshal(t.UTC().Format(time.RFC3339))
    }
    
    // ToUnstructured implements the value.UnstructuredConverter interface.
    func (t Time) ToUnstructured() interface{} {
    	if t.IsZero() {
    		return nil
    	}
    	buf := make([]byte, 0, len(time.RFC3339))
    	buf = t.UTC().AppendFormat(buf, time.RFC3339)
    	return string(buf)
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 21:48:09 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  4. pilot/pkg/serviceregistry/kube/controller/autoserviceexportcontroller.go

    					Kind:       gvk.Service.Kind,
    					Name:       svc.Name,
    					UID:        svc.UID,
    				},
    			},
    		},
    	}
    
    	// Convert to unstructured.
    	u, err := runtime.DefaultUnstructuredConverter.ToUnstructured(&serviceExport)
    	if err != nil {
    		log.Warnf("%s failed converting ServiceExport %s/%s to Unstructured: %v", c.logPrefix(),
    			svc.Namespace, svc.Name, err)
    		return err
    	}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Feb 28 16:41:38 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  5. tests/integration/pilot/mcs/discoverability/discoverability_test.go

    	serviceImportGVR := common.KubeSettings(t).ServiceImportGVR()
    
    	serviceExport := newServiceExport(service, serviceExportGVR)
    
    	u, err := runtime.DefaultUnstructuredConverter.ToUnstructured(serviceExport)
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	// Create the ServiceExports in each cluster concurrently.
    	g := errgroup.Group{}
    	for _, c := range exportClusters {
    		c := c
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Apr 08 22:02:59 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apimachinery/pkg/api/resource/quantity.go

    	// The call to String() should never return the string "<nil>" because the receiver's
    	// address will never be nil.
    	return cbor.Marshal(q.String())
    }
    
    // ToUnstructured implements the value.UnstructuredConverter interface.
    func (q Quantity) ToUnstructured() interface{} {
    	return q.String()
    }
    
    // UnmarshalJSON implements the json.Unmarshaller interface.
    // TODO: Remove support for leading/trailing whitespace
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 21:48:10 UTC 2024
    - 23.8K bytes
    - Viewed (0)
  7. operator/pkg/verifier/verifier.go

    	istioDeploymentCount := 0
    	daemonSetCount := 0
    	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()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 14 19:23:44 UTC 2024
    - 15K bytes
    - Viewed (0)
  8. operator/pkg/controller/istiocontrolplane/istiocontrolplane_controller.go

    			obj, err := meta.Accessor(e.Object)
    			if err != nil {
    				return false
    			}
    			scope.Debugf("got delete event for %s.%s", obj.GetName(), obj.GetNamespace())
    			unsObj, err := runtime.DefaultUnstructuredConverter.ToUnstructured(e.Object)
    			if err != nil {
    				return false
    			}
    			if isOperatorCreatedResource(obj) {
    				crName := obj.GetLabels()[helmreconciler.OwningResourceName]
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 30 13:56:46 UTC 2024
    - 19.4K bytes
    - Viewed (0)
  9. pilot/pkg/config/file/store.go

    func ToConfig(object metav1.Object, schema sresource.Schema, source resource.Reference, fieldMap map[string]int) (*config.Config, error) {
    	m, err := runtime.DefaultUnstructuredConverter.ToUnstructured(object)
    	if err != nil {
    		return nil, err
    	}
    	u := &unstructured.Unstructured{Object: m}
    	if len(fieldMap) > 0 || source != nil {
    		// TODO: populate
    		annots := u.GetAnnotations()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Feb 02 17:36:47 UTC 2024
    - 18.2K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiserver/pkg/endpoints/handlers/patch.go

    	patchBytes []byte,
    	objToUpdate runtime.Object,
    	schemaReferenceObj runtime.Object,
    	validationDirective string,
    ) error {
    	originalObjMap, err := runtime.DefaultUnstructuredConverter.ToUnstructured(originalObject)
    	if err != nil {
    		return err
    	}
    
    	patchMap := make(map[string]interface{})
    	var strictErrs []error
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 28 08:48:22 UTC 2024
    - 28.5K bytes
    - Viewed (0)
Back to top