kubernetes/test/e2e_node/device_plugin_test.go

var appsScheme …

var appsCodecs …

var _ …

// readDaemonSetV1OrDie reads daemonset object from bytes. Panics on error.
func readDaemonSetV1OrDie(objBytes []byte) *appsv1.DaemonSet { … }

const expectedSampleDevsAmount …

const sleepIntervalForever …

const sleepIntervalWithRestart …

const sleepIntervalToCompletion …

func testDevicePlugin(f *framework.Framework, pluginSockDir string) { … }

func testDevicePluginNodeReboot(f *framework.Framework, pluginSockDir string) { … }

// makeBusyboxPod returns a simple Pod spec with a busybox container
// that requests SampleDeviceResourceName and runs the specified command.
func makeBusyboxPod(SampleDeviceResourceName, cmd string) *v1.Pod { … }

// ensurePodContainerRestart confirms that pod container has restarted at least once
func ensurePodContainerRestart(ctx context.Context, f *framework.Framework, podName string, contName string) { … }

// parseLog returns the matching string for the specified regular expression parsed from the container logs.
func parseLog(ctx context.Context, f *framework.Framework, podName string, contName string, re string) (string, error) { … }

func checkPodResourcesAssignment(v1PodRes *kubeletpodresourcesv1.ListPodResourcesResponse, podNamespace, podName, containerName, resourceName string, devs []string) (error, bool) { … }

func matchContainerDevices(ident string, contDevs []*kubeletpodresourcesv1.ContainerDevices, resourceName string, devs []string) (error, bool) { … }

// getSampleDevicePluginPod returns the Sample Device Plugin pod to be used e2e tests.
func getSampleDevicePluginPod(pluginSockDir string) *v1.Pod { … }

func BeTheSamePodStillRunning(expected *v1.Pod) types.GomegaMatcher { … }

// BeReady matches if the pod is reported ready
func BeAPodReady() types.GomegaMatcher { … }

// BeAPodInPhase matches if the pod is running
func BeAPodInPhase(phase v1.PodPhase) types.GomegaMatcher { … }

// BeTheSamePodAs matches if the pod has the given UID
func BeTheSamePodAs(podUID k8stypes.UID) types.GomegaMatcher { … }