const iSCSIIQNTemplate … type nfsDriver … type nfsVolume … var _ … var _ … var _ … var _ … var _ … // InitNFSDriver returns nfsDriver that implements TestDriver interface func InitNFSDriver() storageframework.TestDriver { … } func (n *nfsDriver) GetDriverInfo() *storageframework.DriverInfo { … } func (n *nfsDriver) SkipUnsupportedTest(pattern storageframework.TestPattern) { … } func (n *nfsDriver) GetVolumeSource(readOnly bool, fsType string, e2evolume storageframework.TestVolume) *v1.VolumeSource { … } func (n *nfsDriver) GetPersistentVolumeSource(readOnly bool, fsType string, e2evolume storageframework.TestVolume) (*v1.PersistentVolumeSource, *v1.VolumeNodeAffinity) { … } func (n *nfsDriver) GetDynamicProvisionStorageClass(ctx context.Context, config *storageframework.PerTestConfig, fsType string) *storagev1.StorageClass { … } func (n *nfsDriver) PrepareTest(ctx context.Context, f *framework.Framework) *storageframework.PerTestConfig { … } func (n *nfsDriver) CreateVolume(ctx context.Context, config *storageframework.PerTestConfig, volType storageframework.TestVolType) storageframework.TestVolume { … } func (v *nfsVolume) DeleteVolume(ctx context.Context) { … } type iSCSIDriver … type iSCSIVolume … var _ … var _ … var _ … var _ … // InitISCSIDriver returns iSCSIDriver that implements TestDriver interface func InitISCSIDriver() storageframework.TestDriver { … } func (i *iSCSIDriver) GetDriverInfo() *storageframework.DriverInfo { … } func (i *iSCSIDriver) SkipUnsupportedTest(pattern storageframework.TestPattern) { … } func (i *iSCSIDriver) GetVolumeSource(readOnly bool, fsType string, e2evolume storageframework.TestVolume) *v1.VolumeSource { … } func (i *iSCSIDriver) GetPersistentVolumeSource(readOnly bool, fsType string, e2evolume storageframework.TestVolume) (*v1.PersistentVolumeSource, *v1.VolumeNodeAffinity) { … } func (i *iSCSIDriver) PrepareTest(ctx context.Context, f *framework.Framework) *storageframework.PerTestConfig { … } func (i *iSCSIDriver) CreateVolume(ctx context.Context, config *storageframework.PerTestConfig, volType storageframework.TestVolType) storageframework.TestVolume { … } // newISCSIServer is an iSCSI-specific wrapper for CreateStorageServer. func newISCSIServer(ctx context.Context, cs clientset.Interface, namespace string) (config e2evolume.TestConfig, pod *v1.Pod, ip, iqn string) { … } func (v *iSCSIVolume) DeleteVolume(ctx context.Context) { … } type hostPathDriver … var _ … var _ … var _ … // InitHostPathDriver returns hostPathDriver that implements TestDriver interface func InitHostPathDriver() storageframework.TestDriver { … } func (h *hostPathDriver) GetDriverInfo() *storageframework.DriverInfo { … } func (h *hostPathDriver) SkipUnsupportedTest(pattern storageframework.TestPattern) { … } func (h *hostPathDriver) GetVolumeSource(readOnly bool, fsType string, e2evolume storageframework.TestVolume) *v1.VolumeSource { … } func (h *hostPathDriver) PrepareTest(ctx context.Context, f *framework.Framework) *storageframework.PerTestConfig { … } func (h *hostPathDriver) CreateVolume(ctx context.Context, config *storageframework.PerTestConfig, volType storageframework.TestVolType) storageframework.TestVolume { … } type hostPathSymlinkDriver … type hostPathSymlinkVolume … var _ … var _ … var _ … // InitHostPathSymlinkDriver returns hostPathSymlinkDriver that implements TestDriver interface func InitHostPathSymlinkDriver() storageframework.TestDriver { … } func (h *hostPathSymlinkDriver) GetDriverInfo() *storageframework.DriverInfo { … } func (h *hostPathSymlinkDriver) SkipUnsupportedTest(pattern storageframework.TestPattern) { … } func (h *hostPathSymlinkDriver) GetVolumeSource(readOnly bool, fsType string, e2evolume storageframework.TestVolume) *v1.VolumeSource { … } func (h *hostPathSymlinkDriver) PrepareTest(ctx context.Context, f *framework.Framework) *storageframework.PerTestConfig { … } func (h *hostPathSymlinkDriver) CreateVolume(ctx context.Context, config *storageframework.PerTestConfig, volType storageframework.TestVolType) storageframework.TestVolume { … } func (v *hostPathSymlinkVolume) DeleteVolume(ctx context.Context) { … } type emptydirDriver … var _ … var _ … var _ … // InitEmptydirDriver returns emptydirDriver that implements TestDriver interface func InitEmptydirDriver() storageframework.TestDriver { … } func (e *emptydirDriver) GetDriverInfo() *storageframework.DriverInfo { … } func (e *emptydirDriver) SkipUnsupportedTest(pattern storageframework.TestPattern) { … } func (e *emptydirDriver) GetVolumeSource(readOnly bool, fsType string, e2evolume storageframework.TestVolume) *v1.VolumeSource { … } func (e *emptydirDriver) CreateVolume(ctx context.Context, config *storageframework.PerTestConfig, volType storageframework.TestVolType) storageframework.TestVolume { … } func (e *emptydirDriver) PrepareTest(ctx context.Context, f *framework.Framework) *storageframework.PerTestConfig { … } type cinderDriver … var _ … var _ … // InitCinderDriver returns cinderDriver that implements TestDriver interface func InitCinderDriver() storageframework.TestDriver { … } func (c *cinderDriver) GetDriverInfo() *storageframework.DriverInfo { … } func (c *cinderDriver) SkipUnsupportedTest(pattern storageframework.TestPattern) { … } func (c *cinderDriver) GetDynamicProvisionStorageClass(ctx context.Context, config *storageframework.PerTestConfig, fsType string) *storagev1.StorageClass { … } func (c *cinderDriver) PrepareTest(ctx context.Context, f *framework.Framework) *storageframework.PerTestConfig { … } type gcePdDriver … type gcePdVolume … var _ … var _ … var _ … var _ … var _ … // InitGcePdDriver returns gcePdDriver that implements TestDriver interface func InitGcePdDriver() storageframework.TestDriver { … } // InitWindowsGcePdDriver returns gcePdDriver running on Windows cluster that implements TestDriver interface // In current test structure, it first initialize the driver and then set up // the new framework, so we cannot get the correct OS here and select which file system is supported. // So here uses a separate Windows in-tree gce pd driver func InitWindowsGcePdDriver() storageframework.TestDriver { … } func (g *gcePdDriver) GetDriverInfo() *storageframework.DriverInfo { … } func (g *gcePdDriver) SkipUnsupportedTest(pattern storageframework.TestPattern) { … } func (g *gcePdDriver) GetVolumeSource(readOnly bool, fsType string, e2evolume storageframework.TestVolume) *v1.VolumeSource { … } func (g *gcePdDriver) GetPersistentVolumeSource(readOnly bool, fsType string, e2evolume storageframework.TestVolume) (*v1.PersistentVolumeSource, *v1.VolumeNodeAffinity) { … } func (g *gcePdDriver) GetDynamicProvisionStorageClass(ctx context.Context, config *storageframework.PerTestConfig, fsType string) *storagev1.StorageClass { … } func (g *gcePdDriver) PrepareTest(ctx context.Context, f *framework.Framework) *storageframework.PerTestConfig { … } func (g *gcePdDriver) CreateVolume(ctx context.Context, config *storageframework.PerTestConfig, volType storageframework.TestVolType) storageframework.TestVolume { … } func (v *gcePdVolume) DeleteVolume(ctx context.Context) { … } type vSphereDriver … var _ … var _ … // InitVSphereDriver returns vSphereDriver that implements TestDriver interface func InitVSphereDriver() storageframework.TestDriver { … } func (v *vSphereDriver) GetDriverInfo() *storageframework.DriverInfo { … } func (v *vSphereDriver) SkipUnsupportedTest(pattern storageframework.TestPattern) { … } func (v *vSphereDriver) GetDynamicProvisionStorageClass(ctx context.Context, config *storageframework.PerTestConfig, fsType string) *storagev1.StorageClass { … } func (v *vSphereDriver) PrepareTest(ctx context.Context, f *framework.Framework) *storageframework.PerTestConfig { … } type azureDiskDriver … var _ … var _ … var _ … // InitAzureDiskDriver returns azureDiskDriver that implements TestDriver interface func InitAzureDiskDriver() storageframework.TestDriver { … } func (a *azureDiskDriver) GetDriverInfo() *storageframework.DriverInfo { … } func (a *azureDiskDriver) SkipUnsupportedTest(pattern storageframework.TestPattern) { … } func (a *azureDiskDriver) GetDynamicProvisionStorageClass(ctx context.Context, config *storageframework.PerTestConfig, fsType string) *storagev1.StorageClass { … } func (a *azureDiskDriver) PrepareTest(ctx context.Context, f *framework.Framework) *storageframework.PerTestConfig { … } func (a *azureDiskDriver) GetTimeouts() *framework.TimeoutContext { … } type awsDriver … var _ … var _ … // InitAwsDriver returns awsDriver that implements TestDriver interface func InitAwsDriver() storageframework.TestDriver { … } func (a *awsDriver) GetDriverInfo() *storageframework.DriverInfo { … } func (a *awsDriver) SkipUnsupportedTest(pattern storageframework.TestPattern) { … } func (a *awsDriver) GetDynamicProvisionStorageClass(ctx context.Context, config *storageframework.PerTestConfig, fsType string) *storagev1.StorageClass { … } func (a *awsDriver) PrepareTest(ctx context.Context, f *framework.Framework) *storageframework.PerTestConfig { … } type localDriver … type localVolume … var defaultLocalVolumeCapabilities … var localVolumeCapabitilies … var defaultLocalVolumeSupportedFsTypes … var localVolumeSupportedFsTypes … var defaultLocalVolumeMaxFileSize … var localVolumeMaxFileSizes … var _ … var _ … var _ … // InitLocalDriverWithVolumeType initializes the local driver based on the volume type. func InitLocalDriverWithVolumeType(volumeType utils.LocalVolumeType) func() storageframework.TestDriver { … } func (l *localDriver) GetDriverInfo() *storageframework.DriverInfo { … } func (l *localDriver) SkipUnsupportedTest(pattern storageframework.TestPattern) { … } func (l *localDriver) PrepareTest(ctx context.Context, f *framework.Framework) *storageframework.PerTestConfig { … } func (l *localDriver) CreateVolume(ctx context.Context, config *storageframework.PerTestConfig, volType storageframework.TestVolType) storageframework.TestVolume { … } func (v *localVolume) DeleteVolume(ctx context.Context) { … } func (l *localDriver) nodeAffinityForNode(node *v1.Node) *v1.VolumeNodeAffinity { … } func (l *localDriver) GetPersistentVolumeSource(readOnly bool, fsType string, e2evolume storageframework.TestVolume) (*v1.PersistentVolumeSource, *v1.VolumeNodeAffinity) { … } // cleanUpVolumeServer is a wrapper of cleanup function for volume server without secret created by specific CreateStorageServer function. func cleanUpVolumeServer(ctx context.Context, f *framework.Framework, serverPod *v1.Pod) { … } func getInlineVolumeZone(ctx context.Context, f *framework.Framework) string { … } // cleanUpVolumeServerWithSecret is a wrapper of cleanup function for volume server with secret created by specific CreateStorageServer function. func cleanUpVolumeServerWithSecret(ctx context.Context, f *framework.Framework, serverPod *v1.Pod, secret *v1.Secret) { … } type azureFileDriver … var _ … var _ … // InitAzureFileDriver returns azureFileDriver that implements TestDriver interface func InitAzureFileDriver() storageframework.TestDriver { … } func (a *azureFileDriver) GetDriverInfo() *storageframework.DriverInfo { … } func (a *azureFileDriver) SkipUnsupportedTest(pattern storageframework.TestPattern) { … } func (a *azureFileDriver) GetDynamicProvisionStorageClass(ctx context.Context, config *storageframework.PerTestConfig, fsType string) *storagev1.StorageClass { … } func (a *azureFileDriver) PrepareTest(ctx context.Context, f *framework.Framework) *storageframework.PerTestConfig { … }
Codebase Browser
kubernetes