- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 95 for modstat (0.8 sec)
-
pkg/kubelet/eviction/eviction_manager.go
for _, pod := range pods { podStats, ok := statsFunc(pod) if !ok { continue } if m.emptyDirLimitEviction(podStats, pod) { evicted = append(evicted, pod) continue } if m.podEphemeralStorageLimitEviction(podStats, pod) { evicted = append(evicted, pod) continue } if m.containerEphemeralStorageLimitEviction(podStats, pod) { evicted = append(evicted, pod)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 27 18:55:56 UTC 2024 - 24.6K bytes - Viewed (0) -
pkg/kubelet/eviction/helpers_test.go
} for _, pod := range pods { podStats, found := statsFunc(pod) if !found { t.Errorf("Pod stats were not found for pod %v", pod.UID) } if *podStats.Memory.WorkingSetBytes != podWorkingSetBytes { t.Errorf("Pod working set expected %v, actual: %v", podWorkingSetBytes, *podStats.Memory.WorkingSetBytes) } } } func TestThresholdsMet(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 15 23:14:12 UTC 2024 - 106.7K bytes - Viewed (0) -
pkg/kubelet/stats/cri_stats_provider_windows.go
} } func addCRIPodProcessStats(ps *statsapi.PodStats, criPodStat *runtimeapi.PodSandboxStats) { if criPodStat == nil || criPodStat.Windows == nil || criPodStat.Windows.Process == nil { return } ps.ProcessStats = &statsapi.ProcessStats{ ProcessCount: valueOfUInt64Value(criPodStat.Windows.Process.ProcessCount), } } func addCRIPodNetworkStats(ps *statsapi.PodStats, criPodStat *runtimeapi.PodSandboxStats) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Feb 18 07:03:11 UTC 2024 - 10.4K bytes - Viewed (0) -
cmd/metrics-realtime.go
} else { m.Aggregated.CPU.CPUCount = cpuCount } loadStat, err := load.Avg() if err != nil { m.Errors = append(m.Errors, fmt.Sprintf("%s: %v (loadStat)", byHostName, err.Error())) } else { m.Aggregated.CPU.LoadStat = loadStat } } if types.Contains(madmin.MetricsRPC) { gr := globalGrid.Load() if gr == nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Jun 01 05:16:24 UTC 2024 - 6.3K bytes - Viewed (0) -
pkg/kubelet/stats/provider.go
// containers managed by pods. type containerStatsProvider interface { ListPodStats(ctx context.Context) ([]statsapi.PodStats, error) ListPodStatsAndUpdateCPUNanoCoreUsage(ctx context.Context) ([]statsapi.PodStats, error) ListPodCPUAndMemoryStats(ctx context.Context) ([]statsapi.PodStats, error) ImageFsStats(ctx context.Context) (*statsapi.FsStats, *statsapi.FsStats, error) ImageFsDevice(ctx context.Context) (string, error) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 15 13:56:22 UTC 2023 - 7.4K bytes - Viewed (0) -
pkg/kubelet/eviction/helpers.go
} // cachedStatsFunc returns a statsFunc based on the provided pod stats. func cachedStatsFunc(podStats []statsapi.PodStats) statsFunc { uid2PodStats := map[string]statsapi.PodStats{} for i := range podStats { uid2PodStats[podStats[i].PodRef.UID] = podStats[i] } return func(pod *v1.Pod) (statsapi.PodStats, bool) { stats, found := uid2PodStats[string(pod.UID)] return stats, found } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 01 18:46:33 UTC 2023 - 53.6K bytes - Viewed (0) -
pkg/kubelet/stats/cri_stats_provider_test.go
} } return podSandboxStats } func getPodSandboxStatsStrictlyFromCRI(seed int, podSandbox *critest.FakePodSandbox) statsapi.PodStats { podStats := statsapi.PodStats{ PodRef: statsapi.PodReference{ Name: podSandbox.Metadata.Name, UID: podSandbox.Metadata.Uid, Namespace: podSandbox.Metadata.Namespace, },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 14:24:16 UTC 2024 - 54.5K bytes - Viewed (0) -
pkg/kubelet/metrics/collectors/resource_metrics_test.go
resource_scrape_error 0 `, }, { name: "arbitrary container metrics for different container, pods and namespaces", summary: &statsapi.Summary{ Pods: []statsapi.PodStats{ { PodRef: statsapi.PodReference{ Name: "pod_a", Namespace: "namespace_a", }, Containers: []statsapi.ContainerStats{ { Name: "container_a",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 15.3K bytes - Viewed (1) -
pkg/kubelet/server/stats/testing/mock_stats_provider.go
} // ListPodCPUAndMemoryStats mocks base method. func (m *MockProvider) ListPodCPUAndMemoryStats(ctx context.Context) ([]v1alpha1.PodStats, error) { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "ListPodCPUAndMemoryStats", ctx) ret0, _ := ret[0].([]v1alpha1.PodStats) ret1, _ := ret[1].(error) return ret0, ret1 } // ListPodCPUAndMemoryStats indicates an expected call of ListPodCPUAndMemoryStats.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 11.8K bytes - Viewed (0) -
src/cmd/vendor/rsc.io/markdown/para.go
func (b *Empty) PrintHTML(buf *bytes.Buffer) {} func (b *Empty) printMarkdown(*bytes.Buffer, mdState) {} type Paragraph struct { Position Text *Text } func (b *Paragraph) PrintHTML(buf *bytes.Buffer) { buf.WriteString("<p>") b.Text.PrintHTML(buf) buf.WriteString("</p>\n") } func (b *Paragraph) printMarkdown(buf *bytes.Buffer, s mdState) { // // Ignore prefix when in a list. // if s.bullet == 0 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 24 13:01:26 UTC 2024 - 2.8K bytes - Viewed (0)