Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for NewLazyConstMetric (0.26 sec)

  1. pkg/kubelet/metrics/collectors/resource_metrics.go

    func (rc *resourceMetricsCollector) CollectWithStability(ch chan<- metrics.Metric) {
    	ctx := context.Background()
    	var errorCount float64
    	defer func() {
    		ch <- metrics.NewLazyConstMetric(resourceScrapeResultDesc, metrics.GaugeValue, errorCount)
    		ch <- metrics.NewLazyConstMetric(resourceScrapeErrorResultDesc, metrics.GaugeValue, errorCount)
    	}()
    	statsSummary, err := rc.provider.GetCPUAndMemoryStats(ctx)
    	if err != nil {
    		errorCount = 1
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Sep 08 07:13:37 UTC 2023
    - 9.2K bytes
    - Viewed (1)
  2. pkg/controller/volume/persistentvolume/metrics/metrics.go

    		}
    	}
    	for storageClassName, number := range boundNumberByStorageClass {
    		ch <- metrics.NewLazyConstMetric(
    			boundPVCountDesc,
    			metrics.GaugeValue,
    			float64(number),
    			storageClassName)
    	}
    	for storageClassName, number := range unboundNumberByStorageClass {
    		ch <- metrics.NewLazyConstMetric(
    			unboundPVCountDesc,
    			metrics.GaugeValue,
    			float64(number),
    			storageClassName)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 25 13:09:16 UTC 2022
    - 10.5K bytes
    - Viewed (0)
  3. pkg/kubelet/pluginmanager/metrics/metrics.go

    func (c *totalPluginsCollector) CollectWithStability(ch chan<- metrics.Metric) {
    	for stateName, pluginCount := range c.getPluginCount() {
    		for socketPath, count := range pluginCount {
    			ch <- metrics.NewLazyConstMetric(totalPluginsDesc,
    				metrics.GaugeValue,
    				float64(count),
    				socketPath,
    				stateName)
    		}
    	}
    }
    
    func (c *totalPluginsCollector) getPluginCount() pluginCount {
    	counter := make(pluginCount)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Nov 08 01:16:57 UTC 2019
    - 2.7K bytes
    - Viewed (0)
  4. pkg/controller/volume/attachdetach/metrics/metrics.go

    			ch <- metrics.NewLazyConstMetric(inUseVolumeMetricDesc,
    				metrics.GaugeValue,
    				float64(count),
    				string(nodeName),
    				pluginName)
    		}
    	}
    
    	stateVolumeMap := collector.getTotalVolumesCount()
    	for stateName, pluginCount := range stateVolumeMap {
    		for pluginName, count := range pluginCount {
    			ch <- metrics.NewLazyConstMetric(totalVolumesMetricDesc,
    				metrics.GaugeValue,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jul 10 06:30:05 UTC 2023
    - 7.5K bytes
    - Viewed (0)
  5. pkg/kubelet/metrics/collectors/log_metrics.go

    		klog.ErrorS(err, "Failed to get pod stats")
    		return
    	}
    
    	for _, ps := range podStats {
    		for _, c := range ps.Containers {
    			if c.Logs != nil && c.Logs.UsedBytes != nil {
    				ch <- metrics.NewLazyConstMetric(
    					descLogSize,
    					metrics.GaugeValue,
    					float64(*c.Logs.UsedBytes),
    					ps.PodRef.UID,
    					ps.PodRef.Namespace,
    					ps.PodRef.Name,
    					c.Name,
    				)
    			}
    		}
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Nov 05 13:02:13 UTC 2022
    - 2.3K bytes
    - Viewed (0)
  6. pkg/kubelet/metrics/collectors/volume_stats.go

    	if err != nil {
    		return
    	}
    	addGauge := func(desc *metrics.Desc, pvcRef *stats.PVCReference, v float64, lv ...string) {
    		lv = append([]string{pvcRef.Namespace, pvcRef.Name}, lv...)
    		ch <- metrics.NewLazyConstMetric(desc, metrics.GaugeValue, v, lv...)
    	}
    	allPVCs := sets.Set[string]{}
    	for _, podStat := range podStats {
    		if podStat.VolumeStats == nil {
    			continue
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  7. pkg/kubelet/volumemanager/metrics/metrics.go

    func (c *totalVolumesCollector) CollectWithStability(ch chan<- metrics.Metric) {
    	for stateName, pluginCount := range c.getVolumeCount() {
    		for pluginName, count := range pluginCount {
    			ch <- metrics.NewLazyConstMetric(totalVolumesDesc,
    				metrics.GaugeValue,
    				float64(count),
    				pluginName,
    				stateName)
    		}
    	}
    }
    
    func (c *totalVolumesCollector) getVolumeCount() volumeCount {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Mar 06 16:48:59 UTC 2023
    - 5.2K bytes
    - Viewed (0)
  8. pkg/scheduler/metrics/resources/resources.go

    	namespace, name, nodeName, schedulerName, priority string,
    	resourceName v1.ResourceName,
    	unit string,
    	val resource.Quantity,
    ) {
    	if val.IsZero() {
    		return
    	}
    	ch <- metrics.NewLazyConstMetric(desc, metrics.GaugeValue,
    		val.AsApproximateFloat64(),
    		namespace, name, nodeName, schedulerName, priority, string(resourceName), unit,
    	)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 09 23:15:53 UTC 2023
    - 6.8K bytes
    - Viewed (0)
Back to top