kubernetes/test/e2e_node/podresources_test.go

const defaultTopologyUnawareResourceName …

type podDesc …

func (desc podDesc) CpuRequestQty() resource.Quantity { … }

func (desc podDesc) CpuRequestExclusive() int { … }

func (desc podDesc) RequiresCPU() bool { … }

func (desc podDesc) RequiresDevices() bool { … }

type initContainerDesc …

func (desc initContainerDesc) CPURequestQty() resource.Quantity { … }

func (desc initContainerDesc) CPURequestExclusive() int { … }

func (desc initContainerDesc) RequiresCPU() bool { … }

func (desc initContainerDesc) RequiresDevices() bool { … }

func makePodResourcesTestPod(desc podDesc) *v1.Pod { … }

func logPodResources(podIdx int, pr *kubeletpodresourcesv1.PodResources) { … }

type podResMap …

func convertToMap(podsResources []*kubeletpodresourcesv1.PodResources) podResMap { … }

func getPodResourcesValues(ctx context.Context, cli kubeletpodresourcesv1.PodResourcesListerClient) (podResMap, error) { … }

type testPodData …

func newTestPodData() *testPodData { … }

func (tpd *testPodData) createPodsForTest(ctx context.Context, f *framework.Framework, podReqs []podDesc) { … }

/* deletePodsForTest clean up all the pods run for a testcase. Must ensure proper cleanup */
func (tpd *testPodData) deletePodsForTest(ctx context.Context, f *framework.Framework) { … }

/* deletePod removes pod during a test. Should do a best-effort clean up */
func (tpd *testPodData) deletePod(ctx context.Context, f *framework.Framework, podName string) { … }

func findContainerDeviceByName(devs []*kubeletpodresourcesv1.ContainerDevices, resourceName string) *kubeletpodresourcesv1.ContainerDevices { … }

func matchPodDescWithResources(expected []podDesc, found podResMap) error { … }

func expectPodResources(ctx context.Context, offset int, cli kubeletpodresourcesv1.PodResourcesListerClient, expected []podDesc) { … }

func filterOutDesc(descs []podDesc, name string) []podDesc { … }

func podresourcesListTests(ctx context.Context, f *framework.Framework, cli kubeletpodresourcesv1.PodResourcesListerClient, sd *sriovData, sidecarContainersEnabled bool) { … }

func podresourcesGetAllocatableResourcesTests(ctx context.Context, cli kubeletpodresourcesv1.PodResourcesListerClient, sd *sriovData, onlineCPUs, reservedSystemCPUs cpuset.CPUSet) { … }

func demuxCPUsAndDevicesFromGetAllocatableResources(resp *kubeletpodresourcesv1.AllocatableResourcesResponse) (cpuset.CPUSet, []*kubeletpodresourcesv1.ContainerDevices) { … }

func podresourcesGetTests(ctx context.Context, f *framework.Framework, cli kubeletpodresourcesv1.PodResourcesListerClient, sidecarContainersEnabled bool) { … }

var _ …

func requireLackOfSRIOVDevices() { … }

func getOnlineCPUs() (cpuset.CPUSet, error) { … }

func setupSampleDevicePluginOrFail(ctx context.Context, f *framework.Framework) *v1.Pod { … }

func teardownSampleDevicePluginOrFail(ctx context.Context, f *framework.Framework, pod *v1.Pod) { … }

func waitForTopologyUnawareResources(ctx context.Context, f *framework.Framework) { … }

func getPodResourcesMetrics(ctx context.Context) (e2emetrics.KubeletMetrics, error) { … }

func timelessSampleAtLeast(lower interface{ … }