- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for NewLazyConstMetric (0.26 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)