Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for CustomCollectAndCompare (0.18 sec)

  1. pkg/kubelet/metrics/collectors/log_metrics_test.go

    	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)
    	}
    }
    
    func TestMetricsCollected(t *testing.T) {
    	// Refresh Desc to share with different registry
    	descLogSize = descLogSize.GetRawDesc()
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Nov 05 13:02:13 UTC 2022
    - 2.2K bytes
    - Viewed (0)
  2. pkg/kubelet/metrics/collectors/volume_stats_test.go

    	mockStatsProvider.EXPECT().ListPodStats(ctx).Return(podStats, nil).AnyTimes()
    	mockStatsProvider.EXPECT().ListPodStatsAndUpdateCPUNanoCoreUsage(ctx).Return(podStats, nil).AnyTimes()
    	if err := testutil.CustomCollectAndCompare(&volumeStatsCollector{statsProvider: mockStatsProvider}, strings.NewReader(want), metrics...); err != nil {
    		t.Errorf("unexpected collecting result:\n%s", err)
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 08:12:16 UTC 2024
    - 9.5K bytes
    - Viewed (1)
  3. pkg/kubelet/metrics/collectors/resource_metrics_test.go

    			provider.EXPECT().GetCPUAndMemoryStats(ctx).Return(tc.summary, tc.summaryErr).AnyTimes()
    			collector := NewResourceMetricsCollector(provider)
    
    			if err := testutil.CustomCollectAndCompare(collector, strings.NewReader(tc.expectedMetrics), interestedMetrics...); err != nil {
    				t.Fatal(err)
    			}
    		})
    	}
    }
    
    func uint64Ptr(u uint64) *uint64 {
    	return &u
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 08:12:16 UTC 2024
    - 15.3K bytes
    - Viewed (1)
Back to top