- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for ImageList (0.3 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)