Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 95 for modstat (0.8 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top