Address comments

Author: awgreene

Makefile

@@ -85,7 +85,6 @@ build-coverage: clean $(CMDS)
 
 build-linux: build_cmd=build
 build-linux: arch_flags=GOOS=linux GOARCH=386
-build-linux: BUILD_TAGS="json1 experimental_metrics"
 build-linux: clean $(CMDS)
 
 build-wait: clean bin/wait

pkg/controller/operators/adoption_controller.go

@@ -115,7 +115,7 @@ func (r *AdoptionReconciler) ReconcileSubscription(ctx context.Context, req ctrl
 	// Set up a convenient log object so we don't have to type request over and over again
 	log := r.log.WithValues("request", req)
 	log.V(1).Info("reconciling subscription")
-	metrics.EmitAdoptionSubscriptionReconcile()
+	metrics.EmitAdoptionSubscriptionReconcile(req.Namespace, req.Name)
 
 	// Fetch the Subscription from the cache
 	in := &operatorsv1alpha1.Subscription{}
@@ -179,7 +179,7 @@ func (r *AdoptionReconciler) ReconcileClusterServiceVersion(ctx context.Context,
 	log := r.log.WithValues("request", req)
 	log.V(1).Info("reconciling csv")
 
-	metrics.EmitAdoptionCSVReconcile()
+	metrics.EmitAdoptionCSVReconcile(req.Namespace, req.Name)
 
 	// Fetch the CSV from the cache
 	in := &operatorsv1alpha1.ClusterServiceVersion{}

pkg/controller/operators/operator_controller.go

@@ -116,7 +116,7 @@ func NewOperatorReconciler(cli client.Client, log logr.Logger, scheme *runtime.S
 var _ reconcile.Reconciler = &OperatorReconciler{}
 
 func (r *OperatorReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) {
-	metrics.EmitOperatorReconcile()
+	metrics.EmitOperatorReconcile(req.Namespace, req.Name)
 	// Set up a convenient log object so we don't have to type request over and over again
 	log := r.log.WithValues("request", req)
 	log.V(1).Info("reconciling operator")

pkg/controller/operators/operatorcondition_controller.go

@@ -92,7 +92,7 @@ func NewOperatorConditionReconciler(cli client.Client, log logr.Logger, scheme *
 var _ reconcile.Reconciler = &OperatorConditionReconciler{}
 
 func (r *OperatorConditionReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) {
-	metrics.EmitOperatorConditionReconcile()
+	metrics.EmitOperatorConditionReconcile(req.Namespace, req.Name)
 	// Set up a convenient log object so we don't have to type request over and over again
 	log := r.log.WithValues("request", req)
 	log.V(2).Info("reconciling operatorcondition")

pkg/controller/operators/operatorconditiongenerator_controller.go

@@ -89,7 +89,7 @@ func NewOperatorConditionGeneratorReconciler(cli client.Client, log logr.Logger,
 var _ reconcile.Reconciler = &OperatorConditionGeneratorReconciler{}
 
 func (r *OperatorConditionGeneratorReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) {
-	metrics.EmitOperatorConditionGeneratorReconcile()
+	metrics.EmitOperatorConditionGeneratorReconcile(req.Namespace, req.Name)
 	// Set up a convenient log object so we don't have to type request over and over again
 	log := r.log.WithValues("request", req)
 

pkg/metrics/experimental.go

@@ -13,23 +13,23 @@ func init() {
 	// Register experimental metrics
 	reconcileMetrics = reconcileCounters(operatorController, adoptionCSVController, adoptionSubscriptionController, operatorConditionController, operatorConditionGeneratorController)
 	registerReconcileMetrics()
-	fmt.Printf("metrics")
 }
 
-func reconcileCounters(reconcilerNames ...string) map[string]prometheus.Counter {
+func reconcileCounters(reconcilerNames ...string) map[string]prometheus.CounterVec {
 	result := map[string]prometheus.Counter{}
 	for _, s := range reconcilerNames {
 		result[s] = reconcileCounter(s)
 	}
 	return result
 }
 
-func reconcileCounter(name string) prometheus.Counter {
-	return prometheus.NewCounter(
+func reconcileCounter(name string) prometheus.CounterVec {
+	return prometheus.NewCounterVec(
 		prometheus.CounterOpts{
 			Name: "controller_reconcile_" + name,
 			Help: fmt.Sprintf("Count of reconcile events by the %s controller", strings.Replace(name, "_", " ", -1)),
 		},
+		[]string{NAMESPACE_LABEL, NAME_LABEL},
 	)
 }
 

pkg/metrics/metrics.go

@@ -213,7 +213,7 @@ var (
 	subscriptionSyncCounters = make(map[string]subscriptionSyncLabelValues)
 
 	// Experimental Metrics
-	reconcileMetrics = map[string]prometheus.Counter{}
+	reconcileMetrics = map[string]prometheus.CounterVec{}
 )
 
 type subscriptionSyncLabelValues struct {
@@ -345,28 +345,28 @@ func EmitInstallPlanWarning() {
 	installPlanWarningCount.Inc()
 }
 
-func EmitOperatorReconcile() {
-	emitReconcile(operatorConditionController)
+func EmitOperatorReconcile(namespace, name string) {
+	emitReconcile(operatorConditionController, namespace, name)
 }
 
-func EmitAdoptionCSVReconcile() {
-	emitReconcile(adoptionCSVController)
+func EmitAdoptionCSVReconcile(namespace, name string) {
+	emitReconcile(adoptionCSVController, namespace, name)
 }
 
-func EmitAdoptionSubscriptionReconcile() {
-	emitReconcile(adoptionSubscriptionController)
+func EmitAdoptionSubscriptionReconcile(namespace, name string) {
+	emitReconcile(adoptionSubscriptionController, namespace, name)
 }
 
-func EmitOperatorConditionReconcile() {
-	emitReconcile(operatorConditionController)
+func EmitOperatorConditionReconcile(namespace, name string) {
+	emitReconcile(operatorConditionController, namespace, name)
 }
 
-func EmitOperatorConditionGeneratorReconcile() {
-	emitReconcile(operatorConditionGeneratorController)
+func EmitOperatorConditionGeneratorReconcile(namespace, name string) {
+	emitReconcile(operatorConditionGeneratorController, namespace, name)
 }
 
-func emitReconcile(name string) {
+func emitReconcile(controllerName, namespace, name string) {
 	if counter, ok := reconcileMetrics[name]; ok {
-		counter.Inc()
+		counter.WithLabelValues(namespace, name).Inc()
 	}
 }