Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for GetImageSizeBucket (0.29 sec)

  1. pkg/kubelet/metrics/metrics_test.go

    			{200 * 1024 * 1024 * 1024, 10000},
    		}
    
    		for _, dp := range dataPoints {
    			imageSize := int64(dp[0])
    			duration := dp[1]
    			t.Log(imageSize, duration)
    			t.Log(GetImageSizeBucket(uint64(imageSize)))
    			ImagePullDuration.WithLabelValues(GetImageSizeBucket(uint64(imageSize))).Observe(duration)
    		}
    
    		wants, err := os.Open("testdata/image_pull_duration_metric")
    		defer func() {
    			if err := wants.Close(); err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Feb 08 00:30:31 UTC 2024
    - 1.9K bytes
    - Viewed (0)
  2. pkg/kubelet/images/image_manager.go

    		container.Image, imagePullResult.pullDuration.Truncate(time.Millisecond), imagePullDuration, imagePullResult.imageSize), klog.Info)
    	metrics.ImagePullDuration.WithLabelValues(metrics.GetImageSizeBucket(imagePullResult.imageSize)).Observe(imagePullDuration.Seconds())
    	m.backOff.GC()
    	return imagePullResult.imageRef, "", nil
    }
    
    func evalCRIPullErr(container *v1.Container, err error) (errMsg string, errRes error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Feb 08 00:30:31 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  3. pkg/kubelet/metrics/metrics.go

    	return time.Since(start).Seconds()
    }
    
    // SetNodeName sets the NodeName Gauge to 1.
    func SetNodeName(name types.NodeName) {
    	NodeName.WithLabelValues(string(name)).Set(1)
    }
    
    func GetImageSizeBucket(sizeInBytes uint64) string {
    	if sizeInBytes == 0 {
    		return "N/A"
    	}
    
    	for i := len(imageSizeBuckets) - 1; i >= 0; i-- {
    		if sizeInBytes > imageSizeBuckets[i].lowerBoundInBytes {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Feb 22 15:13:25 UTC 2024
    - 45.6K bytes
    - Viewed (0)
Back to top