storage

Documentation

Index

• Constants
• func AddVolumeAndVerify(virtClient kubecli.KubevirtClient, storageClass string, vm *v1.VirtualMachine, ...) string
• func CreateErrorDisk(nodeName string) (address string, device string)
• func CreateHostDisk(diskPath string) *k8sv1.Pod
• func CreatePVandPVCwithFaultyDisk(nodeName, devicePath, namespace string) (*corev1.PersistentVolume, *corev1.PersistentVolumeClaim, error)
• func CreatePVandPVCwithSCSIDisk(nodeName, devicePath, namespace, storageClass, pvName, pvcName string) (*corev1.PersistentVolume, *corev1.PersistentVolumeClaim, error)
• func CreatePVwithSCSIDisk(storageClass, pvName, nodeName, devicePath string) (*corev1.PersistentVolume, error)
• func CreateSCSIDisk(nodeName string, opts []string) (address string, device string)
• func FSIGDescribe(text string, args ...interface{}) bool
• func FixErrorDevice(nodeName string)
• func MatchConditionIgnoreTimeStamp(expected interface{}) gomegatypes.GomegaMatcher
• func PSIGDescribe(text string, args ...interface{}) bool
• func RandHostDiskDir() string
• func RemoveHostDisk(diskPath string, nodeName string) error
• func RemoveSCSIDisk(nodeName, address string)
• func SIGDescribe(text string, args ...interface{}) bool
• type ConditionNoTimeMatcher
  • func (matcher *ConditionNoTimeMatcher) FailureMessage(actual interface{}) (message string)
  • func (matcher *ConditionNoTimeMatcher) Match(actual interface{}) (success bool, err error)
  • func (matcher *ConditionNoTimeMatcher) NegatedFailureMessage(actual interface{}) (message string)
• type VMICreationFunc

Constants

const InvalidDataVolumeUrl = "docker://127.0.0.1/invalid:latest"

Functions

func AddVolumeAndVerify

func AddVolumeAndVerify(virtClient kubecli.KubevirtClient, storageClass string, vm *v1.VirtualMachine, addVMIOnly bool) string

func CreateErrorDisk

func CreateErrorDisk(nodeName string) (address string, device string)

The tests using the function CreateErrorDisk need to be run serially as it relies on the kernel scsi_debug module

func CreateHostDisk

func CreateHostDisk(diskPath string) *k8sv1.Pod

func CreatePVandPVCwithFaultyDisk

func CreatePVandPVCwithFaultyDisk(nodeName, devicePath, namespace string) (*corev1.PersistentVolume, *corev1.PersistentVolumeClaim, error)

func CreatePVandPVCwithSCSIDisk

func CreatePVandPVCwithSCSIDisk(nodeName, devicePath, namespace, storageClass, pvName, pvcName string) (*corev1.PersistentVolume, *corev1.PersistentVolumeClaim, error)

func CreatePVwithSCSIDisk

func CreatePVwithSCSIDisk(storageClass, pvName, nodeName, devicePath string) (*corev1.PersistentVolume, error)

func CreateSCSIDisk

func CreateSCSIDisk(nodeName string, opts []string) (address string, device string)

CreateSCSIDisk creates a SCSI disk using the scsi_debug module. This function should be used only to check SCSI disk functionalities and not for creating a filesystem or any data. The disk is stored in ram and it isn't suitable for storing large amount of data. If a test uses this function, it needs to be run serially. The device is created directly on the node and the addition and removal of the scsi_debug kernel module could create flakiness

func FSIGDescribe

func FSIGDescribe(text string, args ...interface{}) bool

func FixErrorDevice

func FixErrorDevice(nodeName string)

func MatchConditionIgnoreTimeStamp

func MatchConditionIgnoreTimeStamp(expected interface{}) gomegatypes.GomegaMatcher

func PSIGDescribe

func PSIGDescribe(text string, args ...interface{}) bool

func RandHostDiskDir

func RandHostDiskDir() string

func RemoveHostDisk

func RemoveHostDisk(diskPath string, nodeName string) error

func RemoveSCSIDisk

func RemoveSCSIDisk(nodeName, address string)

func SIGDescribe

func SIGDescribe(text string, args ...interface{}) bool

Types

type ConditionNoTimeMatcher

type ConditionNoTimeMatcher struct {
	Cond interface{}
}

func (*ConditionNoTimeMatcher) FailureMessage

func (matcher *ConditionNoTimeMatcher) FailureMessage(actual interface{}) (message string)

func (*ConditionNoTimeMatcher) Match

func (matcher *ConditionNoTimeMatcher) Match(actual interface{}) (success bool, err error)

func (*ConditionNoTimeMatcher) NegatedFailureMessage

func (matcher *ConditionNoTimeMatcher) NegatedFailureMessage(actual interface{}) (message string)

type VMICreationFunc

type VMICreationFunc func(string) *v1.VirtualMachineInstance