- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 31 for modstat (0.49 sec)
-
pkg/kubelet/metrics/collectors/volume_stats.go
ch <- metrics.NewLazyConstMetric(desc, metrics.GaugeValue, v, lv...) } allPVCs := sets.Set[string]{} for _, podStat := range podStats { if podStat.VolumeStats == nil { continue } for _, volumeStat := range podStat.VolumeStats { pvcRef := volumeStat.PVCRef if pvcRef == nil { // ignore if no PVC reference continue } pvcUniqStr := pvcRef.Namespace + "/" + pvcRef.Name
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/server/stats/summary_windows_test.go
assert.Equal(summary.Node.SystemContainers[0].CPU.UsageCoreNanoSeconds, podStats[0].CPU.UsageCoreNanoSeconds) assert.Equal(summary.Node.SystemContainers[0].CPU.UsageNanoCores, podStats[0].CPU.UsageNanoCores) assert.Equal(summary.Node.SystemContainers[0].Memory.WorkingSetBytes, podStats[0].Memory.WorkingSetBytes) assert.Equal(summary.Node.SystemContainers[0].Memory.UsageBytes, podStats[0].Memory.UsageBytes)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 4.4K bytes - Viewed (0) -
pkg/kubelet/server/stats/summary_sys_containers_windows.go
func (sp *summaryProviderImpl) GetSystemContainersStats(nodeConfig cm.NodeConfig, podStats []statsapi.PodStats, updateStats bool) (stats []statsapi.ContainerStats) { stats = append(stats, sp.getSystemPodsCPUAndMemoryStats(nodeConfig, podStats, updateStats)) return stats } func (sp *summaryProviderImpl) GetSystemContainersCPUAndMemoryStats(nodeConfig cm.NodeConfig, podStats []statsapi.PodStats, updateStats bool) (stats []statsapi.ContainerStats) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 24 19:47:49 UTC 2021 - 3K bytes - Viewed (0) -
pkg/kubelet/stats/cri_stats_provider_others.go
} func addCRIPodCPUStats(ps *statsapi.PodStats, criPodStat *runtimeapi.PodSandboxStats) { } func addCRIPodProcessStats(ps *statsapi.PodStats, criPodStat *runtimeapi.PodSandboxStats) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 16 11:09:04 UTC 2023 - 1.8K bytes - Viewed (0) -
pkg/kubelet/metrics/collectors/log_metrics.go
return &logMetricsCollector{ podStats: podStats, } } // DescribeWithStability implements the metrics.StableCollector interface. func (c *logMetricsCollector) DescribeWithStability(ch chan<- *metrics.Desc) { ch <- descLogSize } // CollectWithStability implements the metrics.StableCollector interface. func (c *logMetricsCollector) CollectWithStability(ch chan<- metrics.Metric) { podStats, err := c.podStats(context.Background())
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/server/stats/summary.go
if err != nil { return nil, fmt.Errorf("failed to get imageFs stats: %v", err) } var podStats []statsapi.PodStats if updateStats { podStats, err = sp.provider.ListPodStatsAndUpdateCPUNanoCoreUsage(ctx) } else { podStats, err = sp.provider.ListPodStats(ctx) } if err != nil { return nil, fmt.Errorf("failed to list pod stats: %v", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 01 18:46:33 UTC 2023 - 5.1K bytes - Viewed (0) -
pkg/kubelet/stats/cri_stats_provider_linux.go
runtimeapi "k8s.io/cri-api/pkg/apis/runtime/v1" statsapi "k8s.io/kubelet/pkg/apis/stats/v1alpha1" ) func (p *criStatsProvider) addCRIPodContainerStats(criSandboxStat *runtimeapi.PodSandboxStats, ps *statsapi.PodStats, fsIDtoInfo map[runtimeapi.FilesystemIdentifier]*cadvisorapiv2.FsInfo, containerMap map[string]*runtimeapi.Container, podSandbox *runtimeapi.PodSandbox, rootFsInfo *cadvisorapiv2.FsInfo, updateCPUNanoCoreUsage bool) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 16 11:09:04 UTC 2023 - 4K bytes - Viewed (0) -
pkg/kubelet/metrics/collectors/log_metrics_test.go
func TestNoMetricsCollected(t *testing.T) { // Refresh Desc to share with different registry descLogSize = descLogSize.GetRawDesc() collector := &logMetricsCollector{ podStats: func(_ context.Context) ([]statsapi.PodStats, error) { return []statsapi.PodStats{}, nil }, } if err := testutil.CustomCollectAndCompare(collector, strings.NewReader(""), ""); err != nil { t.Fatal(err) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Nov 05 13:02:13 UTC 2022 - 2.2K bytes - Viewed (0) -
pkg/kubelet/server/stats/summary_sys_containers.go
statsapi "k8s.io/kubelet/pkg/apis/stats/v1alpha1" "k8s.io/kubernetes/pkg/kubelet/cm" ) func (sp *summaryProviderImpl) GetSystemContainersStats(nodeConfig cm.NodeConfig, podStats []statsapi.PodStats, updateStats bool) (stats []statsapi.ContainerStats) { systemContainers := map[string]struct { name string forceStatsUpdate bool startTime metav1.Time }{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 24 19:47:49 UTC 2021 - 3.5K bytes - Viewed (0) -
pkg/kubelet/metrics/collectors/volume_stats_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 9.5K bytes - Viewed (1)