Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for UnstructuredObject (0.26 sec)

  1. operator/pkg/helmreconciler/apply_test.go

    			}
    			if err := h.ApplyObject(obj.UnstructuredObject()); (err != nil) != tt.wantErr {
    				t.Errorf("HelmReconciler.ApplyObject() error = %v, wantErr %v", err, tt.wantErr)
    			}
    
    			manifest := loadData(t, tt.want)
    			key := client.ObjectKeyFromObject(manifest.UnstructuredObject())
    			got, want := obj.UnstructuredObject(), manifest.UnstructuredObject()
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Dec 12 17:12:54 UTC 2023
    - 4.9K bytes
    - Viewed (0)
  2. operator/pkg/helmreconciler/prune_test.go

    			t.Fatalf("failed parse k8s objects from yaml: %v", err)
    		}
    		for _, obj := range objects {
    			obju := obj.UnstructuredObject()
    			if err := h.applyLabelsAndAnnotations(obju, cn); err != nil {
    				t.Errorf("failed to apply label and annotations: %v", err)
    			}
    			if err := h.ApplyObject(obj.UnstructuredObject()); err != nil {
    				t.Errorf("HelmReconciler.ApplyObject() error = %v", err)
    			}
    		}
    	}
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Dec 15 12:13:37 UTC 2023
    - 5.2K bytes
    - Viewed (0)
  3. operator/pkg/helmreconciler/apply.go

    		objList.Sort(object.DefaultObjectOrder())
    		for _, obj := range objList {
    			obju := obj.UnstructuredObject()
    			if err := h.applyLabelsAndAnnotations(obju, cname); err != nil {
    				return result, err
    			}
    			if err := h.ApplyObject(obj.UnstructuredObject()); err != nil {
    				plog.ReportError(err.Error())
    				return result, err
    			}
    			plog.ReportProgress()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Dec 12 17:12:54 UTC 2023
    - 6.4K bytes
    - Viewed (0)
  4. tests/fuzz/helm_reconciler_fuzzer.go

    		return 0
    	}
    	k8obj, err := object.ParseYAMLToK8sObject(k8sobjBytes)
    	if err != nil {
    		return 0
    	}
    	m := name.Manifest{}
    	err = f.GenerateStruct(&m)
    	if err != nil {
    		return 0
    	}
    	obj := k8obj.UnstructuredObject()
    	gvk := obj.GetObjectKind().GroupVersionKind()
    	if len(gvk.Kind) == 0 {
    		return 0
    	}
    	if len(gvk.Version) == 0 {
    		return 0
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Dec 12 17:12:54 UTC 2023
    - 1.6K bytes
    - Viewed (0)
  5. operator/pkg/object/objects.go

    	if len(objects) == 0 || objects[0] == nil {
    		return nil, fmt.Errorf("decoding object %v: %v", string(yaml), "no object found")
    	}
    	return objects[0], nil
    }
    
    // UnstructuredObject exposes the raw object, primarily for testing
    func (o *K8sObject) UnstructuredObject() *unstructured.Unstructured {
    	return o.object
    }
    
    // ResolveK8sConflict - This method resolves k8s object possible
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Sep 21 07:16:46 UTC 2023
    - 15.5K bytes
    - Viewed (0)
  6. operator/pkg/translate/translate_test.go

    			assert.NoError(t, err)
    			obj, err := translator.fixMergedObjectWithCustomServicePortOverlay(serviceObj,
    				iop.Components.IngressGateways[0].GetK8S().GetService(), serviceObj)
    			assert.NoError(t, err)
    			val := obj.UnstructuredObject().Object["spec"].(map[string]interface{})["ports"].([]interface{})[0]
    			apVal, found, _ := tpath.GetFromStructPath(val, "appProtocol")
    			if !tt.expectExist {
    				assert.Equal(t, found, false)
    			} else {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Feb 12 19:43:09 UTC 2024
    - 5.1K bytes
    - Viewed (0)
  7. operator/cmd/mesh/test-util_test.go

    			ret.append(obj)
    		}
    	}
    	return ret
    }
    
    // HasLabel reports whether 0 has the given label.
    func hasLabel(o *object.K8sObject, label, value string) bool {
    	got, found, err := tpath.Find(o.UnstructuredObject().UnstructuredContent(), util.PathFromString("metadata.labels"))
    	if err != nil {
    		log.Errorf("bad path: %s", err)
    		return false
    	}
    	if !found {
    		return false
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Oct 31 14:48:28 UTC 2023
    - 15.3K bytes
    - Viewed (0)
  8. operator/pkg/helmreconciler/prune.go

    func (h *HelmReconciler) deleteResource(obj *object.K8sObject, componentName, oh string) error {
    	if h.opts.DryRun {
    		h.opts.Log.LogAndPrintf("Not pruning object %s because of dry run.", oh)
    		return nil
    	}
    	u := obj.UnstructuredObject()
    	if u.GetKind() == name.IstioOperatorStr {
    		u.SetFinalizers([]string{})
    		if err := h.client.Patch(context.TODO(), u, client.Merge); err != nil {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 02 08:32:06 UTC 2024
    - 15.9K bytes
    - Viewed (0)
Back to top