Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for NewHelmReconciler (0.3 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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