Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for NewSummaryProvider (0.17 sec)

  1. pkg/kubelet/server/stats/resource_analyzer.go

    	fsAnalyzer := newFsResourceAnalyzer(statsProvider, calVolumeFrequency, eventRecorder)
    	summaryProvider := NewSummaryProvider(statsProvider)
    	return &resourceAnalyzer{fsAnalyzer, summaryProvider}
    }
    
    // Start starts background functions necessary for the ResourceAnalyzer to function
    func (ra *resourceAnalyzer) Start() {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 09 16:16:37 UTC 2021
    - 1.5K bytes
    - Viewed (0)
  2. pkg/kubelet/server/stats/summary.go

    	systemBootTime metav1.Time
    
    	provider Provider
    }
    
    var _ SummaryProvider = &summaryProviderImpl{}
    
    // NewSummaryProvider returns a SummaryProvider using the stats provided by the
    // specified statsProvider.
    func NewSummaryProvider(statsProvider Provider) SummaryProvider {
    	kubeletCreationTime := metav1.Now()
    	bootTime, err := util.GetBootTime()
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 01 18:46:33 UTC 2023
    - 5.1K bytes
    - Viewed (0)
  3. pkg/kubelet/server/stats/summary_test.go

    	mockStatsProvider.EXPECT().GetCgroupCPUAndMemoryStats("/kubepods", false).Return(cgroupStatsMap["/pods"].cs, nil)
    
    	provider := NewSummaryProvider(mockStatsProvider)
    	summary, err := provider.GetCPUAndMemoryStats(ctx)
    	assert.NoError(err)
    
    	assert.Equal(summary.Node.NodeName, "test-node")
    	assert.Equal(summary.Node.StartTime, cgroupStatsMap["/"].cs.StartTime)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 08:12:16 UTC 2024
    - 15.1K bytes
    - Viewed (0)
Back to top