- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for NewHelmReconciler (0.32 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)