Clowdapp Dependency metrics

controllers/cloud.redhat.com/clowdapp_reconciliation.go

@@ -89,6 +89,41 @@ func (r *ClowdAppReconciliation) stopMetrics() (ctrl.Result, error) {
 	return ctrl.Result{}, nil
 }
 
+func reportDependencies(ctx context.Context, pClient client.Client, o *crd.ClowdApp) (ctrl.Result, error) {
+	// get parent clowdapp name
+	var appName string = o.Name
+	var dependencies []string
+
+	// get dependencies and optional dependencies
+	dependencies = append(dependencies, o.Spec.Dependencies...)
+	dependencies = append(dependencies, o.Spec.OptionalDependencies...)
+
+	applist := crd.ClowdAppList{}
+
+	err := pClient.List(ctx, &applist, client.MatchingFields{"spec.envName": o.Spec.EnvName})
+
+	if err != nil {
+		return ctrl.Result{}, err
+	}
+
+	// for each dependency
+	for _, dependency := range dependencies {
+		//   get child clowdapp with name of dependency
+		for _, app := range applist.Items {
+			if app.Name == dependency {
+				//	 report child clowdapp availability
+				if app.Status.Ready {
+					dependencyMetrics.With(prometheus.Labels{"app": appName, "dependency": dependency}).Set(1.0)
+				} else {
+					dependencyMetrics.With(prometheus.Labels{"app": appName, "dependency": dependency}).Set(0.0)
+				}
+			}
+		}
+	}
+
+	return ctrl.Result{}, nil
+}
+
 func (r *ClowdAppReconciliation) setPresentAndManagedApps() (ctrl.Result, error) {
 	presentApps[r.app.GetIdent()] = true
 
@@ -358,6 +393,11 @@ func (r *ClowdAppReconciliation) deletedUnusedResources() (ctrl.Result, error) {
 }
 
 func (r *ClowdAppReconciliation) setReconciliationSuccessful() (ctrl.Result, error) {
+	_, err := reportDependencies(r.ctx, r.client, r.app)
+	if err != nil {
+		r.log.Info("Error during depency metric reporting", "err", err)
+	}
+
 	if setClowdStatusErr := SetClowdAppConditions(r.ctx, r.client, r.app, crd.ReconciliationSuccessful, r.oldStatus, nil); setClowdStatusErr != nil {
 		r.log.Info("Set status error", "err", setClowdStatusErr)
 		return ctrl.Result{Requeue: true}, setClowdStatusErr

controllers/cloud.redhat.com/metrics.go

@@ -95,6 +95,13 @@ var (
 		},
 		[]string{"app", "env"},
 	)
+	dependencyMetrics = prometheus.NewGaugeVec(
+		prometheus.GaugeOpts{
+			Name: "clowder_dependency_availability",
+			Help: "Clowder dependency availability",
+		},
+		[]string{"app", "dependency"},
+	)
 )
 
 func init() {
@@ -108,5 +115,6 @@ func init() {
 		presentAppsMetric,
 		presentEnvsMetric,
 		reconciliationMetrics,
+		dependencyMetrics,
 	)
 }