kubernetes/pkg/kubelet/eviction/eviction_manager_test.go

const lowPriority …

const defaultPriority …

const highPriority …

type mockPodKiller …

// killPodNow records the pod that was killed
func (m *mockPodKiller) killPodNow(pod *v1.Pod, evict bool, gracePeriodOverride *int64, statusFn func(*v1.PodStatus)) error { … }

type mockDiskInfoProvider …

// HasDedicatedImageFs returns the mocked value
func (m *mockDiskInfoProvider) HasDedicatedImageFs(_ context.Context) (bool, error) { … }

// HasDedicatedContainerFs returns the mocked value
func (m *mockDiskInfoProvider) HasDedicatedContainerFs(_ context.Context) (bool, error) { … }

type mockDiskGC …

// DeleteUnusedImages returns the mocked values.
func (m *mockDiskGC) DeleteUnusedImages(_ context.Context) error { … }

// DeleteAllUnusedContainers returns the mocked value
func (m *mockDiskGC) DeleteAllUnusedContainers(_ context.Context) error { … }

func makePodWithMemoryStats(name string, priority int32, requests v1.ResourceList, limits v1.ResourceList, memoryWorkingSet string) (*v1.Pod, statsapi.PodStats) { … }

func makePodWithPIDStats(name string, priority int32, processCount uint64) (*v1.Pod, statsapi.PodStats) { … }

func makePodWithDiskStats(name string, priority int32, requests v1.ResourceList, limits v1.ResourceList, rootFsUsed, logsUsed, perLocalVolumeUsed string, volumes []v1.Volume) (*v1.Pod, statsapi.PodStats) { … }

func makePodWithLocalStorageCapacityIsolationOpen(name string, priority int32, requests v1.ResourceList, limits v1.ResourceList, memoryWorkingSet string) (*v1.Pod, statsapi.PodStats) { … }

func makePIDStats(nodeAvailablePIDs string, numberOfRunningProcesses string, podStats map[*v1.Pod]statsapi.PodStats) *statsapi.Summary { … }

func makeMemoryStats(nodeAvailableBytes string, podStats map[*v1.Pod]statsapi.PodStats) *statsapi.Summary { … }

type diskStats …

func makeDiskStats(diskStats diskStats) *statsapi.Summary { … }

type podToMake …

func TestMemoryPressure_VerifyPodStatus(t *testing.T) { … }

func TestPIDPressure_VerifyPodStatus(t *testing.T) { … }

func TestDiskPressureNodeFs_VerifyPodStatus(t *testing.T) { … }

// TestMemoryPressure
func TestMemoryPressure(t *testing.T) { … }

func makeContainersByQOS(class v1.PodQOSClass) []v1.Container { … }

func TestPIDPressure(t *testing.T) { … }

func TestAdmitUnderNodeConditions(t *testing.T) { … }

// parseQuantity parses the specified value (if provided) otherwise returns 0 value
func parseQuantity(value string) resource.Quantity { … }

func TestDiskPressureNodeFs(t *testing.T) { … }

// TestMinReclaim verifies that min-reclaim works as desired.
func TestMinReclaim(t *testing.T) { … }

func TestNodeReclaimFuncs(t *testing.T) { … }

func TestInodePressureFsInodes(t *testing.T) { … }

// TestStaticCriticalPodsAreNotEvicted
func TestStaticCriticalPodsAreNotEvicted(t *testing.T) { … }

func TestStorageLimitEvictions(t *testing.T) { … }

// TestAllocatableMemoryPressure
func TestAllocatableMemoryPressure(t *testing.T) { … }

func TestUpdateMemcgThreshold(t *testing.T) { … }

func TestManagerWithLocalStorageCapacityIsolationOpen(t *testing.T) { … }