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) {}

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 (m *mockDiskGC) IsContainerFsSeparateFromImageFs(_ context.Context) bool {}

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) {}