Skip to content

Commit a795785

Browse files
committed
fix review comments
1 parent 0536682 commit a795785

File tree

3 files changed

+9
-6
lines changed

3 files changed

+9
-6
lines changed

pkg/helm/templatereconciler/chart.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -38,12 +38,12 @@ func orderedChartObjectsWithState(releaseData *ReleaseData) ([]runtime.Object, r
3838
func chartObjects(releaseData *ReleaseData) ([]runtime.Object, error) {
3939
chartDefaultValues, err := helm.GetDefaultValues(releaseData.Chart)
4040
if err != nil {
41-
return nil, errors.WrapIf(err, "could not get prometheus helm default values")
41+
return nil, errors.WrapIff(err, "could not get chart default values for %s", releaseData.ChartName)
4242
}
4343

4444
chartDefaultValuesYaml := helm.Strimap{}
4545
if err := yaml.Unmarshal(chartDefaultValues, &chartDefaultValuesYaml); err != nil {
46-
return nil, errors.WrapIf(err, "could not marshal default values")
46+
return nil, errors.WrapIff(err, "could not marshal default values for %s", releaseData.ChartName)
4747
}
4848

4949
objects, err := helm.Render(releaseData.Chart, helm.MergeMaps(chartDefaultValuesYaml, releaseData.Values), helm.ReleaseOptions{

pkg/helm/templatereconciler/reconciler.go

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@ import (
2424
"github.com/banzaicloud/operator-tools/pkg/reconciler"
2525
"github.com/banzaicloud/operator-tools/pkg/types"
2626
"github.com/go-logr/logr"
27-
v1 "k8s.io/api/core/v1"
27+
"k8s.io/api/core/v1"
2828
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
2929
"k8s.io/client-go/discovery"
3030
controllerruntime "sigs.k8s.io/controller-runtime"
@@ -87,11 +87,14 @@ func (rec *HelmReconciler) Reconcile(object runtime.Object, component Component)
8787
return &reconcile.Result{}, nil
8888
}
8989

90+
if err := component.UpdateStatus(object, types.ReconcileStatusReconciling, ""); err != nil {
91+
rec.logger.Error(err, "status update failed")
92+
}
9093
rec.logger.Info("reconciling")
9194

9295
if component.Enabled(object) {
9396
if err := component.PreChecks(object); err != nil {
94-
if err := component.UpdateStatus(object, types.ReconcileStatusReconciling, err.Error()); err != nil {
97+
if err := component.UpdateStatus(object, types.ReconcileStatusReconciling, "waiting for precondition checks to pass"); err != nil {
9598
rec.logger.Error(err, "status update failed")
9699
}
97100
rec.logger.Error(err, "precondition checks failed")
@@ -168,7 +171,7 @@ func (rec *HelmReconciler) reconcile(parent reconciler.ResourceOwner, component
168171
func(_ reconciler.ResourceOwner, _ interface{}) []reconciler.ResourceBuilder {
169172
return resourceBuilders
170173
},
171-
rec.inventory.Purge,
174+
rec.inventory.TypesToPurge,
172175
func(_ runtime.Object) (reconciler.ResourceOwner, interface{}) {
173176
return nil, nil
174177
},

pkg/inventory/inventory.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -141,7 +141,7 @@ func GetObjectsFromInventory(inventory core.ConfigMap) []runtime.Object {
141141
}
142142

143143
// Hand over a GVK list to the native reconcile loop's purge method
144-
func (c *Inventory) Purge() []schema.GroupVersionKind {
144+
func (c *Inventory) TypesToPurge() []schema.GroupVersionKind {
145145
currentObjects := c.inventoryData.ObjectsToDelete
146146
groupVersionKindDict := make(map[schema.GroupVersionKind]struct{})
147147

0 commit comments

Comments
 (0)