Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for HasDedicatedImageFs (0.21 sec)

  1. pkg/kubelet/eviction/mock_threshold_notifier_test.go

    	return m.recorder
    }
    
    // HasDedicatedImageFs mocks base method.
    func (m *MockDiskInfoProvider) HasDedicatedImageFs(ctx context.Context) (bool, error) {
    	m.ctrl.T.Helper()
    	ret := m.ctrl.Call(m, "HasDedicatedImageFs", ctx)
    	ret0, _ := ret[0].(bool)
    	ret1, _ := ret[1].(error)
    	return ret0, ret1
    }
    
    // HasDedicatedImageFs indicates an expected call of HasDedicatedImageFs.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 08:12:16 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  2. pkg/kubelet/eviction/types.go

    	IsUnderPIDPressure() bool
    }
    
    // DiskInfoProvider is responsible for informing the manager how disk is configured.
    type DiskInfoProvider interface {
    	// HasDedicatedImageFs returns true if the imagefs is on a separate device from the rootfs.
    	HasDedicatedImageFs(ctx context.Context) (bool, error)
    }
    
    // ImageGC is responsible for performing garbage collection of unused images.
    type ImageGC interface {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 01 18:46:33 UTC 2023
    - 7.1K bytes
    - Viewed (0)
  3. pkg/kubelet/stats/provider.go

    		Inodes:         rootFsInfo.Inodes,
    		InodesUsed:     nodeFsInodesUsed,
    	}, nil
    }
    
    // HasDedicatedImageFs returns true if a dedicated image filesystem exists for storing images.
    // KEP Issue Number 4191: Enhanced this to allow for the containers to be separate from images.
    func (p *Provider) HasDedicatedImageFs(ctx context.Context) (bool, error) {
    	device, err := p.containerStatsProvider.ImageFsDevice(ctx)
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 13:56:22 UTC 2023
    - 7.4K bytes
    - Viewed (0)
  4. pkg/kubelet/eviction/eviction_manager.go

    	if m.dedicatedImageFs == nil {
    		hasImageFs, splitDiskError := diskInfoProvider.HasDedicatedImageFs(ctx)
    		if splitDiskError != nil {
    			klog.ErrorS(splitDiskError, "Eviction manager: failed to get HasDedicatedImageFs")
    			return nil, fmt.Errorf("eviction manager: failed to get HasDedicatedImageFs: %v", splitDiskError)
    		}
    		m.dedicatedImageFs = &hasImageFs
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 27 18:55:56 UTC 2024
    - 24.6K bytes
    - Viewed (0)
  5. pkg/kubelet/stats/provider_test.go

    			device:      test.imagefsDevice,
    			imageFs:     test.imageFsStats,
    			containerFs: test.containerFsStats,
    		})
    
    		dedicated, err := provider.HasDedicatedImageFs(ctx)
    		assert.NoError(t, err)
    		assert.Equal(t, test.dedicated, dedicated)
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 08:12:16 UTC 2024
    - 20K bytes
    - Viewed (0)
  6. pkg/kubelet/eviction/eviction_manager_test.go

    	return nil
    }
    
    // mockDiskInfoProvider is used to simulate testing.
    type mockDiskInfoProvider struct {
    	dedicatedImageFs *bool
    }
    
    // HasDedicatedImageFs returns the mocked value
    func (m *mockDiskInfoProvider) HasDedicatedImageFs(_ context.Context) (bool, error) {
    	return ptr.Deref(m.dedicatedImageFs, false), nil
    }
    
    // mockDiskGC is used to simulate invoking image and container garbage collection.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 15 23:14:12 UTC 2024
    - 119.9K bytes
    - Viewed (0)
Back to top