Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for NewHelmReconciler (0.32 sec)

  1. tests/fuzz/helm_reconciler_fuzzer.go

    	if len(gvk.Kind) == 0 {
    		return 0
    	}
    	if len(gvk.Version) == 0 {
    		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)
  2. operator/cmd/mesh/shared.go

    ) error {
    	// Needed in case we are running a test through this path that doesn't start a new process.
    	cache.FlushObjectCaches()
    	reconciler, err := helmreconciler.NewHelmReconciler(client, kubeClient, iop, &helmreconciler.Options{DryRun: opts.DryRun, Log: l})
    	if err != nil {
    		l.LogAndError(err)
    		return err
    	}
    	ms := name.Manifest{
    		Name:    componentName,
    		Content: manifestStr,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Mar 29 02:29:02 UTC 2024
    - 5.1K bytes
    - Viewed (0)
  3. operator/cmd/mesh/manifest_shared_test.go

    }
    
    // fakeApplyExtraResources applies any extra resources for the given test name.
    func fakeApplyExtraResources(inFile string) error {
    	reconciler, err := helmreconciler.NewHelmReconciler(testClient, nil, nil, nil)
    	if err != nil {
    		return err
    	}
    
    	if rs, err := readFile(filepath.Join(testDataDir, "input-extra-resources", inFile+".yaml")); err == nil {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Feb 20 22:39:28 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  4. operator/cmd/mesh/operator-remove.go

    		iop, err = translate.IOPStoIOP(emptyiops, "", "")
    		if err != nil {
    			l.LogAndFatal(err)
    		}
    	}
    	reconciler, err := helmreconciler.NewHelmReconciler(client, kubeClient, iop, &helmreconciler.Options{DryRun: args.DryRun, Log: l})
    	if err != nil {
    		l.LogAndFatal(err)
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Mar 15 01:18:49 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  5. operator/pkg/controller/istiocontrolplane/istiocontrolplane_controller.go

    			metrics.CRDeletionTotal.Increment()
    			return reconcile.Result{}, nil
    		}
    		scope.Infof("Deleting IstioOperator %s", iopName)
    
    		reconciler, err := helmreconciler.NewHelmReconciler(r.client, r.kubeClient, iopMerged, nil)
    		if err != nil {
    			return reconcile.Result{}, err
    		}
    		if err := reconciler.Delete(); err != nil {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 30 13:56:46 UTC 2024
    - 19.4K bytes
    - Viewed (0)
  6. operator/pkg/helmreconciler/reconciler.go

    	// SkipPrune will skip pruning
    	SkipPrune bool
    }
    
    var defaultOptions = &Options{
    	Log:         clog.NewDefaultLogger(),
    	ProgressLog: progress.NewLog(),
    }
    
    // NewHelmReconciler creates a HelmReconciler and returns a ptr to it
    func NewHelmReconciler(client client.Client, kubeClient kube.Client, iop *istioV1Alpha1.IstioOperator, opts *Options) (*HelmReconciler, error) {
    	if opts == nil {
    		opts = defaultOptions
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Feb 22 08:32:23 UTC 2024
    - 22K bytes
    - Viewed (0)
  7. operator/pkg/verifier/verifier.go

    	iop, err := translate.IOPStoIOP(emptyiops, "", "")
    	if err != nil {
    		return err
    	}
    	h, err := helmreconciler.NewHelmReconciler(v.kclient, v.client, iop, &helmreconciler.Options{})
    	if err != nil {
    		return err
    	}
    	resources, err := h.GetPrunedResources(v.controlPlaneOpts.Revision, true, "")
    	if err != nil {
    		return err
    	}
    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/cmd/mesh/uninstall.go

    			applyFlagAliases(uiArgs.set, uiArgs.manifestsPath, uiArgs.revision), uiArgs.force, nil, kubeClient, l)
    		if err != nil {
    			return err
    		}
    		iop.Name = savedIOPName(iop)
    	}
    
    	h, err = helmreconciler.NewHelmReconciler(client, kubeClient, iop, opts)
    	if err != nil {
    		return fmt.Errorf("failed to create reconciler: %v", err)
    	}
    	objectsList, err := h.GetPrunedResources(uiArgs.revision, uiArgs.purge, "")
    	if err != nil {
    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. operator/cmd/mesh/install.go

    	cache.FlushObjectCaches()
    	opts := &helmreconciler.Options{
    		DryRun: dryRun, Log: l, WaitTimeout: waitTimeout, ProgressLog: progress.NewLog(),
    		Force: force,
    	}
    	reconciler, err := helmreconciler.NewHelmReconciler(client, kubeClient, iop, opts)
    	if err != nil {
    		return err
    	}
    	status, err := reconciler.Reconcile()
    	if err != nil {
    		return fmt.Errorf("errors occurred during operation: %v", err)
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 17 21:52:35 UTC 2024
    - 15.4K bytes
    - Viewed (0)
Back to top