Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for ImageList (0.14 sec)

  1. pkg/kubelet/images/image_gc_manager_test.go

    	manager, fakeRuntime := newRealImageGCManager(ImageGCPolicy{}, mockStatsProvider)
    	fakeRuntime.ImageList = []container.Image{
    		{
    			ID:     sandboxImage,
    			Size:   1024,
    			Pinned: true,
    		},
    	}
    
    	err := manager.DeleteUnusedImages(ctx)
    	assert := assert.New(t)
    	assert.Len(fakeRuntime.ImageList, 1)
    	require.NoError(t, err)
    }
    
    func TestDeletePinnedImage(t *testing.T) {
    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/container/testing/fake_runtime.go

    	f.CalledFunctions = append(f.CalledFunctions, "RemoveImage")
    	index := 0
    	for i := range f.ImageList {
    		if f.ImageList[i].ID == image.Image {
    			index = i
    			break
    		}
    	}
    	f.ImageList = append(f.ImageList[:index], f.ImageList[index+1:]...)
    
    	return f.Err
    }
    
    func (f *FakeRuntime) GarbageCollect(_ context.Context, gcPolicy kubecontainer.GCPolicy, ready bool, evictNonDeletedPods bool) error {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 14 00:23:50 UTC 2024
    - 13.9K bytes
    - Viewed (0)
  3. pkg/kubelet/kuberuntime/kuberuntime_image_test.go

    	imagesPinned := map[string]bool{
    		"1111": false,
    		"2222": true,
    		"3333": false,
    	}
    	imageList := []string{}
    	for image, pinned := range imagesPinned {
    		fakeImageService.SetFakeImagePinned(image, pinned)
    		imageList = append(imageList, image)
    	}
    	fakeImageService.SetFakeImages(imageList)
    
    	actualImages, err := fakeManager.ListImages(ctx)
    	assert.NoError(t, err)
    	for _, image := range actualImages {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 12.8K bytes
    - Viewed (0)
  4. pkg/kubelet/nodestatus/setters_test.go

    	}
    	return images
    }
    
    func makeExpectedImageList(imageList []kubecontainer.Image, maxImages, maxNames int32) []v1.ContainerImage {
    	// copy the imageList, we do not want to mutate it in-place and accidentally edit a test case
    	images := make([]kubecontainer.Image, len(imageList))
    	copy(images, imageList)
    	// sort images by size
    	sort.Sort(sliceutils.ByImageSize(images))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 21:47:24 UTC 2024
    - 76.1K bytes
    - Viewed (0)
  5. pkg/kubelet/images/image_manager_test.go

    	fakeClock = testingclock.NewFakeClock(time.Now())
    	backOff.Clock = fakeClock
    
    	fakeRuntime = &ctest.FakeRuntime{T: t}
    	fakeRecorder := &record.FakeRecorder{}
    
    	fakeRuntime.ImageList = []Image{{ID: "present_image:latest"}}
    	fakeRuntime.Err = c.pullerErr
    	fakeRuntime.InspectErr = c.inspectErr
    
    	fakePodPullingTimeRecorder = &mockPodPullingTimeRecorder{}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 19K bytes
    - Viewed (0)
  6. pkg/kubelet/kubelet_node_status_test.go

    	return imageList, expectedImageList
    }
    
    func makeExpectedImageList(imageList []kubecontainer.Image, maxImages int) []v1.ContainerImage {
    	// expectedImageList is generated by imageList according to size and maxImages
    	// 1. sort the imageList by size
    	sort.Sort(sliceutils.ByImageSize(imageList))
    	// 2. convert sorted imageList to v1.ContainerImage list
    	var expectedImageList []v1.ContainerImage
    	for _, kubeImage := range imageList {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 08 19:23:19 UTC 2024
    - 115.8K bytes
    - Viewed (0)
  7. pkg/kubelet/kubelet_volumes_test.go

    	}
    }
    
    func TestPodVolumeDeadlineAttachAndMount(t *testing.T) {
    	if testing.Short() {
    		t.Skip("skipping test in short mode.")
    	}
    
    	testKubelet := newTestKubeletWithImageList(t, nil /*imageList*/, false, /* controllerAttachDetachEnabled */
    		false /*initFakeVolumePlugin*/, true /*localStorageCapacityIsolation*/)
    
    	defer testKubelet.Cleanup()
    	kubelet := testKubelet.kubelet
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 17 16:53:28 UTC 2023
    - 20.4K bytes
    - Viewed (0)
  8. cmd/kubeadm/app/preflight/checks.go

    	}
    
    	// Perform parallel pulls.
    	if !ipc.imagePullSerial {
    		if err := ipc.runtime.PullImagesInParallel(ipc.imageList, policy == v1.PullIfNotPresent); err != nil {
    			errorList = append(errorList, err)
    		}
    		return warnings, errorList
    	}
    
    	// Perform serial pulls.
    	for _, image := range ipc.imageList {
    		switch policy {
    		case v1.PullIfNotPresent:
    			if ipc.runtime.ImageExists(image) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 03 11:20:55 UTC 2024
    - 39.5K bytes
    - Viewed (0)
  9. pkg/kubelet/kubelet_test.go

    }
    
    func newTestKubeletWithImageList(
    	t *testing.T,
    	imageList []kubecontainer.Image,
    	controllerAttachDetachEnabled bool,
    	initFakeVolumePlugin bool,
    	localStorageCapacityIsolation bool,
    ) *TestKubelet {
    	logger, _ := ktesting.NewTestContext(t)
    
    	fakeRuntime := &containertest.FakeRuntime{
    		ImageList: imageList,
    		// Set ready conditions by default.
    		RuntimeStatus: &kubecontainer.RuntimeStatus{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 106.9K bytes
    - Viewed (0)
Back to top