driver

Documentation

Index

• type BeegfsDriver
  • func InitBeegfsDriver(dynamicVolDirBasePathBeegfsRoot, staticVolDirBasePathBeegfsRoot, ... string) *BeegfsDriver
  • func (d *BeegfsDriver) CreateVolume(config *storageframework.PerTestConfig, ...) storageframework.TestVolume
  • func (d BeegfsDriver) GetDriverInfo() *storageframework.DriverInfo
  • func (d BeegfsDriver) GetDynamicProvisionStorageClass(config *storageframework.PerTestConfig, fsType string) *storagev1.StorageClass
  • func (d BeegfsDriver) GetNumFS() int
  • func (d *BeegfsDriver) GetPersistentVolumeSource(readOnly bool, fsType string, testVolume storageframework.TestVolume) (*corev1.PersistentVolumeSource, *corev1.VolumeNodeAffinity)
  • func (d BeegfsDriver) PrepareTest(f *e2eframework.Framework) (*storageframework.PerTestConfig, func())
  • func (d BeegfsDriver) SetFSIndex(fsIndex int)
  • func (d BeegfsDriver) SetFSIndexForRDMA() bool
  • func (d BeegfsDriver) SetPerFSConfigs(perFSConfigs []beegfsv1.FileSystemSpecificConfig)
  • func (d BeegfsDriver) SetStorageClassParams(extraSCParams map[string]string)
  • func (d BeegfsDriver) SkipUnsupportedTest(pattern storageframework.TestPattern)
  • func (d BeegfsDriver) UnsetStorageClassParams()
• type BeegfsDynamicDriver
  • func InitBeegfsDynamicDriver(dynamicVolDirBasePathBeegfsRoot string) *BeegfsDynamicDriver
  • func (d BeegfsDynamicDriver) GetDriverInfo() *storageframework.DriverInfo
  • func (d BeegfsDynamicDriver) GetDynamicProvisionStorageClass(config *storageframework.PerTestConfig, fsType string) *storagev1.StorageClass
  • func (d BeegfsDynamicDriver) GetNumFS() int
  • func (d BeegfsDynamicDriver) PrepareTest(f *e2eframework.Framework) (*storageframework.PerTestConfig, func())
  • func (d BeegfsDynamicDriver) SetFSIndex(fsIndex int)
  • func (d BeegfsDynamicDriver) SetFSIndexForRDMA() bool
  • func (d BeegfsDynamicDriver) SetPerFSConfigs(perFSConfigs []beegfsv1.FileSystemSpecificConfig)
  • func (d BeegfsDynamicDriver) SetStorageClassParams(extraSCParams map[string]string)
  • func (d BeegfsDynamicDriver) SkipUnsupportedTest(pattern storageframework.TestPattern)
  • func (d BeegfsDynamicDriver) UnsetStorageClassParams()

Types

type BeegfsDriver

type BeegfsDriver struct {
	// contains filtered or unexported fields
}

BeegfsDriver is an exported driver that implements the storageframework.TestDriver, storageframework.DynamicPVTestDriver, storageframework.PreprovisionedVolumeTestDriver, and storageframework.PreprovisionedPVTestDriver interfaces. It is intended to be used in all beegfs-csi-driver specific tests.

func InitBeegfsDriver

func InitBeegfsDriver(dynamicVolDirBasePathBeegfsRoot, staticVolDirBasePathBeegfsRoot,
	staticVolDirName string) *BeegfsDriver

InitBeegfsDriver returns a pointer to a BeegfsDriver.

func (*BeegfsDriver) CreateVolume

func (d *BeegfsDriver) CreateVolume(config *storageframework.PerTestConfig, volumeType storageframework.TestVolType) storageframework.TestVolume

BeegfsDriver implements the storageframework.PreprovisionedVolumeTestDriver interface. CreateVolume returns a storageframework.TestVolume that appropriately references a pre-created directory on a BeeGFS file system known to the driver. Tests can use SetFSIndex and SetStaticDirName to modify its behavior.

func (BeegfsDriver) GetDriverInfo

func (d BeegfsDriver) GetDriverInfo() *storageframework.DriverInfo

baseBeegfsDriver implements the storageframework.TestDriver interface.

func (BeegfsDriver) GetDynamicProvisionStorageClass

func (d BeegfsDriver) GetDynamicProvisionStorageClass(config *storageframework.PerTestConfig,
	fsType string) *storagev1.StorageClass

baseBeegfsDriver directly implements the storageframework.DynamicPVTestDriver interface.

func (BeegfsDriver) GetNumFS

func (d BeegfsDriver) GetNumFS() int

GetNumFS returns the maximum fsIndex that should be used with setFSIndex. It may also be useful in skipping certain beegfs-csi-driver specific tests (e.g. a test that requires two different file systems should be skipped if GetNumFS returns 1.

func (*BeegfsDriver) GetPersistentVolumeSource

func (d *BeegfsDriver) GetPersistentVolumeSource(readOnly bool, fsType string,
	testVolume storageframework.TestVolume) (*corev1.PersistentVolumeSource, *corev1.VolumeNodeAffinity)

BeegfsDriver implements the storageframework.PreprovisionedPVTestDriver interface. GetPersistentVolumeSource returns a PersistentVolumeSource that appropriately references a pre-created directory on a BeeGFS file system known to the driver.

func (BeegfsDriver) PrepareTest

func (d BeegfsDriver) PrepareTest(f *e2eframework.Framework) (*storageframework.PerTestConfig, func())

baseBeegfsDriver implements the storageframework.TestDriver interface.

func (BeegfsDriver) SetFSIndex

func (d BeegfsDriver) SetFSIndex(fsIndex int)

SetFSIndex determines which PerFSConfig will be used for various volume provisioning related tasks. It intentionally has no internal error correction. Use GetNumFS to determine the maximum fsIndex to set. If you set fsIndex above the maximum, tests will fail.

func (BeegfsDriver) SetFSIndexForRDMA

func (d BeegfsDriver) SetFSIndexForRDMA() bool

SetFSIndexForRDMA looks for an RDMA capable file system and sets fsIndex to refer to the first one it finds. It returns false if there are no RDMA capable file systems.

func (BeegfsDriver) SetPerFSConfigs

func (d BeegfsDriver) SetPerFSConfigs(perFSConfigs []beegfsv1.FileSystemSpecificConfig)

SetPerFSConfigs sets perFSConfigs from a slice of beegfs.FileSystemSpecificConfigs.

func (BeegfsDriver) SetStorageClassParams

func (d BeegfsDriver) SetStorageClassParams(extraSCParams map[string]string)

SetStorageClassParams injects additional parameters into the driver. These parameters will appear in all generated StorageClasses until UnsetStorageClassParams() is called.

func (BeegfsDriver) SkipUnsupportedTest

func (d BeegfsDriver) SkipUnsupportedTest(pattern storageframework.TestPattern)

baseBeegfsDriver implements the storageframework.TestDriver interface.

func (BeegfsDriver) UnsetStorageClassParams

func (d BeegfsDriver) UnsetStorageClassParams()

UnsetStorageClassParams() reverses SetStorageClassParams.

type BeegfsDynamicDriver

type BeegfsDynamicDriver struct {
	// contains filtered or unexported fields
}

BeegfsDynamicDriver is an exported driver that implements the storageframework.TestDriver and storageframework.DynamicPVTestDriver interfaces. It intentionally does not implement the storageframework.PreprovisionedVolumeTestDriver and storageframework.PreprovisionedPVTestDriver interfaces. It is intended to be used for K8s built-in tests, which may use the pre-provisioned interface in unanticipated ways if allowed.

func InitBeegfsDynamicDriver

func InitBeegfsDynamicDriver(dynamicVolDirBasePathBeegfsRoot string) *BeegfsDynamicDriver

InitBeegfsDynamicDriver returns a pointer to a BeegfsDynamicDriver.

func (BeegfsDynamicDriver) GetDriverInfo

func (d BeegfsDynamicDriver) GetDriverInfo() *storageframework.DriverInfo

baseBeegfsDriver implements the storageframework.TestDriver interface.

func (BeegfsDynamicDriver) GetDynamicProvisionStorageClass

func (d BeegfsDynamicDriver) GetDynamicProvisionStorageClass(config *storageframework.PerTestConfig,
	fsType string) *storagev1.StorageClass

baseBeegfsDriver directly implements the storageframework.DynamicPVTestDriver interface.

func (BeegfsDynamicDriver) GetNumFS

func (d BeegfsDynamicDriver) GetNumFS() int

GetNumFS returns the maximum fsIndex that should be used with setFSIndex. It may also be useful in skipping certain beegfs-csi-driver specific tests (e.g. a test that requires two different file systems should be skipped if GetNumFS returns 1.

func (BeegfsDynamicDriver) PrepareTest

func (d BeegfsDynamicDriver) PrepareTest(f *e2eframework.Framework) (*storageframework.PerTestConfig, func())

baseBeegfsDriver implements the storageframework.TestDriver interface.

func (BeegfsDynamicDriver) SetFSIndex

func (d BeegfsDynamicDriver) SetFSIndex(fsIndex int)

SetFSIndex determines which PerFSConfig will be used for various volume provisioning related tasks. It intentionally has no internal error correction. Use GetNumFS to determine the maximum fsIndex to set. If you set fsIndex above the maximum, tests will fail.

func (BeegfsDynamicDriver) SetFSIndexForRDMA

func (d BeegfsDynamicDriver) SetFSIndexForRDMA() bool

SetFSIndexForRDMA looks for an RDMA capable file system and sets fsIndex to refer to the first one it finds. It returns false if there are no RDMA capable file systems.

func (BeegfsDynamicDriver) SetPerFSConfigs

func (d BeegfsDynamicDriver) SetPerFSConfigs(perFSConfigs []beegfsv1.FileSystemSpecificConfig)

SetPerFSConfigs sets perFSConfigs from a slice of beegfs.FileSystemSpecificConfigs.

func (BeegfsDynamicDriver) SetStorageClassParams

func (d BeegfsDynamicDriver) SetStorageClassParams(extraSCParams map[string]string)

SetStorageClassParams injects additional parameters into the driver. These parameters will appear in all generated StorageClasses until UnsetStorageClassParams() is called.

func (BeegfsDynamicDriver) SkipUnsupportedTest

func (d BeegfsDynamicDriver) SkipUnsupportedTest(pattern storageframework.TestPattern)

baseBeegfsDriver implements the storageframework.TestDriver interface.

func (BeegfsDynamicDriver) UnsetStorageClassParams

func (d BeegfsDynamicDriver) UnsetStorageClassParams()

UnsetStorageClassParams() reverses SetStorageClassParams.