Skip to content

Commit cacde34

Browse files
committed
Uses constants
1 parent fb413b7 commit cacde34

File tree

1 file changed

+20
-19
lines changed

1 file changed

+20
-19
lines changed

pkg/patterns/declarative/reconciler.go

Lines changed: 20 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -295,8 +295,8 @@ func (r *Reconciler) reconcileExists(ctx context.Context, name types.NamespacedN
295295
return reconcile.Result{}, fmt.Errorf("instance %T was not an addonsv1alpha1.CommonObject", instance)
296296
}
297297
status := addonObject.GetCommonStatus()
298-
if status.Phase != aggregateStatus(statusMap) {
299-
status.Phase = aggregateStatus(statusMap)
298+
if status.Phase != string(aggregateStatus(statusMap)) {
299+
status.Phase = string(aggregateStatus(statusMap))
300300
addonObject.SetCommonStatus(status)
301301
log.WithValues("name", addonObject.GetName()).WithValues("status", status).Info("updating status")
302302

@@ -593,7 +593,24 @@ func (r *Reconciler) CollectMetrics() bool {
593593
return r.options.metrics
594594
}
595595

596-
func getObjectFromCluster(obj *manifest.Object, r *Reconciler) (*unstructured.Unstructured, error) {
596+
func aggregateStatus(m map[status.Status]bool) status.Status {
597+
inProgress := m[status.InProgressStatus]
598+
terminating := m[status.TerminatingStatus]
599+
600+
failed := m[status.FailedStatus]
601+
602+
if inProgress || terminating {
603+
return status.TerminatingStatus
604+
}
605+
606+
if failed {
607+
return status.FailedStatus
608+
}
609+
return status.CurrentStatus
610+
}
611+
612+
func getObjectFromCluster(obj *manifest.Object, r *Reconciler) (*unstructured.
613+
Unstructured, error) {
597614
getOptions := metav1.GetOptions{}
598615
gvk := obj.GroupVersionKind()
599616

@@ -609,19 +626,3 @@ func getObjectFromCluster(obj *manifest.Object, r *Reconciler) (*unstructured.Un
609626
}
610627
return unstruct, nil
611628
}
612-
613-
func aggregateStatus(m map[status.Status]bool) string {
614-
inProgress := m["InProgress"]
615-
terminating := m["Terminating"]
616-
617-
failed := m["Failed"]
618-
619-
if inProgress || terminating {
620-
return "InProgress"
621-
}
622-
623-
if failed {
624-
return "Failed"
625-
}
626-
return "Current"
627-
}

0 commit comments

Comments
 (0)