kubernetes/test/e2e/storage/drivers/csi.go

const GCEPDCSIDriverName …

const GCEPDCSIZoneTopologyKey …

const grpcCallPrefix …

const hostpathCSIDriverMutableParameterName …

const hostpathCSIDriverMutableParameterValue …

type hostpathCSIDriver …

func initHostPathCSIDriver(name string, capabilities map[storageframework.Capability]bool, volumeAttributes []map[string]string, manifests ...string) storageframework.TestDriver { … }

var _ …

var _ …

var _ …

var _ …

// InitHostPathCSIDriver returns hostpathCSIDriver that implements TestDriver interface
func InitHostPathCSIDriver() storageframework.TestDriver { … }

func (h *hostpathCSIDriver) GetDriverInfo() *storageframework.DriverInfo { … }

func (h *hostpathCSIDriver) SkipUnsupportedTest(pattern storageframework.TestPattern) { … }

func (h *hostpathCSIDriver) GetDynamicProvisionStorageClass(ctx context.Context, config *storageframework.PerTestConfig, fsType string) *storagev1.StorageClass { … }

func (h *hostpathCSIDriver) GetVolume(config *storageframework.PerTestConfig, volumeNumber int) (map[string]string, bool, bool) { … }

func (h *hostpathCSIDriver) GetCSIDriverName(config *storageframework.PerTestConfig) string { … }

func (h *hostpathCSIDriver) GetSnapshotClass(ctx context.Context, config *storageframework.PerTestConfig, parameters map[string]string) *unstructured.Unstructured { … }

func (h *hostpathCSIDriver) GetVolumeAttributesClass(_ context.Context, config *storageframework.PerTestConfig) *storagev1beta1.VolumeAttributesClass { … }

func (h *hostpathCSIDriver) GetVolumeGroupSnapshotClass(ctx context.Context, config *storageframework.PerTestConfig, parameters map[string]string) *unstructured.Unstructured { … }

func (h *hostpathCSIDriver) PrepareTest(ctx context.Context, f *framework.Framework) *storageframework.PerTestConfig { … }

type mockCSIDriver …

type Hooks …

type MockCSITestDriver …

type CSIMockDriverOpts …

type MockCSICall …

type MockCSICalls …

// Get returns all currently recorded calls.
func (c *MockCSICalls) Get() []MockCSICall { … }

// Add appends one new call at the end.
func (c *MockCSICalls) Add(call MockCSICall) { … }

// LogGRPC takes individual parameters from the mock CSI driver and adds them.
func (c *MockCSICalls) LogGRPC(method string, request, reply interface{ … }

var _ …

var _ …

var _ …

// InitMockCSIDriver returns a mockCSIDriver that implements TestDriver interface
func InitMockCSIDriver(driverOpts CSIMockDriverOpts) MockCSITestDriver { … }

func (m *mockCSIDriver) GetDriverInfo() *storageframework.DriverInfo { … }

func (m *mockCSIDriver) SkipUnsupportedTest(pattern storageframework.TestPattern) { … }

func (m *mockCSIDriver) GetDynamicProvisionStorageClass(ctx context.Context, config *storageframework.PerTestConfig, fsType string) *storagev1.StorageClass { … }

func (m *mockCSIDriver) GetSnapshotClass(ctx context.Context, config *storageframework.PerTestConfig, parameters map[string]string) *unstructured.Unstructured { … }

func (m *mockCSIDriver) PrepareTest(ctx context.Context, f *framework.Framework) *storageframework.PerTestConfig { … }

func (m *mockCSIDriver) interceptGRPC(ctx context.Context, req interface{ … }

func (m *mockCSIDriver) GetCalls(ctx context.Context) ([]MockCSICall, error) { … }

type gcePDCSIDriver …

var _ …

var _ …

var _ …

// InitGcePDCSIDriver returns gcePDCSIDriver that implements TestDriver interface
func InitGcePDCSIDriver() storageframework.TestDriver { … }

func (g *gcePDCSIDriver) GetDriverInfo() *storageframework.DriverInfo { … }

func (g *gcePDCSIDriver) SkipUnsupportedTest(pattern storageframework.TestPattern) { … }

func (g *gcePDCSIDriver) GetDynamicProvisionStorageClass(ctx context.Context, config *storageframework.PerTestConfig, fsType string) *storagev1.StorageClass { … }

func (g *gcePDCSIDriver) GetSnapshotClass(ctx context.Context, config *storageframework.PerTestConfig, parameters map[string]string) *unstructured.Unstructured { … }

func (g *gcePDCSIDriver) PrepareTest(ctx context.Context, f *framework.Framework) *storageframework.PerTestConfig { … }

// WaitForCSIDriverRegistrationOnAllNodes waits for the CSINode object to be updated
// with the given driver on all schedulable nodes.
func WaitForCSIDriverRegistrationOnAllNodes(ctx context.Context, driverName string, cs clientset.Interface) error { … }

// WaitForCSIDriverRegistrationOnNode waits for the CSINode object generated by the node-registrar on a certain node
func WaitForCSIDriverRegistrationOnNode(ctx context.Context, nodeName string, driverName string, cs clientset.Interface) error { … }

func tryFunc(f func()) error { … }

func generateDriverCleanupFunc(
	f *framework.Framework,
	driverName, testns, driverns string,
	cancelLogging func()) func(ctx context.Context) { … }