refactor

Signed-off-by: odubajDT <[email protected]>

metrics-operator/api/v1alpha3/analysis_types.go

@@ -86,10 +86,3 @@ type Timeframe struct {
 func init() {
 	SchemeBuilder.Register(&Analysis{}, &AnalysisList{})
 }
-
-func (a *Analysis) GetAnalysisDefinitionNamespace() string {
-	if !a.Spec.AnalysisDefinition.IsNamespaceSet() {
-		return a.Namespace
-	}
-	return a.Spec.AnalysisDefinition.Namespace
-}

metrics-operator/api/v1alpha3/analysisdefinition_types.go

@@ -124,10 +124,3 @@ func init() {
 func (o *OperatorValue) GetFloatValue() float64 {
 	return o.FixedValue.AsApproximateFloat64()
 }
-
-func (o *Objective) GetAnalysisValueTemplateNamespace(namespace string) string {
-	if !o.AnalysisValueTemplateRef.IsNamespaceSet() {
-		return namespace
-	}
-	return o.AnalysisValueTemplateRef.Namespace
-}

metrics-operator/api/v1alpha3/analysisdefinition_types_test.go

@@ -14,15 +14,3 @@ func TestOperatorValue_GetFloatValue(t *testing.T) {
 
 	require.Equal(t, 15.0, o.GetFloatValue())
 }
-
-func TestObjective_GetAnalysisValueTemplateNamespace(t *testing.T) {
-	o := Objective{
-		AnalysisValueTemplateRef: ObjectReference{},
-	}
-
-	require.Equal(t, "default", o.GetAnalysisValueTemplateNamespace("default"))
-
-	o.AnalysisValueTemplateRef.Namespace = "ns"
-
-	require.Equal(t, "ns", o.GetAnalysisValueTemplateNamespace("default"))
-}

metrics-operator/api/v1alpha3/analysisvaluetemplate_types.go

@@ -56,10 +56,3 @@ type AnalysisValueTemplateList struct {
 func init() {
 	SchemeBuilder.Register(&AnalysisValueTemplate{}, &AnalysisValueTemplateList{})
 }
-
-func (a *AnalysisValueTemplate) GetProviderNamespace(namespace string) string {
-	if !a.Spec.Provider.IsNamespaceSet() {
-		return namespace
-	}
-	return a.Spec.Provider.Namespace
-}

metrics-operator/api/v1alpha3/common.go

@@ -10,3 +10,11 @@ type ObjectReference struct {
 func (o *ObjectReference) IsNamespaceSet() bool {
 	return o.Namespace != ""
 }
+
+func (o *ObjectReference) GetNamespace(defaultNamespace string) string {
+	if o.IsNamespaceSet() {
+		return o.Namespace
+	}
+
+	return defaultNamespace
+}

metrics-operator/api/v1alpha3/common_test.go

@@ -15,3 +15,13 @@ func TestObjectReference_IsNamespaceSet(t *testing.T) {
 
 	require.True(t, o.IsNamespaceSet())
 }
+
+func TestObjectReference_GetNamespace(t *testing.T) {
+	o := ObjectReference{}
+
+	require.Equal(t, "default", o.GetNamespace("default"))
+
+	o.Namespace = "ns"
+
+	require.Equal(t, "ns", o.GetNamespace("default"))
+}

metrics-operator/controllers/analysis/controller.go

@@ -72,11 +72,12 @@ func (a *AnalysisReconciler) Reconcile(ctx context.Context, req ctrl.Request) (c
 	}
 
 	//find AnalysisDefinition to have the collection of Objectives
+	analysisDefNamespace := analysis.Spec.AnalysisDefinition.GetNamespace(analysis.Namespace)
 	analysisDef := &metricsapi.AnalysisDefinition{}
 	err := a.Client.Get(ctx,
 		types.NamespacedName{
 			Name:      analysis.Spec.AnalysisDefinition.Name,
-			Namespace: analysis.GetAnalysisDefinitionNamespace()},
+			Namespace: analysisDefNamespace},
 		analysisDef,
 	)
 
@@ -85,7 +86,7 @@ func (a *AnalysisReconciler) Reconcile(ctx context.Context, req ctrl.Request) (c
 			a.Log.Info(
 				fmt.Sprintf("AnalysisDefinition '%s' in namespace '%s' not found, requeue",
 					analysis.Spec.AnalysisDefinition.Name,
-					analysis.GetAnalysisDefinitionNamespace()),
+					analysisDefNamespace),
 			)
 			return ctrl.Result{Requeue: true, RequeueAfter: 10 * time.Second}, nil
 		}
@@ -103,7 +104,7 @@ func (a *AnalysisReconciler) Reconcile(ctx context.Context, req ctrl.Request) (c
 	}
 
 	//create multiple workers handling the Objectives
-	childCtx, wp := a.NewWorkersPoolFactory(ctx, analysis, todo, a.MaxWorkers, a.Client, a.Log, analysis.GetAnalysisDefinitionNamespace())
+	childCtx, wp := a.NewWorkersPoolFactory(ctx, analysis, todo, a.MaxWorkers, a.Client, a.Log, analysisDefNamespace)
 
 	res, err := wp.DispatchAndCollect(childCtx)
 	if err != nil {

metrics-operator/controllers/analysis/provider_selector.go

@@ -57,7 +57,7 @@ func (ps ProvidersPool) DispatchToProviders(ctx context.Context, id int) {
 			err := ps.Client.Get(ctx,
 				types.NamespacedName{
 					Name:      j.AnalysisValueTemplateRef.Name,
-					Namespace: j.GetAnalysisValueTemplateNamespace(ps.Namespace)},
+					Namespace: j.AnalysisValueTemplateRef.GetNamespace(ps.Namespace)},
 				templ,
 			)
 
@@ -68,12 +68,11 @@ func (ps ProvidersPool) DispatchToProviders(ctx context.Context, id int) {
 				return
 			}
 
-			ns := templ.GetProviderNamespace(ps.Namespace)
 			providerRef := &metricsapi.KeptnMetricsProvider{}
 			err = ps.Client.Get(ctx,
 				types.NamespacedName{
 					Name:      templ.Spec.Provider.Name,
-					Namespace: ns},
+					Namespace: templ.Spec.Provider.GetNamespace(ps.Namespace)},
 				providerRef,
 			)