Register imagePullThroughput and count with MiB

Shukui Yang · Shukui Yang · commit db223271e3d4 · 2023-04-07T10:12:41.000+08:00
Signed-off-by: Shukui Yang &lt;yangshukui@bytedance.com&gt;
diff --git a/pkg/cri/sbserver/images/image_pull.go b/pkg/cri/sbserver/images/image_pull.go
@@ -212,8 +212,9 @@ func (c *CRIImageService) PullImage(ctx context.Context, r *runtime.PullImageReq
 		}
 	}
 
+	const mbToByte = 1024 * 1024
 	size, _ := image.Size(ctx)
-	imagePullingSpeed := float64(size) / time.Since(startTime).Seconds()
+	imagePullingSpeed := float64(size) / mbToByte / time.Since(startTime).Seconds()
 	imagePullThroughput.Observe(imagePullingSpeed)
 
 	log.G(ctx).Infof("Pulled image %q with image id %q, repo tag %q, repo digest %q, size %q in %s", imageRef, imageID,
diff --git a/pkg/cri/sbserver/images/metrics.go b/pkg/cri/sbserver/images/metrics.go
@@ -24,23 +24,30 @@ import (
 var (
 	imagePulls           metrics.LabeledCounter
 	inProgressImagePulls metrics.Gauge
-	//  pull duration / (image size / 1MBi)
+	// image size in MB / image pull duration in seconds
 	imagePullThroughput prom.Histogram
 )
 
 func init() {
+	const (
+		namespace = "containerd"
+		subsystem = "cri_sandboxed"
+	)
+
 	// these CRI metrics record latencies for successful operations around a sandbox and container's lifecycle.
-	ns := metrics.NewNamespace("containerd", "cri_sandboxed", nil)
+	ns := metrics.NewNamespace(namespace, subsystem, nil)
 
 	imagePulls = ns.NewLabeledCounter("image_pulls", "succeeded and failed counters", "status")
 	inProgressImagePulls = ns.NewGauge("in_progress_image_pulls", "in progress pulls", metrics.Total)
 	imagePullThroughput = prom.NewHistogram(
 		prom.HistogramOpts{
-			Name:    "image_pulling_throughput",
-			Help:    "image pull throughput",
-			Buckets: prom.DefBuckets,
+			Namespace: namespace,
+			Subsystem: subsystem,
+			Name:      "image_pulling_throughput",
+			Help:      "image pull throughput",
+			Buckets:   prom.DefBuckets,
 		},
 	)
-
+	ns.Add(imagePullThroughput)
 	metrics.Register(ns)
 }
diff --git a/pkg/cri/server/image_pull.go b/pkg/cri/server/image_pull.go
@@ -209,8 +209,9 @@ func (c *criService) PullImage(ctx context.Context, r *runtime.PullImageRequest)
 		}
 	}
 
+	const mbToByte = 1024 * 1024
 	size, _ := image.Size(ctx)
-	imagePullingSpeed := float64(size) / time.Since(startTime).Seconds()
+	imagePullingSpeed := float64(size) / mbToByte / time.Since(startTime).Seconds()
 	imagePullThroughput.Observe(imagePullingSpeed)
 
 	log.G(ctx).Infof("Pulled image %q with image id %q, repo tag %q, repo digest %q, size %q in %s", imageRef, imageID,
diff --git a/pkg/cri/server/metrics.go b/pkg/cri/server/metrics.go
@@ -42,13 +42,18 @@ var (
 
 	imagePulls           metrics.LabeledCounter
 	inProgressImagePulls metrics.Gauge
-	//  pull duration / (image size / 1MBi)
+	// image size in MB / image pull duration in seconds
 	imagePullThroughput prom.Histogram
 )
 
 func init() {
+	const (
+		namespace = "containerd"
+		subsystem = "cri"
+	)
+
 	// these CRI metrics record latencies for successful operations around a sandbox and container's lifecycle.
-	ns := metrics.NewNamespace("containerd", "cri", nil)
+	ns := metrics.NewNamespace(namespace, subsystem, nil)
 
 	sandboxListTimer = ns.NewTimer("sandbox_list", "time to list sandboxes")
 	sandboxCreateNetworkTimer = ns.NewTimer("sandbox_create_network", "time to create the network for a sandbox")
@@ -72,12 +77,15 @@ func init() {
 	inProgressImagePulls = ns.NewGauge("in_progress_image_pulls", "in progress pulls", metrics.Total)
 	imagePullThroughput = prom.NewHistogram(
 		prom.HistogramOpts{
-			Name:    "image_pulling_throughput",
-			Help:    "image pull throughput",
-			Buckets: prom.DefBuckets,
+			Namespace: namespace,
+			Subsystem: subsystem,
+			Name:      "image_pulling_throughput",
+			Help:      "image pull throughput",
+			Buckets:   prom.DefBuckets,
 		},
 	)
 
+	ns.Add(imagePullThroughput)
 	metrics.Register(ns)
 }
 

Original file line number	Diff line number	Diff line change
`@@ -212,8 +212,9 @@ func (c CRIImageService) PullImage(ctx context.Context, r runtime.PullImageReq`
`212`	`212`	`}`
`213`	`213`	`}`
`214`	`214`
	`215`	`+ const mbToByte = 1024 * 1024`
`215`	`216`	`size, _ := image.Size(ctx)`
`216`		`- imagePullingSpeed := float64(size) / time.Since(startTime).Seconds()`
	`217`	`+ imagePullingSpeed := float64(size) / mbToByte / time.Since(startTime).Seconds()`
`217`	`218`	`imagePullThroughput.Observe(imagePullingSpeed)`
`218`	`219`
`219`	`220`	`log.G(ctx).Infof("Pulled image %q with image id %q, repo tag %q, repo digest %q, size %q in %s", imageRef, imageID,`
Original file line number	Diff line number	Diff line change
`@@ -209,8 +209,9 @@ func (c criService) PullImage(ctx context.Context, r runtime.PullImageRequest)`
`209`	`209`	`}`
`210`	`210`	`}`
`211`	`211`
	`212`	`+ const mbToByte = 1024 * 1024`
`212`	`213`	`size, _ := image.Size(ctx)`
`213`		`- imagePullingSpeed := float64(size) / time.Since(startTime).Seconds()`
	`214`	`+ imagePullingSpeed := float64(size) / mbToByte / time.Since(startTime).Seconds()`
`214`	`215`	`imagePullThroughput.Observe(imagePullingSpeed)`
`215`	`216`
`216`	`217`	`log.G(ctx).Infof("Pulled image %q with image id %q, repo tag %q, repo digest %q, size %q in %s", imageRef, imageID,`