Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for ApplyObject (0.15 sec)

  1. staging/src/k8s.io/apimachinery/pkg/util/managedfields/internal/managedfieldsupdater_test.go

    	err = applyObject(f, "fieldmanager_test", []byte(`{
    		"apiVersion": "v1",
    		"kind": "ConfigMap",
    		"metadata": {
    			"name": "configmap"
    		},
    		"data": {
    			"key": "value"
    		}
    	}`))
    	if err != nil {
    		t.Fatal(err)
    	}
    	previousManagedFields := f.ManagedFields()
    
    	time.Sleep(time.Second)
    
    	err = applyObject(f, "fieldmanager_test", []byte(`{
    		"apiVersion": "v1",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 08 21:44:00 UTC 2023
    - 13.2K bytes
    - Viewed (0)
  2. operator/pkg/helmreconciler/testdata/configmap-changed.yaml

    apiVersion: v1
    kind: ConfigMap
    metadata:
      creationTimestamp: null
      name: config
      namespace: istio-system
    data:
      # Can't delete a field until we mandate >= Kube 1.16. See ApplyObject comments.
      field: two
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Sep 22 16:53:35 UTC 2021
    - 220 bytes
    - Viewed (0)
  3. operator/pkg/helmreconciler/apply.go

    			plog.ReportError(werr.Error())
    			return result, werr
    		}
    		plog.ReportFinished()
    
    	}
    	return result, nil
    }
    
    // ApplyObject creates or updates an object in the API server depending on whether it already exists.
    // It mutates obj.
    func (h *HelmReconciler) ApplyObject(obj *unstructured.Unstructured) error {
    	if obj.GetKind() == "List" {
    		var errs util.Errors
    		list, err := obj.ToList()
    		if err != nil {
    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. operator/pkg/helmreconciler/apply_test.go

    					Spec: &v1alpha12.IstioOperatorSpec{},
    				},
    				countLock:     &sync.Mutex{},
    				prunedKindSet: map[schema.GroupKind]struct{}{},
    			}
    			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())
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Dec 12 17:12:54 UTC 2023
    - 4.9K bytes
    - Viewed (0)
  5. operator/pkg/helmreconciler/prune_test.go

    			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)
    			}
    		}
    	}
    }
    
    func TestHelmReconciler_GetPrunedResources(t *testing.T) {
    	t.Run("get gateway pruned resources", func(t *testing.T) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Dec 15 12:13:37 UTC 2023
    - 5.2K bytes
    - Viewed (0)
  6. tests/fuzz/helm_reconciler_fuzzer.go

    		return 0
    	}
    	cl := &fakeClientWrapper{fake.NewClientBuilder().WithRuntimeObjects(obj).Build()}
    	h, err := helmreconciler.NewHelmReconciler(cl, nil, nil, nil)
    	if err != nil {
    		return 0
    	}
    	_ = h.ApplyObject(obj)
    	_, _ = h.Reconcile()
    	_, _ = h.ApplyManifest(m)
    	return 1
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Dec 12 17:12:54 UTC 2023
    - 1.6K bytes
    - Viewed (0)
Back to top