Merge pull request #11 from sandhyadalavi/add-sample-metrics

Added few sample metrics

cmd/reference-addon-manager/main.go

@@ -15,6 +15,7 @@ import (
 
 	refapis "github.com/openshift/reference-addon/apis"
 	"github.com/openshift/reference-addon/internal/controllers"
+	"github.com/openshift/reference-addon/internal/metrics"
 )
 
 var (
@@ -104,6 +105,10 @@ func main() {
 		os.Exit(1)
 	}
 
+	// register and fill metrics
+	metrics.RegisterMetrics()
+	metrics.RequestSampleResponseData()
+
 	setupLog.Info("starting manager")
 	if err := mgr.Start(ctrl.SetupSignalHandler()); err != nil {
 		setupLog.Error(err, "problem running manager")

go.mod

@@ -4,6 +4,7 @@ go 1.16
 
 require (
 	github.com/go-logr/logr v0.4.0
+	github.com/prometheus/client_golang v1.7.1 // indirect
 	github.com/stretchr/testify v1.6.1
 	k8s.io/api v0.20.2
 	k8s.io/apiextensions-apiserver v0.20.1

internal/controllers/reference_addon_controller.go

@@ -10,6 +10,7 @@ import (
 	"sigs.k8s.io/controller-runtime/pkg/client"
 
 	refapisv1alpha1 "github.com/openshift/reference-addon/apis/reference/v1alpha1"
+	"github.com/openshift/reference-addon/internal/metrics"
 )
 
 type ReferenceAddonReconciler struct {
@@ -31,6 +32,9 @@ func (r *ReferenceAddonReconciler) Reconcile(
 		log.Info("reconciling for a reference addon object not prefixed by redhat- or named reference-addon")
 	}
 
+	// add sample metrics
+	metrics.RequestSampleResponseData()
+
 	return ctrl.Result{}, nil
 }
 

internal/metrics/url_response.go

@@ -0,0 +1,57 @@
+package metrics
+
+import (
+	"net/http"
+	"time"
+
+	"github.com/prometheus/client_golang/prometheus"
+	ctrlmetrics "sigs.k8s.io/controller-runtime/pkg/metrics"
+)
+
+var (
+	externalURLs = []string{"https://httpstat.us/503", "https://httpstat.us/200"}
+
+	availability = prometheus.NewGaugeVec(
+		prometheus.GaugeOpts{
+			Name: "reference_addon_sample_availability",
+			Help: "external url availability 0-not available and 1-available.",
+		},
+		[]string{"url"},
+	)
+	responseTime = prometheus.NewGaugeVec(
+		prometheus.GaugeOpts{
+			Name: "reference_addon_sample_response_time",
+			Help: "external url response time taken.",
+		},
+		[]string{"url"},
+	)
+)
+
+// RegisterMetrics must register metrics in given registry collector
+func RegisterMetrics() {
+	ctrlmetrics.Registry.MustRegister(availability)
+	ctrlmetrics.Registry.MustRegister(responseTime)
+}
+
+func RequestSampleResponseData() {
+	for _, externalURL := range externalURLs {
+		status, timeTaken := callExternalURL(externalURL)
+		availability.WithLabelValues(externalURL).Set(status)
+		responseTime.WithLabelValues(externalURL).Set(timeTaken)
+	}
+}
+
+func callExternalURL(externalURL string) (float64, float64) {
+	start := time.Now()
+	response, err := http.Get(externalURL)
+	if err != nil {
+		return 0, 0
+	}
+	defer response.Body.Close()
+	timeTaken := time.Since(start).Milliseconds()
+	status := 0
+	if response.StatusCode == 200 {
+		status = 1
+	}
+	return float64(status), float64(timeTaken)
+}