Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 31 for modstat (0.49 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. pkg/kubelet/metrics/collectors/volume_stats_test.go

    		# TYPE kubelet_volume_stats_health_status_abnormal gauge
    	`
    
    	var (
    		podStats = []statsapi.PodStats{
    			{
    				PodRef:    statsapi.PodReference{Name: "test-pod", Namespace: "test-namespace", UID: "UID_test-pod"},
    				StartTime: metav1.Now(),
    				VolumeStats: []statsapi.VolumeStats{
    					{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 08:12:16 UTC 2024
    - 9.5K bytes
    - Viewed (1)
Back to top