const postTestConditionMonitoringPeriod … const evictionPollInterval … const pressureDisappearTimeout … const pressureDelay … const testContextFmt … const noPressure … const lotsOfDisk … const lotsOfFiles … const resourceInodes … const noStarvedResource … var _ … var _ … var _ … var _ … var _ … var _ … var _ … var _ … var _ … var _ … var _ … type podEvictSpec … // runEvictionTest sets up a testing environment given the provided pods, and checks a few things: // // It ensures that the desired expectedNodeCondition is actually triggered. // It ensures that evictionPriority 0 pods are not evicted // It ensures that lower evictionPriority pods are always evicted before higher evictionPriority pods (2 evicted before 1, etc.) // It ensures that all pods with non-zero evictionPriority are eventually evicted. // // runEvictionTest then cleans up the testing environment by deleting provided pods, and ensures that expectedNodeCondition no longer exists func runEvictionTest(f *framework.Framework, pressureTimeout time.Duration, expectedNodeCondition v1.NodeConditionType, expectedStarvedResource v1.ResourceName, logFunc func(ctx context.Context), testSpecs []podEvictSpec) { … } // verifyEvictionOrdering returns an error if all non-zero priority pods have not been evicted, nil otherwise // This function panics (via Expect) if eviction ordering is violated, or if a priority-zero pod fails. func verifyEvictionOrdering(ctx context.Context, f *framework.Framework, testSpecs []podEvictSpec) error { … } func verifyEvictionPeriod(ctx context.Context, f *framework.Framework, testSpecs []podEvictSpec, nodeUnreadyTime time.Time) { … } func verifyPodConditions(ctx context.Context, f *framework.Framework, testSpecs []podEvictSpec) { … } func verifyEvictionEvents(ctx context.Context, f *framework.Framework, testSpecs []podEvictSpec, expectedStarvedResource v1.ResourceName) { … } // Returns TRUE if the node has the node condition, FALSE otherwise func hasNodeCondition(ctx context.Context, f *framework.Framework, expectedNodeCondition v1.NodeConditionType) bool { … } func logInodeMetrics(ctx context.Context) { … } func logDiskMetrics(ctx context.Context) { … } func logMemoryMetrics(ctx context.Context) { … } func logPidMetrics(ctx context.Context) { … } func eventuallyGetSummary(ctx context.Context) (s *kubeletstatsv1alpha1.Summary) { … } // returns a pod that does not use any resources func innocentPod() *v1.Pod { … } const volumeMountPath … const volumeName … func inodeConsumingPod(name string, numFiles int, volumeSource *v1.VolumeSource) *v1.Pod { … } func diskConsumingPod(name string, diskConsumedMB int, volumeSource *v1.VolumeSource, resources v1.ResourceRequirements) *v1.Pod { … } func pidConsumingPod(name string, numProcesses int) *v1.Pod { … } // podWithCommand returns a pod with the provided volumeSource and resourceRequirements. func podWithCommand(volumeSource *v1.VolumeSource, resources v1.ResourceRequirements, iterations int, name, command string) *v1.Pod { … } func getMemhogPod(podName string, ctnName string, res v1.ResourceRequirements) *v1.Pod { … }
Codebase Browser
kubernetes