initial commit for helm install

Signed-off-by: Kartikey Mamgain <[email protected]>

Author: Kartikey-star

pkg/gatherers/clusterconfig/clusterconfig_gatherer.go

@@ -79,6 +79,7 @@ var gatheringFunctions = map[string]gathererFuncPtr{
 	"image":                             (*Gatherer).GatherClusterImage,
 	"kube_controller_manager_logs":      (*Gatherer).GatherKubeControllerManagerLogs,
 	"overlapping_namespace_uids":        (*Gatherer).GatherNamespacesWithOverlappingUIDs,
+	"console_helm_installs_total":       (*Gatherer).GatherMetricsForHelmInstalls,
 }
 
 func New(

pkg/gatherers/clusterconfig/helm_metrics.go

@@ -0,0 +1,73 @@
+package clusterconfig
+
+import (
+	"context"
+	"fmt"
+	"io"
+
+	"github.com/openshift/insights-operator/pkg/record"
+	"github.com/openshift/insights-operator/pkg/utils"
+	"github.com/openshift/insights-operator/pkg/utils/marshal"
+	"k8s.io/client-go/rest"
+	"k8s.io/klog/v2"
+)
+
+const (
+	// metricsAlertsLinesLimit is the maximal number of lines read from monitoring Prometheus
+	// 500 KiB of alerts is limit, one alert line has typically 450 bytes => 1137 lines.
+	// This number has been rounded to 1000 for simplicity.
+	// Formerly, the `500 * 1024 / 450` expression was used instead.
+	helmMetricsAlertsLinesLimit = 1000
+)
+
+func (g *Gatherer) GatherMetricsForHelmInstalls(ctx context.Context) ([]record.Record, []error) {
+	metricsRESTClient, err := rest.RESTClientFor(g.metricsGatherKubeConfig)
+	if err != nil {
+		klog.Warningf("Unable to load metrics client, no metrics will be collected: %v", err)
+		return nil, nil
+	}
+
+	return gatherMetricsForHelmInstalls(ctx, metricsRESTClient)
+}
+
+func gatherMetricsForHelmInstalls(ctx context.Context, metricsClient rest.Interface) ([]record.Record, []error) {
+	data, err := metricsClient.Get().AbsPath("federate").
+		Param("match[]", "console_helm_installs_total").
+		DoRaw(ctx)
+	if err != nil {
+		klog.Errorf("Unable to retrieve  metrics for helm installs: %v", err)
+		return nil, []error{err}
+	}
+
+	rsp, err := metricsClient.Get().AbsPath("federate").
+		Param("match[]", "ALERTS").
+		Stream(ctx)
+	if err != nil {
+		klog.Errorf("Unable to retrieve most recent alerts from metrics: %v", err)
+		return nil, []error{err}
+	}
+	r := utils.NewLineLimitReader(rsp, metricsAlertsLinesLimit)
+	alerts, err := io.ReadAll(r)
+	if err != nil && err != io.EOF {
+		klog.Errorf("Unable to read most recent alerts from metrics: %v", err)
+		return nil, []error{err}
+	}
+
+	remainingAlertLines, err := utils.CountLines(rsp)
+	if err != nil && err != io.EOF {
+		klog.Errorf("Unable to count truncated lines of alerts metric: %v", err)
+		return nil, []error{err}
+	}
+	totalAlertCount := r.GetTotalLinesRead() + remainingAlertLines
+
+	// # ALERTS <Total Alerts Lines>/<Alerts Line Limit>
+	// The total number of alerts will typically be greater than the true number of alerts by 2
+	// because the `# TYPE ALERTS untyped` header and the final empty line are counter in.
+	data = append(data, []byte(fmt.Sprintf("# ALERTS %d/%d\n", totalAlertCount, metricsAlertsLinesLimit))...)
+	data = append(data, alerts...)
+	records := []record.Record{
+		{Name: "config/metrics", Item: marshal.RawByte(data)},
+	}
+
+	return records, nil
+}