kubernetes/test/e2e_node/dra_test.go

const driverName …

const kubeletPlugin1Name …

const kubeletPlugin2Name …

const cdiDir …

const endpointTemplate …

const pluginRegistrationPath …

const pluginRegistrationTimeout …

const podInPendingStateTimeout …

const kubeletRetryPeriod …

const retryTestTimeout …

var _ …

// Run Kubelet plugin and wait until it's registered
func newKubeletPlugin(ctx context.Context, clientSet kubernetes.Interface, nodeName, pluginName string) *testdriver.ExamplePlugin { … }

// createTestObjects creates objects required by the test
// NOTE: as scheduler and controller manager are not running by the Node e2e,
// the objects must contain all required data to be processed correctly by the API server
// and placed on the node without involving the scheduler and the DRA controller
func createTestObjects(ctx context.Context, clientSet kubernetes.Interface, nodename, namespace, className, claimName, podName string, deferPodDeletion bool, driverNames []string) *v1.Pod { … }

func createTestResourceSlice(ctx context.Context, clientSet kubernetes.Interface, nodeName, driverName string) { … }