backport: Add metricts collection from MTV.

pkg/controller/migration/BUILD.bazel

@@ -5,7 +5,6 @@ go_library(
     srcs = [
         "controller.go",
         "doc.go",
-        "metrics.go",
         "predicate.go",
         "validation.go",
     ],
@@ -20,9 +19,8 @@ go_library(
         "//pkg/lib/error",
         "//pkg/lib/logging",
         "//pkg/lib/ref",
+        "//pkg/monitoring/metrics/forklift-controller",
         "//pkg/settings",
-        "//vendor/github.com/prometheus/client_golang/prometheus",
-        "//vendor/github.com/prometheus/client_golang/prometheus/promauto",
         "//vendor/k8s.io/apimachinery/pkg/api/errors",
         "//vendor/k8s.io/apiserver/pkg/storage/names",
         "//vendor/sigs.k8s.io/controller-runtime/pkg/client",

pkg/controller/migration/controller.go

@@ -24,6 +24,7 @@ import (
 	libcnd "github.com/konveyor/forklift-controller/pkg/lib/condition"
 	"github.com/konveyor/forklift-controller/pkg/lib/logging"
 	libref "github.com/konveyor/forklift-controller/pkg/lib/ref"
+	metrics "github.com/konveyor/forklift-controller/pkg/monitoring/metrics/forklift-controller"
 	"github.com/konveyor/forklift-controller/pkg/settings"
 	k8serr "k8s.io/apimachinery/pkg/api/errors"
 	"k8s.io/apiserver/pkg/storage/names"
@@ -84,7 +85,7 @@ func Add(mgr manager.Manager) error {
 	}
 
 	// Gather migration metrics
-	recordMetrics(mgr.GetClient())
+	metrics.RecordMigrationMetrics(mgr.GetClient())
 
 	return nil
 }

pkg/controller/plan/BUILD.bazel

@@ -7,7 +7,6 @@ go_library(
         "doc.go",
         "hook.go",
         "kubevirt.go",
-        "metrics.go",
         "migration.go",
         "predicate.go",
         "util.go",
@@ -36,13 +35,12 @@ go_library(
         "//pkg/lib/itinerary",
         "//pkg/lib/logging",
         "//pkg/lib/ref",
+        "//pkg/monitoring/metrics/forklift-controller",
         "//pkg/settings",
         "//vendor/github.com/k8snetworkplumbingwg/network-attachment-definition-client/pkg/apis/k8s.cni.cncf.io/v1:k8s_cni_cncf_io",
         "//vendor/github.com/openshift/api/template/v1:template",
         "//vendor/github.com/openshift/library-go/pkg/template/generator",
         "//vendor/github.com/openshift/library-go/pkg/template/templateprocessing",
-        "//vendor/github.com/prometheus/client_golang/prometheus",
-        "//vendor/github.com/prometheus/client_golang/prometheus/promauto",
         "//vendor/gopkg.in/yaml.v2:yaml_v2",
         "//vendor/k8s.io/api/batch/v1:batch",
         "//vendor/k8s.io/api/core/v1:core",

pkg/controller/plan/controller.go

@@ -30,6 +30,7 @@ import (
 	liberr "github.com/konveyor/forklift-controller/pkg/lib/error"
 	"github.com/konveyor/forklift-controller/pkg/lib/logging"
 	libref "github.com/konveyor/forklift-controller/pkg/lib/ref"
+	metrics "github.com/konveyor/forklift-controller/pkg/monitoring/metrics/forklift-controller"
 	"github.com/konveyor/forklift-controller/pkg/settings"
 	k8serr "k8s.io/apimachinery/pkg/api/errors"
 	"k8s.io/apiserver/pkg/storage/names"
@@ -145,7 +146,7 @@ func Add(mgr manager.Manager) error {
 	}
 
 	// Gather migration Plan metrics
-	recordMetrics(mgr.GetClient())
+	metrics.RecordMigrationMetrics(mgr.GetClient())
 
 	return nil
 }

pkg/monitoring/metrics/forklift-controller/BUILD.bazel

@@ -0,0 +1,18 @@
+load("@io_bazel_rules_go//go:def.bzl", "go_library")
+
+go_library(
+    name = "forklift-controller",
+    srcs = [
+        "metrics.go",
+        "migration_metrics.go",
+        "plan_metrics.go",
+    ],
+    importpath = "github.com/konveyor/forklift-controller/pkg/monitoring/metrics/forklift-controller",
+    visibility = ["//visibility:public"],
+    deps = [
+        "//pkg/apis/forklift/v1beta1",
+        "//vendor/github.com/prometheus/client_golang/prometheus",
+        "//vendor/github.com/prometheus/client_golang/prometheus/promauto",
+        "//vendor/sigs.k8s.io/controller-runtime/pkg/client",
+    ],
+)

pkg/monitoring/metrics/forklift-controller/metrics.go

@@ -0,0 +1,117 @@
+package forklift_controller
+
+import (
+	"github.com/prometheus/client_golang/prometheus"
+	"github.com/prometheus/client_golang/prometheus/promauto"
+)
+
+const (
+	Succeeded = "Succeeded"
+	Failed    = "Failed"
+	Executing = "Executing"
+	Running   = "Running"
+	Pending   = "Pending"
+	Canceled  = "Canceled"
+	Blocked   = "Blocked"
+	Ready     = "Ready"
+	Deleted   = "Deleted"
+	Warm      = "Warm"
+	Cold      = "Cold"
+	Local     = "Local"
+	Remote    = "Remote"
+)
+
+var (
+	// 'status' - [ Succeeded, Failed, Executing, Canceled]
+	// 'provider' - [oVirt, VSphere, Openstack, OVA, Openshift]
+	// 'mode' - [Cold, Warm]
+	// 'target' - [Local, Remote]
+	migrationStatusGauge = promauto.NewGaugeVec(prometheus.GaugeOpts{
+		Name: "mtv_migrations_status",
+		Help: "VM Migrations sorted by status, provider, mode and destination",
+	},
+		[]string{
+			"status",
+			"provider",
+			"mode",
+			"target",
+		},
+	)
+
+	// 'status' - [ Succeeded, Failed, Executing, Running, Pending, Canceled, Blocked, Deleted]
+	// 'provider' - [oVirt, VSphere, Openstack, OVA, Openshift]
+	// 'mode' - [Cold, Warm]
+	// 'target' - [Local, Remote]
+	planStatusGauge = promauto.NewGaugeVec(prometheus.GaugeOpts{
+		Name: "mtv_plans_status",
+		Help: "VM migration Plans sorted by status, provider, mode and destination",
+	},
+		[]string{
+			"status",
+			"provider",
+			"mode",
+			"target",
+		},
+	)
+
+	// 'status' - [ Succeeded, Failed, Executing, Canceled]
+	// 'provider' - [oVirt, VSphere, Openstack, OVA, Openshift]
+	// 'mode' - [Cold, Warm]
+	// 'target' - [Local, Remote]
+	// 'plan' - [Id]
+	migrationDurationGauge = promauto.NewGaugeVec(prometheus.GaugeOpts{
+		Name: "mtv_migration_duration_seconds",
+		Help: "Duration of VM migrations in seconds",
+	},
+		[]string{"provider", "mode", "target", "plan"},
+	)
+
+	// 'provider' - [oVirt, VSphere, Openstack, OVA, Openshift]
+	// 'mode' - [Cold, Warm]
+	// 'target' - [Local, Remote]
+	// 'plan' - [Id]
+	dataTransferredGauge = promauto.NewGaugeVec(prometheus.GaugeOpts{
+		Name: "mtv_migration_data_transferred_bytes",
+		Help: "Total data transferred during VM migrations in bytes",
+	},
+		[]string{
+			"provider",
+			"mode",
+			"target",
+			"plan",
+		},
+	)
+
+	// 'status' - [ Succeeded, Failed, Executing, Canceled]
+	// 'provider' - [oVirt, VSphere, Openstack, OVA, Openshift]
+	// 'mode' - [Cold, Warm]
+	// 'target' - [Local, Remote]
+	// 'plan' - [Id]
+	migrationPlanCorrelationStatusGauge = promauto.NewGaugeVec(prometheus.GaugeOpts{
+		Name: "mtv_workload_migrations_status",
+		Help: "VM Migrations status by provider, mode, destination and plan",
+	},
+		[]string{
+			"status",
+			"provider",
+			"mode",
+			"target",
+			"plan",
+		},
+	)
+
+	// 'provider' - [oVirt, VSphere, Openstack, OVA, Openshift]
+	// 'mode' - [Cold, Warm]
+	// 'target' - [Local, Remote]
+	migrationDurationHistogram = promauto.NewHistogramVec(prometheus.HistogramOpts{
+		Name:    "mtv_migrations_duration_seconds",
+		Help:    "Histogram of VM migrations duration in seconds",
+		Buckets: []float64{1 * 3600, 2 * 3600, 5 * 3600, 10 * 3600, 24 * 3600, 48 * 3600}, // 1, 2, 5, 10, 24, 48 hours in seconds
+	},
+		[]string{
+			"provider",
+			"mode",
+			"target",
+		},
+	)
+)