Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for NewMockProvider (0.17 sec)

  1. pkg/kubelet/images/image_gc_manager_test.go

    	}
    }
    
    func TestDetectImagesInitialDetect(t *testing.T) {
    	ctx := context.Background()
    	mockCtrl := gomock.NewController(t)
    	defer mockCtrl.Finish()
    	mockStatsProvider := statstest.NewMockProvider(mockCtrl)
    
    	manager, fakeRuntime := newRealImageGCManager(ImageGCPolicy{}, mockStatsProvider)
    	fakeRuntime.ImageList = []container.Image{
    		makeImage(0, 1024),
    		makeImage(1, 2048),
    		makeImage(2, 2048),
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 22 15:38:20 UTC 2024
    - 29.2K bytes
    - Viewed (0)
  2. pkg/kubelet/server/stats/volume_stat_calculator_test.go

    	volumeCondition = &csipbv1.VolumeCondition{}
    )
    
    func TestPVCRef(t *testing.T) {
    	mockCtrl := gomock.NewController(t)
    	defer mockCtrl.Finish()
    
    	// Setup mock stats provider
    	mockStats := statstest.NewMockProvider(mockCtrl)
    	volumes := map[string]volume.Volume{vol0: &fakeVolume{}, vol1: &fakeVolume{}, vol3: &fakeVolume{}}
    	mockStats.EXPECT().ListVolumesForPod(fakePod.UID).Return(volumes, true)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 9.6K bytes
    - Viewed (0)
  3. pkg/kubelet/metrics/collectors/volume_stats_test.go

    			"kubelet_volume_stats_used_bytes",
    			"kubelet_volume_stats_health_status_abnormal",
    		}
    	)
    
    	mockCtrl := gomock.NewController(t)
    	defer mockCtrl.Finish()
    	mockStatsProvider := statstest.NewMockProvider(mockCtrl)
    
    	mockStatsProvider.EXPECT().ListPodStats(ctx).Return(podStats, nil).AnyTimes()
    	mockStatsProvider.EXPECT().ListPodStatsAndUpdateCPUNanoCoreUsage(ctx).Return(podStats, nil).AnyTimes()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 08:12:16 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  4. pkg/kubelet/server/stats/summary_test.go

    		"/pods":    {cs: getContainerStats(), ns: getNetworkStats()},
    	}
    
    	mockCtrl := gomock.NewController(t)
    	defer mockCtrl.Finish()
    	mockStatsProvider := statstest.NewMockProvider(mockCtrl)
    
    	mockStatsProvider.EXPECT().GetNode().Return(node, nil)
    	mockStatsProvider.EXPECT().GetNodeConfig().Return(nodeConfig)
    	mockStatsProvider.EXPECT().GetPodCgroupRoot().Return(cgroupRoot)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 08:12:16 UTC 2024
    - 15.1K bytes
    - Viewed (0)
  5. pkg/kubelet/server/stats/testing/mock_stats_provider.go

    	recorder *MockProviderMockRecorder
    }
    
    // MockProviderMockRecorder is the mock recorder for MockProvider.
    type MockProviderMockRecorder struct {
    	mock *MockProvider
    }
    
    // NewMockProvider creates a new mock instance.
    func NewMockProvider(ctrl *gomock.Controller) *MockProvider {
    	mock := &MockProvider{ctrl: ctrl}
    	mock.recorder = &MockProviderMockRecorder{mock}
    	return mock
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 08:12:16 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  6. pkg/kubelet/server/stats/summary_windows_test.go

    			"/pods": {cs: getContainerStats()},
    		}
    	)
    
    	assert := assert.New(t)
    
    	mockCtrl := gomock.NewController(t)
    	defer mockCtrl.Finish()
    
    	mockStatsProvider := statstest.NewMockProvider(mockCtrl)
    	mockStatsProvider.EXPECT().GetNode().Return(node, nil).AnyTimes()
    	mockStatsProvider.EXPECT().GetNodeConfig().Return(nodeConfig).AnyTimes()
    	mockStatsProvider.EXPECT().GetPodCgroupRoot().Return(cgroupRoot).AnyTimes()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 08:12:16 UTC 2024
    - 4.4K bytes
    - Viewed (0)
Back to top