Documentation ¶
Index ¶
- Constants
- Variables
- func AddBootOrderToDisk(vmi *v1.VirtualMachineInstance, diskName string, bootorder *uint) *v1.VirtualMachineInstance
- func AddCloudInitConfigDriveData(vmi *v1.VirtualMachineInstance, name, userData, networkData string, ...)
- func AddCloudInitNoCloudData(vmi *v1.VirtualMachineInstance, name, userData, networkData string, ...)
- func AddConfigMapDisk(vmi *v1.VirtualMachineInstance, configMapName string, volumeName string)
- func AddConfigMapDiskWithCustomLabel(vmi *v1.VirtualMachineInstance, configMapName string, volumeName string, ...)
- func AddEphemeralCdrom(vmi *v1.VirtualMachineInstance, name string, bus string, image string) *v1.VirtualMachineInstance
- func AddEphemeralDisk(vmi *v1.VirtualMachineInstance, name string, bus string, image string) *v1.VirtualMachineInstance
- func AddExplicitPodNetworkInterface(vmi *v1.VirtualMachineInstance)
- func AddHostDisk(vmi *v1.VirtualMachineInstance, path string, diskType v1.HostDiskType, ...)
- func AddLabelToNode(nodeName string, key string, value string)
- func AddPVCDisk(vmi *v1.VirtualMachineInstance, name string, bus string, claimName string) *v1.VirtualMachineInstance
- func AddSecretDisk(vmi *v1.VirtualMachineInstance, secretName string, volumeName string)
- func AddSecretDiskWithCustomLabel(vmi *v1.VirtualMachineInstance, secretName string, volumeName string, ...)
- func AddServiceAccountDisk(vmi *v1.VirtualMachineInstance, serviceAccountName string)
- func AddUserData(vmi *v1.VirtualMachineInstance, name string, userData string)
- func AdjustKubeVirtResource()
- func AfterTestSuitCleanup()
- func AppendEmptyDisk(vmi *v1.VirtualMachineInstance, diskName, busName, diskSize string)
- func ApplyRawManifest(object unstructured.Unstructured) error
- func BeforeAll(fn func())
- func BeforeTestCleanup()
- func BeforeTestSuitSetup()
- func CallUrlOnPod(pod *k8sv1.Pod, port string, url string) ([]byte, error)
- func CheckForTextExpecter(vmi *v1.VirtualMachineInstance, expected []expect.Batcher, wait int) error
- func CleanNodes()
- func ContainerDiskFor(name ContainerDisk) string
- func ContainsCrt(bundle []byte, containedCrt []byte) bool
- func CreateBlockVolumePvAndPvc(size string)
- func CreateCommandWithNS(namespace string, cmdName string, args ...string) (string, *exec.Cmd, error)
- func CreateConfigMap(name string, data map[string]string)
- func CreateHostDiskImage(diskPath string) *k8sv1.Pod
- func CreateHostPathPVC(os, size string)
- func CreateHostPathPv(osName string, hostPath string)
- func CreateHostPathPvWithSize(osName string, hostPath string, size string)
- func CreateISCSIPvAndPvc(name string, size string, iscsiTargetIP string, ...)
- func CreateISCSITargetPOD(containerDiskName ContainerDisk) (iscsiTargetIP string)
- func CreateNFSPvAndPvc(name string, size string, nfsTargetIP string, os string)
- func CreateNFSTargetPOD(os string) (nfsTargetIP string)
- func CreatePVC(os, size, storageClass string)
- func CreateSecret(name string, data map[string]string)
- func DeleteConfigMap(name string)
- func DeletePV(os string)
- func DeletePVC(os string)
- func DeletePvAndPvc(name string)
- func DeleteRawManifest(object unstructured.Unstructured) error
- func DeleteSecret(name string)
- func DeployTestingInfrastructure()
- func DetectLatestUpstreamOfficialTag() (string, error)
- func DisableFeatureGate(feature string)
- func DoScaleDeployment(namespace string, name string, desired int32) (error, int32)
- func DoScaleVirtHandler(namespace string, name string, selector map[string]string) (int32, map[string]string, int64, error)
- func EnableFeatureGate(feature string)
- func EncodePrivateKeyToPEM(privateKey *rsa.PrivateKey) []byte
- func EnsureKVMPresent()
- func EnsurePodsCertIsSynced(labelSelector string, namespace string, port string) []byte
- func ExecuteCommandOnPod(virtCli kubecli.KubevirtClient, pod *k8sv1.Pod, containerName string, ...) (string, error)
- func ExecuteCommandOnPodV2(virtCli kubecli.KubevirtClient, pod *k8sv1.Pod, containerName string, ...) (stdout, stderr string, err error)
- func FlagParse()
- func FormatIPForURL(ip string) string
- func ForwardPorts(pod *k8sv1.Pod, ports []string, stop chan struct{}, readyTimeout time.Duration) error
- func GenerateHelloWorldServer(vmi *v1.VirtualMachineInstance, testPort int, protocol string)
- func GeneratePrivateKey(bitSize int) (*rsa.PrivateKey, error)
- func GeneratePublicKey(privatekey *rsa.PublicKey) ([]byte, error)
- func GenerateRESTReport() error
- func GenerateRandomMac() (net.HardwareAddr, error)
- func GenerateTemplateJson(template *vmsgen.Template, generateDirectory string) (string, error)
- func GenerateVMIJson(vmi *v1.VirtualMachineInstance, generateDirectory string) (string, error)
- func GenerateVMJson(vm *v1.VirtualMachine, generateDirectory string) (string, error)
- func GetAllSchedulableNodes(virtClient kubecli.KubevirtClient) *k8sv1.NodeList
- func GetBundleFromConfigMap(configMapName string) ([]byte, []*x509.Certificate)
- func GetCephStorageClass() (string, bool)
- func GetCertFromSecret(secretName string) []byte
- func GetCertsForPods(labelSelector string, namespace string, port string) ([][]byte, error)
- func GetCloudInitNetworkData(ipAddress string, gateway string, dnsServer string, searchDomains []string) string
- func GetComputeContainerOfPod(pod *k8sv1.Pod) *k8sv1.Container
- func GetContainerDiskContainerOfPod(pod *k8sv1.Pod, volumeName string) *k8sv1.Container
- func GetContainerOfPod(pod *k8sv1.Pod, containerName string) *k8sv1.Container
- func GetCurrentKv(virtClient kubecli.KubevirtClient) *v1.KubeVirt
- func GetGuestAgentUserData() string
- func GetHighestCPUNumberAmongNodes(virtClient kubecli.KubevirtClient) int
- func GetK8sCmdClient() string
- func GetKubeVirtConfigMap() (*k8sv1.ConfigMap, error)
- func GetKvList(virtClient kubecli.KubevirtClient) []v1.KubeVirt
- func GetListOfManifests(pathToManifestsDir string) []string
- func GetNodeCPUInfo(vmi *v1.VirtualMachineInstance) string
- func GetNodeDrainKey() string
- func GetNodeLibvirtCapabilities(vmi *v1.VirtualMachineInstance) string
- func GetNodeWithHugepages(virtClient kubecli.KubevirtClient, hugepages k8sv1.ResourceName) *k8sv1.Node
- func GetPodByVirtualMachineInstance(vmi *v1.VirtualMachineInstance, namespace string) *k8sv1.Pod
- func GetPodsCertIfSynced(labelSelector string, namespace string, port string) (cert []byte, synced bool, err error)
- func GetRunningPodByLabel(label string, labelType string, namespace string, node string) (*k8sv1.Pod, error)
- func GetRunningPodByVirtualMachineInstance(vmi *v1.VirtualMachineInstance, namespace string) *k8sv1.Pod
- func GetRunningVMIDomainSpec(vmi *v1.VirtualMachineInstance) (*launcherApi.DomainSpec, error)
- func GetRunningVirtualMachineInstanceDomainXML(virtClient kubecli.KubevirtClient, vmi *v1.VirtualMachineInstance) (string, error)
- func GetUrl(urlIndex int) string
- func GetVmPodName(virtCli kubecli.KubevirtClient, vmi *v1.VirtualMachineInstance) string
- func HasCDI() bool
- func HasDataVolumeCRD() bool
- func HasExperimentalIgnitionSupport() bool
- func HasFeature(feature string) bool
- func HasLiveMigration() bool
- func IsIPv6Cluster(virtClient kubecli.KubevirtClient) bool
- func IsLauncherCapabilityValid(capability k8sv1.Capability) bool
- func IsOpenShift() bool
- func IsRunningOnKindInfra() bool
- func IsRunningOnKindInfraIPv6() bool
- func IsUsingBuiltinNodeDrainKey() bool
- func LoggedInAlpineExpecter(vmi *v1.VirtualMachineInstance) (expect.Expecter, error)
- func LoggedInCirrosExpecter(vmi *v1.VirtualMachineInstance) (expect.Expecter, error)
- func LoggedInFedoraExpecter(vmi *v1.VirtualMachineInstance) (expect.Expecter, error)
- func NewBool(x bool) *bool
- func NewConsoleExpecter(virtCli kubecli.KubevirtClient, vmi *v1.VirtualMachineInstance, ...) (expect.Expecter, <-chan error, error)
- func NewHelloWorldJob(host string, port string) *k8sv1.Pod
- func NewHelloWorldJobHttp(host string, port string) *k8sv1.Pod
- func NewHelloWorldJobUDP(host string, port string) *k8sv1.Pod
- func NewISCSIPV(name, size, iscsiTargetIP string, accessMode k8sv1.PersistentVolumeAccessMode, ...) *k8sv1.PersistentVolume
- func NewInt32(x int32) *int32
- func NewRandomDataVolumeWithHttpImport(imageUrl, namespace string, accessMode k8sv1.PersistentVolumeAccessMode) *cdiv1.DataVolume
- func NewRandomDataVolumeWithHttpImportInStorageClass(imageUrl, namespace, storageClass string, ...) *cdiv1.DataVolume
- func NewRandomDataVolumeWithPVCSource(sourceNamespace, sourceName, targetNamespace string, ...) *cdiv1.DataVolume
- func NewRandomDataVolumeWithPVCSourceWithStorageClass(sourceNamespace, sourceName, targetNamespace, storageClass, size string, ...) *cdiv1.DataVolume
- func NewRandomFedora32VMIWithFedoraUser() *v1.VirtualMachineInstance
- func NewRandomFedoraVMIWitGuestAgent() *v1.VirtualMachineInstance
- func NewRandomFedoraVMIWithDmidecode() *v1.VirtualMachineInstance
- func NewRandomMigration(vmiName string, namespace string) *v1.VirtualMachineInstanceMigration
- func NewRandomReplicaSetFromVMI(vmi *v1.VirtualMachineInstance, replicas int32) *v1.VirtualMachineInstanceReplicaSet
- func NewRandomVMI() *v1.VirtualMachineInstance
- func NewRandomVMIWithCDRom(claimName string) *v1.VirtualMachineInstance
- func NewRandomVMIWithConfigMap(configMapName string) *v1.VirtualMachineInstance
- func NewRandomVMIWithCustomMacAddress() *v1.VirtualMachineInstance
- func NewRandomVMIWithDataVolume(dataVolumeName string) *v1.VirtualMachineInstance
- func NewRandomVMIWithEFIBootloader() *v1.VirtualMachineInstance
- func NewRandomVMIWithEphemeralDisk(containerImage string) *v1.VirtualMachineInstance
- func NewRandomVMIWithEphemeralDiskAndConfigDriveUserdata(containerImage string, userData string) *v1.VirtualMachineInstance
- func NewRandomVMIWithEphemeralDiskAndConfigDriveUserdataHighMemory(containerImage string, userData string) *v1.VirtualMachineInstance
- func NewRandomVMIWithEphemeralDiskAndConfigDriveUserdataNetworkData(containerImage, userData, networkData string, b64encode bool) *v1.VirtualMachineInstance
- func NewRandomVMIWithEphemeralDiskAndUserdata(containerImage string, userData string) *v1.VirtualMachineInstance
- func NewRandomVMIWithEphemeralDiskAndUserdataHighMemory(containerImage string, userData string) *v1.VirtualMachineInstance
- func NewRandomVMIWithEphemeralDiskAndUserdataNetworkData(containerImage, userData, networkData string, b64encode bool) *v1.VirtualMachineInstance
- func NewRandomVMIWithEphemeralDiskHighMemory(containerImage string) *v1.VirtualMachineInstance
- func NewRandomVMIWithEphemeralPVC(claimName string) *v1.VirtualMachineInstance
- func NewRandomVMIWithHostDisk(diskPath string, diskType v1.HostDiskType, nodeName string) *v1.VirtualMachineInstance
- func NewRandomVMIWithMasqueradeInterfaceEphemeralDiskAndUserdata(containerImage string, userData string, Ports []v1.Port) *v1.VirtualMachineInstance
- func NewRandomVMIWithNS(namespace string) *v1.VirtualMachineInstance
- func NewRandomVMIWithPVC(claimName string) *v1.VirtualMachineInstance
- func NewRandomVMIWithSecret(secretName string) *v1.VirtualMachineInstance
- func NewRandomVMIWithSecureBoot() *v1.VirtualMachineInstance
- func NewRandomVMIWithServiceAccount(serviceAccountName string) *v1.VirtualMachineInstance
- func NewRandomVMIWithSlirpInterfaceEphemeralDiskAndUserdata(containerImage string, userData string, Ports []v1.Port) *v1.VirtualMachineInstance
- func NewRandomVMIWithWatchdog() *v1.VirtualMachineInstance
- func NewRandomVMIWithe1000NetworkInterface() *v1.VirtualMachineInstance
- func NewRandomVMWithCloneDataVolume(sourceNamespace, sourceName, targetNamespace string) *v1.VirtualMachine
- func NewRandomVMWithDataVolume(imageUrl string, namespace string) *v1.VirtualMachine
- func NewRandomVMWithDataVolumeInStorageClass(imageUrl, namespace, storageClass string) *v1.VirtualMachine
- func NewRandomVMWithEphemeralDisk(containerImage string) *v1.VirtualMachine
- func NewRandomVirtualMachine(vmi *v1.VirtualMachineInstance, running bool) *v1.VirtualMachine
- func NewRandomVirtualMachineInstanceWithOCSDisk(imageUrl, namespace string, accessMode k8sv1.PersistentVolumeAccessMode, ...) (*v1.VirtualMachineInstance, *cdiv1.DataVolume)
- func NewRepeatableVirtctlCommand(args ...string) func() error
- func NewVirtctlCommand(args ...string) *cobra.Command
- func NotDeleted(vmis *v1.VirtualMachineInstanceList) (notDeleted []v1.VirtualMachineInstance)
- func PanicOnError(err error)
- func PodReady(pod *k8sv1.Pod) k8sv1.ConditionStatus
- func PrometheusRuleEnabled() bool
- func RandTmpDir() string
- func ReLoggedInFedoraExpecter(vmi *v1.VirtualMachineInstance, timeout int) (expect.Expecter, error)
- func ReadManifestYamlFile(pathToManifest string) []unstructured.Unstructured
- func RemoveHostDiskImage(diskPath string, nodeName string)
- func RemoveLabelFromNode(nodeName string, key string)
- func RenderHostPathJob(jobName string, dir string, hostPathType k8sv1.HostPathType, ...) *k8sv1.Pod
- func RenderJob(name string, cmd []string, args []string) *k8sv1.Pod
- func RestoreKubeVirtResource()
- func RetryIfModified(do func() error) (err error)
- func RetryWithMetadataIfModified(objectMeta metav1.ObjectMeta, do func(objectMeta metav1.ObjectMeta) error) (err error)
- func RunCommand(cmdName string, args ...string) (string, string, error)
- func RunCommandOnVmiPod(vmi *v1.VirtualMachineInstance, command []string) string
- func RunCommandPipe(commands ...[]string) (string, string, error)
- func RunCommandPipeWithNS(namespace string, commands ...[]string) (string, string, error)
- func RunCommandWithNS(namespace string, cmdName string, args ...string) (string, string, error)
- func RunCommandWithNSAndInput(namespace string, input io.Reader, cmdName string, args ...string) (string, string, error)
- func RunVMI(vmi *v1.VirtualMachineInstance, timeout int) *v1.VirtualMachineInstance
- func RunVMIAndExpectLaunch(vmi *v1.VirtualMachineInstance, timeout int) *v1.VirtualMachineInstance
- func RunVMIAndExpectLaunchIgnoreWarnings(vmi *v1.VirtualMachineInstance, timeout int) *v1.VirtualMachineInstance
- func RunVMIAndExpectLaunchWithIgnoreWarningArg(vmi *v1.VirtualMachineInstance, timeout int, ignoreWarnings bool) *v1.VirtualMachineInstance
- func RunVMIAndExpectScheduling(vmi *v1.VirtualMachineInstance, timeout int) *v1.VirtualMachineInstance
- func SecureBootExpecter(vmi *v1.VirtualMachineInstance) (expect.Expecter, error)
- func ServiceMonitorEnabled() bool
- func SkipIfNoCmd(cmdName string)
- func SkipIfNoRhelImage(virtClient kubecli.KubevirtClient)
- func SkipIfNoWindowsImage(virtClient kubecli.KubevirtClient)
- func SkipIfNotUseNetworkPolicy(virtClient kubecli.KubevirtClient)
- func SkipIfOpenShift(message string)
- func SkipIfOpenShift4(message string)
- func SkipIfOpenShiftAndBelowOrEqualVersion(message string, version string)
- func SkipIfUseFlannel(virtClient kubecli.KubevirtClient)
- func SkipIfVersionAboveOrEqual(message string, expectedVersion string)
- func SkipIfVersionBelow(message string, expectedVersion string)
- func SkipNFSTestIfRunnigOnKindInfra()
- func SkipPVCTestIfRunnigOnKindInfra()
- func StartHTTPServer(vmi *v1.VirtualMachineInstance, port int, isFedoraVM bool)
- func StartTCPServer(vmi *v1.VirtualMachineInstance, port int)
- func StartVirtualMachine(vm *v1.VirtualMachine) *v1.VirtualMachine
- func StartVmOnNode(vmi *v1.VirtualMachineInstance, nodeName string)
- func StopVirtualMachine(vm *v1.VirtualMachine) *v1.VirtualMachine
- func Taint(nodeName string, key string, effect k8sv1.TaintEffect)
- func UnfinishedVMIPodSelector(vmi *v1.VirtualMachineInstance) metav1.ListOptions
- func UpdateClusterConfigValueAndWait(key string, value string) string
- func WaitAgentConnected(virtClient kubecli.KubevirtClient, vmi *v1.VirtualMachineInstance)
- func WaitForAllPodsReady(timeout time.Duration, listOptions metav1.ListOptions)
- func WaitForMigrationToDisappearWithTimeout(migration *v1.VirtualMachineInstanceMigration, seconds int)
- func WaitForPodToDisappearWithTimeout(podName string, seconds int)
- func WaitForSuccessfulDataVolumeImport(dv *cdiv1.DataVolume, seconds int)
- func WaitForSuccessfulDataVolumeImportOfVMI(obj runtime.Object, seconds int)
- func WaitForSuccessfulVMIStart(vmi runtime.Object) string
- func WaitForSuccessfulVMIStartIgnoreWarnings(vmi runtime.Object) string
- func WaitForSuccessfulVMIStartWithTimeout(vmi runtime.Object, seconds int) (nodeName string)
- func WaitForSuccessfulVMIStartWithTimeoutIgnoreWarnings(vmi runtime.Object, seconds int) string
- func WaitForVMCondition(virtClient kubecli.KubevirtClient, vm *v1.VirtualMachine, ...)
- func WaitForVMConditionRemovedOrFalse(virtClient kubecli.KubevirtClient, vm *v1.VirtualMachine, ...)
- func WaitForVMICondition(virtClient kubecli.KubevirtClient, vmi *v1.VirtualMachineInstance, ...)
- func WaitForVMIConditionRemovedOrFalse(virtClient kubecli.KubevirtClient, vmi *v1.VirtualMachineInstance, ...)
- func WaitForVirtualMachineToDisappearWithTimeout(vmi *v1.VirtualMachineInstance, seconds int)
- func WaitUntilVMIReady(vmi *v1.VirtualMachineInstance, expecterFactory VMIExpecterFactory) *v1.VirtualMachineInstance
- func WaitUntilVMIReadyWithNamespace(namespace string, vmi *v1.VirtualMachineInstance, ...) *v1.VirtualMachineInstance
- func WipeTestingInfrastructure()
- type ContainerDisk
- type EventType
- type KubeVirtTestsConfiguration
- type ObjectEventWatcher
- func (w *ObjectEventWatcher) FailOnWarnings() *ObjectEventWatcher
- func (w *ObjectEventWatcher) SinceNow() *ObjectEventWatcher
- func (w *ObjectEventWatcher) SinceObjectResourceVersion(object runtime.Object) *ObjectEventWatcher
- func (w *ObjectEventWatcher) SinceResourceVersion(rv string) *ObjectEventWatcher
- func (w *ObjectEventWatcher) SinceWatchedObjectResourceVersion() *ObjectEventWatcher
- func (w *ObjectEventWatcher) Timeout(duration time.Duration) *ObjectEventWatcher
- func (w *ObjectEventWatcher) WaitFor(stopChan chan struct{}, eventType EventType, reason interface{}) (e *k8sv1.Event)
- func (w *ObjectEventWatcher) WaitNotFor(stopChan chan struct{}, eventType EventType, reason interface{}) (e *k8sv1.Event)
- func (w *ObjectEventWatcher) Watch(abortChan chan struct{}, processFunc ProcessFunc, watchedDescription string)
- type ProcessFunc
- type VMIExpecterFactory
Constants ¶
const ( AlpineHttpUrl = iota GuestAgentHttpUrl StressHttpUrl DmidecodeHttpUrl DummyFileHttpUrl )
const ( SubresourceServiceAccountName = "kubevirt-subresource-test-sa" AdminServiceAccountName = "kubevirt-admin-test-sa" EditServiceAccountName = "kubevirt-edit-test-sa" ViewServiceAccountName = "kubevirt-view-test-sa" )
const ( // tests.NamespaceTestDefault is the default namespace, to test non-infrastructure related KubeVirt objects. NamespaceTestDefault = "kubevirt-test-default" // NamespaceTestAlternative is used to test controller-namespace independency. NamespaceTestAlternative = "kubevirt-test-alternative" // NamespaceTestOperator is used to test if namespaces can still be deleted when kubevirt is uninstalled NamespaceTestOperator = "kubevirt-test-operator" )
const ( NFSTargetName = "test-nfs-target" ISCSITargetName = "test-isci-target" )
const ( HostPathBase = "/tmp/hostImages/" HostPathAlpine = HostPathBase + "alpine" HostPathCustom = HostPathBase + "custom" )
const ( DiskAlpineHostPath = "disk-alpine-host-path" DiskWindows = "disk-windows" DiskRhel = "disk-rhel" DiskCustomHostPath = "disk-custom-host-path" )
const (
// BlockDiskForTest contains name of the block PV and PVC
BlockDiskForTest = "block-disk-for-tests"
)
const (
CustomHostPath = "custom-host-path"
)
const (
SecretLabel = "kubevirt.io/secret"
)
const SubresourceTestLabel = "subresource-access-test-pod"
const TempDirPrefix = "kubevirt-test"
const VMIResource = "virtualmachineinstances"
Variables ¶
var ConfigFile = ""
var ContainerizedDataImporterNamespace = "cdi"
var DeployTestingInfrastructureFlag = false
var ImagePrefixAlt = ""
var KubeVirtDefaultConfig map[string]string
var KubeVirtGoCliPath = ""
var KubeVirtInstallNamespace string
var KubeVirtKubectlPath = ""
var KubeVirtOcPath = ""
var KubeVirtRepoPrefix = "kubevirt"
var KubeVirtUtilityRepoPrefix = ""
var KubeVirtUtilityVersionTag = ""
var KubeVirtVersionTag = "latest"
var KubeVirtVersionTagAlt = ""
var KubeVirtVirtctlPath = ""
var PathToTestingInfrastrucureManifests = ""
var PreviousReleaseRegistry = ""
var PreviousReleaseTag = ""
var SkipShasumCheck bool
Functions ¶
func AddBootOrderToDisk ¶ added in v0.6.0
func AddBootOrderToDisk(vmi *v1.VirtualMachineInstance, diskName string, bootorder *uint) *v1.VirtualMachineInstance
func AddCloudInitConfigDriveData ¶ added in v0.19.0
func AddCloudInitConfigDriveData(vmi *v1.VirtualMachineInstance, name, userData, networkData string, b64encode bool)
func AddCloudInitNoCloudData ¶ added in v0.19.0
func AddCloudInitNoCloudData(vmi *v1.VirtualMachineInstance, name, userData, networkData string, b64encode bool)
func AddConfigMapDisk ¶ added in v0.9.0
func AddConfigMapDisk(vmi *v1.VirtualMachineInstance, configMapName string, volumeName string)
func AddConfigMapDiskWithCustomLabel ¶ added in v0.29.0
func AddConfigMapDiskWithCustomLabel(vmi *v1.VirtualMachineInstance, configMapName string, volumeName string, volumeLabel string)
func AddEphemeralCdrom ¶ added in v0.12.0
func AddEphemeralCdrom(vmi *v1.VirtualMachineInstance, name string, bus string, image string) *v1.VirtualMachineInstance
func AddEphemeralDisk ¶ added in v0.3.0
func AddEphemeralDisk(vmi *v1.VirtualMachineInstance, name string, bus string, image string) *v1.VirtualMachineInstance
func AddExplicitPodNetworkInterface ¶ added in v0.7.0
func AddExplicitPodNetworkInterface(vmi *v1.VirtualMachineInstance)
func AddHostDisk ¶ added in v0.9.4
func AddHostDisk(vmi *v1.VirtualMachineInstance, path string, diskType v1.HostDiskType, name string)
func AddLabelToNode ¶ added in v0.16.0
func AddPVCDisk ¶ added in v0.5.0
func AddPVCDisk(vmi *v1.VirtualMachineInstance, name string, bus string, claimName string) *v1.VirtualMachineInstance
func AddSecretDisk ¶ added in v0.9.0
func AddSecretDisk(vmi *v1.VirtualMachineInstance, secretName string, volumeName string)
func AddSecretDiskWithCustomLabel ¶ added in v0.29.0
func AddSecretDiskWithCustomLabel(vmi *v1.VirtualMachineInstance, secretName string, volumeName string, volumeLabel string)
func AddServiceAccountDisk ¶ added in v0.9.2
func AddServiceAccountDisk(vmi *v1.VirtualMachineInstance, serviceAccountName string)
func AddUserData ¶ added in v0.9.0
func AddUserData(vmi *v1.VirtualMachineInstance, name string, userData string)
func AdjustKubeVirtResource ¶ added in v0.29.0
func AdjustKubeVirtResource()
func AfterTestSuitCleanup ¶
func AfterTestSuitCleanup()
func AppendEmptyDisk ¶ added in v0.16.0
func AppendEmptyDisk(vmi *v1.VirtualMachineInstance, diskName, busName, diskSize string)
func ApplyRawManifest ¶ added in v0.12.0
func ApplyRawManifest(object unstructured.Unstructured) error
func BeforeTestCleanup ¶
func BeforeTestCleanup()
func BeforeTestSuitSetup ¶
func BeforeTestSuitSetup()
func CallUrlOnPod ¶ added in v0.30.5
func CheckForTextExpecter ¶ added in v0.6.0
func CleanNodes ¶ added in v0.16.0
func CleanNodes()
func ContainerDiskFor ¶ added in v0.11.0
func ContainerDiskFor(name ContainerDisk) string
ContainerDiskFor takes the name of an image and returns the full registry diks image path. Supported values are: cirros, fedora, alpine, guest-agent
func ContainsCrt ¶ added in v0.29.0
func CreateBlockVolumePvAndPvc ¶ added in v0.9.2
func CreateBlockVolumePvAndPvc(size string)
func CreateCommandWithNS ¶ added in v0.9.5
func CreateConfigMap ¶ added in v0.9.0
func CreateHostDiskImage ¶ added in v0.9.0
func CreateHostPathPVC ¶ added in v0.11.0
func CreateHostPathPVC(os, size string)
func CreateHostPathPv ¶ added in v0.6.1
func CreateHostPathPvWithSize ¶ added in v0.9.6
func CreateISCSIPvAndPvc ¶ added in v0.12.0
func CreateISCSIPvAndPvc(name string, size string, iscsiTargetIP string, accessMode k8sv1.PersistentVolumeAccessMode, volumeMode k8sv1.PersistentVolumeMode)
func CreateISCSITargetPOD ¶ added in v0.12.0
func CreateISCSITargetPOD(containerDiskName ContainerDisk) (iscsiTargetIP string)
func CreateNFSPvAndPvc ¶ added in v0.19.0
func CreateNFSTargetPOD ¶ added in v0.19.0
func CreateSecret ¶ added in v0.9.0
func DeleteConfigMap ¶ added in v0.9.0
func DeleteConfigMap(name string)
func DeletePvAndPvc ¶ added in v0.9.2
func DeletePvAndPvc(name string)
func DeleteRawManifest ¶ added in v0.12.0
func DeleteRawManifest(object unstructured.Unstructured) error
func DeleteSecret ¶ added in v0.9.0
func DeleteSecret(name string)
func DeployTestingInfrastructure ¶ added in v0.12.0
func DeployTestingInfrastructure()
func DetectLatestUpstreamOfficialTag ¶ added in v0.31.0
func DisableFeatureGate ¶ added in v0.20.0
func DisableFeatureGate(feature string)
func DoScaleDeployment ¶ added in v0.12.0
Do scale and retuns error, replicas-before.
func DoScaleVirtHandler ¶ added in v0.12.0
func EnableFeatureGate ¶ added in v0.20.0
func EnableFeatureGate(feature string)
func EncodePrivateKeyToPEM ¶ added in v0.19.0
func EncodePrivateKeyToPEM(privateKey *rsa.PrivateKey) []byte
EncodePrivateKeyToPEM encodes Private Key from RSA to PEM format
func EnsureKVMPresent ¶ added in v0.7.0
func EnsureKVMPresent()
func EnsurePodsCertIsSynced ¶ added in v0.29.0
EnsurePodsCertIsSynced waits until new certificates are rolled out to all pods which are matching the specified labelselector. Once all certificates are in sync, the final secret is returned
func ExecuteCommandOnPod ¶ added in v0.4.1
func ExecuteCommandOnPodV2 ¶ added in v0.9.0
func FormatIPForURL ¶ added in v0.29.0
func ForwardPorts ¶ added in v0.17.0
func GenerateHelloWorldServer ¶ added in v0.19.0
func GenerateHelloWorldServer(vmi *v1.VirtualMachineInstance, testPort int, protocol string)
func GeneratePrivateKey ¶ added in v0.19.0
func GeneratePrivateKey(bitSize int) (*rsa.PrivateKey, error)
GeneratePrivateKey creates a RSA Private Key of specified byte size
func GeneratePublicKey ¶ added in v0.19.0
GeneratePublicKey will return in the format "ssh-rsa ..."
func GenerateRESTReport ¶ added in v0.23.0
func GenerateRESTReport() error
func GenerateRandomMac ¶ added in v0.26.0
func GenerateRandomMac() (net.HardwareAddr, error)
func GenerateTemplateJson ¶ added in v0.7.0
func GenerateVMIJson ¶ added in v0.6.1
func GenerateVMIJson(vmi *v1.VirtualMachineInstance, generateDirectory string) (string, error)
func GenerateVMJson ¶ added in v0.17.0
func GenerateVMJson(vm *v1.VirtualMachine, generateDirectory string) (string, error)
func GetAllSchedulableNodes ¶ added in v0.9.0
func GetAllSchedulableNodes(virtClient kubecli.KubevirtClient) *k8sv1.NodeList
func GetBundleFromConfigMap ¶ added in v0.29.0
func GetBundleFromConfigMap(configMapName string) ([]byte, []*x509.Certificate)
func GetCephStorageClass ¶ added in v0.20.5
func GetCertFromSecret ¶ added in v0.29.0
func GetCertsForPods ¶ added in v0.29.0
GetCertsForPods returns the used certificates for all pods matching the label selector
func GetCloudInitNetworkData ¶ added in v0.31.0
func GetCloudInitNetworkData(ipAddress string, gateway string, dnsServer string, searchDomains []string) string
Returns NetworkData for configuring a dynamic IPv4 address, and a static IPv6 address, along with DNS configuration.
func GetComputeContainerOfPod ¶ added in v0.19.0
func GetContainerDiskContainerOfPod ¶ added in v0.19.0
func GetContainerOfPod ¶ added in v0.19.0
func GetCurrentKv ¶ added in v0.29.0
func GetCurrentKv(virtClient kubecli.KubevirtClient) *v1.KubeVirt
func GetGuestAgentUserData ¶ added in v0.19.0
func GetGuestAgentUserData() string
func GetHighestCPUNumberAmongNodes ¶ added in v0.20.7
func GetHighestCPUNumberAmongNodes(virtClient kubecli.KubevirtClient) int
func GetK8sCmdClient ¶ added in v0.17.0
func GetK8sCmdClient() string
func GetKubeVirtConfigMap ¶ added in v0.26.5
func GetListOfManifests ¶ added in v0.12.0
func GetNodeCPUInfo ¶ added in v0.6.3
func GetNodeCPUInfo(vmi *v1.VirtualMachineInstance) string
GetNodeCPUInfo returns output of lscpu on the pod that runs on the specified node
func GetNodeDrainKey ¶ added in v0.26.5
func GetNodeDrainKey() string
func GetNodeLibvirtCapabilities ¶ added in v0.6.2
func GetNodeLibvirtCapabilities(vmi *v1.VirtualMachineInstance) string
GetNodeLibvirtCapabilities returns node libvirt capabilities
func GetNodeWithHugepages ¶ added in v0.6.1
func GetNodeWithHugepages(virtClient kubecli.KubevirtClient, hugepages k8sv1.ResourceName) *k8sv1.Node
func GetPodByVirtualMachineInstance ¶ added in v0.17.0
func GetPodByVirtualMachineInstance(vmi *v1.VirtualMachineInstance, namespace string) *k8sv1.Pod
func GetPodsCertIfSynced ¶ added in v0.29.0
func GetPodsCertIfSynced(labelSelector string, namespace string, port string) (cert []byte, synced bool, err error)
GetPodsCertIfSynced returns the certificate for all matching pods once all of them use the same certificate
func GetRunningPodByLabel ¶ added in v0.3.0
func GetRunningPodByVirtualMachineInstance ¶ added in v0.8.0
func GetRunningPodByVirtualMachineInstance(vmi *v1.VirtualMachineInstance, namespace string) *k8sv1.Pod
func GetRunningVMIDomainSpec ¶ added in v0.28.0
func GetRunningVMIDomainSpec(vmi *v1.VirtualMachineInstance) (*launcherApi.DomainSpec, error)
func GetRunningVirtualMachineInstanceDomainXML ¶ added in v0.9.2
func GetRunningVirtualMachineInstanceDomainXML(virtClient kubecli.KubevirtClient, vmi *v1.VirtualMachineInstance) (string, error)
func GetVmPodName ¶ added in v0.15.0
func GetVmPodName(virtCli kubecli.KubevirtClient, vmi *v1.VirtualMachineInstance) string
func HasDataVolumeCRD ¶ added in v0.17.0
func HasDataVolumeCRD() bool
func HasExperimentalIgnitionSupport ¶ added in v0.17.3
func HasExperimentalIgnitionSupport() bool
func HasFeature ¶ added in v0.16.0
func HasLiveMigration ¶ added in v0.16.0
func HasLiveMigration() bool
func IsIPv6Cluster ¶ added in v0.30.0
func IsIPv6Cluster(virtClient kubecli.KubevirtClient) bool
func IsLauncherCapabilityValid ¶ added in v0.30.4
func IsLauncherCapabilityValid(capability k8sv1.Capability) bool
func IsOpenShift ¶ added in v0.12.0
func IsOpenShift() bool
func IsRunningOnKindInfra ¶ added in v0.29.0
func IsRunningOnKindInfra() bool
func IsRunningOnKindInfraIPv6 ¶ added in v0.30.0
func IsRunningOnKindInfraIPv6() bool
func IsUsingBuiltinNodeDrainKey ¶ added in v0.29.0
func IsUsingBuiltinNodeDrainKey() bool
func LoggedInAlpineExpecter ¶ added in v0.6.0
func LoggedInAlpineExpecter(vmi *v1.VirtualMachineInstance) (expect.Expecter, error)
func LoggedInCirrosExpecter ¶ added in v0.3.0
func LoggedInCirrosExpecter(vmi *v1.VirtualMachineInstance) (expect.Expecter, error)
func LoggedInFedoraExpecter ¶ added in v0.10.0
func LoggedInFedoraExpecter(vmi *v1.VirtualMachineInstance) (expect.Expecter, error)
LoggedInFedoraExpecter return prepared and ready to use console expecter for Fedora test VM
func NewConsoleExpecter ¶ added in v0.0.4
func NewHelloWorldJob ¶ added in v0.6.0
NewHelloWorldJob takes a DNS entry or an IP and a port which it will use create a pod which tries to contact the host on the provided port. It expects to receive "Hello World!" to succeed.
func NewHelloWorldJobHttp ¶ added in v0.15.0
NewHelloWorldJobHttp gets an IP address and a port, which it uses to create a pod. This pod tries to contact the host on the provided port, over HTTP. On success - it expects to receive "Hello World!".
func NewHelloWorldJobUDP ¶ added in v0.6.0
NewHelloWorldJobUDP takes a DNS entry or an IP and a port which it will use create a pod which tries to contact the host on the provided port. It expects to receive "Hello World!" to succeed. Note that in case of UDP, the server will not see the connection unless something is sent over it However, netcat does not work well with UDP and closes before the answer arrives, for that another netcat call is needed, this time as a UDP listener
func NewISCSIPV ¶ added in v0.22.0
func NewISCSIPV(name, size, iscsiTargetIP string, accessMode k8sv1.PersistentVolumeAccessMode, volumeMode k8sv1.PersistentVolumeMode) *k8sv1.PersistentVolume
func NewRandomDataVolumeWithHttpImport ¶ added in v0.8.0
func NewRandomDataVolumeWithHttpImport(imageUrl, namespace string, accessMode k8sv1.PersistentVolumeAccessMode) *cdiv1.DataVolume
func NewRandomDataVolumeWithHttpImportInStorageClass ¶ added in v0.31.0
func NewRandomDataVolumeWithHttpImportInStorageClass(imageUrl, namespace, storageClass string, accessMode k8sv1.PersistentVolumeAccessMode) *cdiv1.DataVolume
func NewRandomDataVolumeWithPVCSource ¶ added in v0.20.0
func NewRandomDataVolumeWithPVCSource(sourceNamespace, sourceName, targetNamespace string, accessMode k8sv1.PersistentVolumeAccessMode) *cdiv1.DataVolume
func NewRandomDataVolumeWithPVCSourceWithStorageClass ¶ added in v0.20.5
func NewRandomDataVolumeWithPVCSourceWithStorageClass(sourceNamespace, sourceName, targetNamespace, storageClass, size string, accessMode k8sv1.PersistentVolumeAccessMode) *cdiv1.DataVolume
func NewRandomFedora32VMIWithFedoraUser ¶ added in v0.30.0
func NewRandomFedora32VMIWithFedoraUser() *v1.VirtualMachineInstance
func NewRandomFedoraVMIWitGuestAgent ¶ added in v0.16.1
func NewRandomFedoraVMIWitGuestAgent() *v1.VirtualMachineInstance
func NewRandomFedoraVMIWithDmidecode ¶ added in v0.22.0
func NewRandomFedoraVMIWithDmidecode() *v1.VirtualMachineInstance
func NewRandomMigration ¶ added in v0.9.2
func NewRandomMigration(vmiName string, namespace string) *v1.VirtualMachineInstanceMigration
func NewRandomReplicaSetFromVMI ¶ added in v0.6.1
func NewRandomReplicaSetFromVMI(vmi *v1.VirtualMachineInstance, replicas int32) *v1.VirtualMachineInstanceReplicaSet
func NewRandomVMI ¶ added in v0.6.1
func NewRandomVMI() *v1.VirtualMachineInstance
func NewRandomVMIWithCDRom ¶ added in v0.6.1
func NewRandomVMIWithCDRom(claimName string) *v1.VirtualMachineInstance
func NewRandomVMIWithConfigMap ¶ added in v0.9.0
func NewRandomVMIWithConfigMap(configMapName string) *v1.VirtualMachineInstance
func NewRandomVMIWithCustomMacAddress ¶ added in v0.6.4
func NewRandomVMIWithCustomMacAddress() *v1.VirtualMachineInstance
func NewRandomVMIWithDataVolume ¶ added in v0.8.0
func NewRandomVMIWithDataVolume(dataVolumeName string) *v1.VirtualMachineInstance
func NewRandomVMIWithEFIBootloader ¶ added in v0.14.0
func NewRandomVMIWithEFIBootloader() *v1.VirtualMachineInstance
func NewRandomVMIWithEphemeralDisk ¶ added in v0.6.1
func NewRandomVMIWithEphemeralDisk(containerImage string) *v1.VirtualMachineInstance
func NewRandomVMIWithEphemeralDiskAndConfigDriveUserdata ¶ added in v0.19.0
func NewRandomVMIWithEphemeralDiskAndConfigDriveUserdata(containerImage string, userData string) *v1.VirtualMachineInstance
func NewRandomVMIWithEphemeralDiskAndConfigDriveUserdataHighMemory ¶ added in v0.19.0
func NewRandomVMIWithEphemeralDiskAndConfigDriveUserdataHighMemory(containerImage string, userData string) *v1.VirtualMachineInstance
func NewRandomVMIWithEphemeralDiskAndConfigDriveUserdataNetworkData ¶ added in v0.19.0
func NewRandomVMIWithEphemeralDiskAndConfigDriveUserdataNetworkData(containerImage, userData, networkData string, b64encode bool) *v1.VirtualMachineInstance
func NewRandomVMIWithEphemeralDiskAndUserdata ¶ added in v0.6.1
func NewRandomVMIWithEphemeralDiskAndUserdata(containerImage string, userData string) *v1.VirtualMachineInstance
func NewRandomVMIWithEphemeralDiskAndUserdataHighMemory ¶ added in v0.6.1
func NewRandomVMIWithEphemeralDiskAndUserdataHighMemory(containerImage string, userData string) *v1.VirtualMachineInstance
func NewRandomVMIWithEphemeralDiskAndUserdataNetworkData ¶ added in v0.14.0
func NewRandomVMIWithEphemeralDiskAndUserdataNetworkData(containerImage, userData, networkData string, b64encode bool) *v1.VirtualMachineInstance
func NewRandomVMIWithEphemeralDiskHighMemory ¶ added in v0.6.1
func NewRandomVMIWithEphemeralDiskHighMemory(containerImage string) *v1.VirtualMachineInstance
func NewRandomVMIWithEphemeralPVC ¶ added in v0.6.1
func NewRandomVMIWithEphemeralPVC(claimName string) *v1.VirtualMachineInstance
func NewRandomVMIWithHostDisk ¶ added in v0.9.0
func NewRandomVMIWithHostDisk(diskPath string, diskType v1.HostDiskType, nodeName string) *v1.VirtualMachineInstance
func NewRandomVMIWithMasqueradeInterfaceEphemeralDiskAndUserdata ¶ added in v0.19.0
func NewRandomVMIWithNS ¶ added in v0.6.1
func NewRandomVMIWithNS(namespace string) *v1.VirtualMachineInstance
func NewRandomVMIWithPVC ¶ added in v0.6.1
func NewRandomVMIWithPVC(claimName string) *v1.VirtualMachineInstance
func NewRandomVMIWithSecret ¶ added in v0.9.0
func NewRandomVMIWithSecret(secretName string) *v1.VirtualMachineInstance
func NewRandomVMIWithSecureBoot ¶ added in v0.30.4
func NewRandomVMIWithSecureBoot() *v1.VirtualMachineInstance
func NewRandomVMIWithServiceAccount ¶ added in v0.9.2
func NewRandomVMIWithServiceAccount(serviceAccountName string) *v1.VirtualMachineInstance
func NewRandomVMIWithSlirpInterfaceEphemeralDiskAndUserdata ¶ added in v0.7.0
func NewRandomVMIWithWatchdog ¶ added in v0.6.1
func NewRandomVMIWithWatchdog() *v1.VirtualMachineInstance
func NewRandomVMIWithe1000NetworkInterface ¶ added in v0.6.1
func NewRandomVMIWithe1000NetworkInterface() *v1.VirtualMachineInstance
func NewRandomVMWithCloneDataVolume ¶ added in v0.20.0
func NewRandomVMWithCloneDataVolume(sourceNamespace, sourceName, targetNamespace string) *v1.VirtualMachine
func NewRandomVMWithDataVolume ¶ added in v0.8.0
func NewRandomVMWithDataVolume(imageUrl string, namespace string) *v1.VirtualMachine
func NewRandomVMWithDataVolumeInStorageClass ¶ added in v0.31.0
func NewRandomVMWithDataVolumeInStorageClass(imageUrl, namespace, storageClass string) *v1.VirtualMachine
func NewRandomVMWithEphemeralDisk ¶
func NewRandomVMWithEphemeralDisk(containerImage string) *v1.VirtualMachine
func NewRandomVirtualMachine ¶ added in v0.8.0
func NewRandomVirtualMachine(vmi *v1.VirtualMachineInstance, running bool) *v1.VirtualMachine
func NewRandomVirtualMachineInstanceWithOCSDisk ¶ added in v0.20.5
func NewRandomVirtualMachineInstanceWithOCSDisk(imageUrl, namespace string, accessMode k8sv1.PersistentVolumeAccessMode, volMode k8sv1.PersistentVolumeMode) (*v1.VirtualMachineInstance, *cdiv1.DataVolume)
func NewRepeatableVirtctlCommand ¶ added in v0.4.0
func NewVirtctlCommand ¶ added in v0.4.0
func NotDeleted ¶ added in v0.5.0
func NotDeleted(vmis *v1.VirtualMachineInstanceList) (notDeleted []v1.VirtualMachineInstance)
func PanicOnError ¶
func PanicOnError(err error)
func PrometheusRuleEnabled ¶ added in v0.26.0
func PrometheusRuleEnabled() bool
PrometheusRuleEnabled returns true if the PrometheusRule CRD is enabled and false otherwise.
func RandTmpDir ¶ added in v0.29.0
func RandTmpDir() string
func ReLoggedInFedoraExpecter ¶ added in v0.19.0
ReLoggedInFedoraExpecter return prepared and ready to use console expecter for Fedora test VM, when you are reconnecting (no login needed)
func ReadManifestYamlFile ¶ added in v0.12.0
func ReadManifestYamlFile(pathToManifest string) []unstructured.Unstructured
func RemoveHostDiskImage ¶ added in v0.9.0
func RemoveLabelFromNode ¶ added in v0.16.0
func RenderHostPathJob ¶ added in v0.9.6
func RenderHostPathJob(jobName string, dir string, hostPathType k8sv1.HostPathType, mountPropagation k8sv1.MountPropagationMode, cmd []string, args []string) *k8sv1.Pod
func RestoreKubeVirtResource ¶ added in v0.29.0
func RestoreKubeVirtResource()
func RetryIfModified ¶ added in v0.22.0
func RetryWithMetadataIfModified ¶ added in v0.23.0
func RetryWithMetadataIfModified(objectMeta metav1.ObjectMeta, do func(objectMeta metav1.ObjectMeta) error) (err error)
func RunCommand ¶ added in v0.8.0
func RunCommandOnVmiPod ¶ added in v0.6.3
func RunCommandOnVmiPod(vmi *v1.VirtualMachineInstance, command []string) string
RunCommandOnVmiPod runs specified command on the virt-launcher pod
func RunCommandPipe ¶ added in v0.9.2
func RunCommandPipeWithNS ¶ added in v0.9.2
func RunCommandWithNS ¶ added in v0.9.2
func RunCommandWithNSAndInput ¶ added in v0.20.0
func RunVMI ¶ added in v0.9.0
func RunVMI(vmi *v1.VirtualMachineInstance, timeout int) *v1.VirtualMachineInstance
func RunVMIAndExpectLaunch ¶ added in v0.9.0
func RunVMIAndExpectLaunch(vmi *v1.VirtualMachineInstance, timeout int) *v1.VirtualMachineInstance
func RunVMIAndExpectLaunchIgnoreWarnings ¶ added in v0.29.0
func RunVMIAndExpectLaunchIgnoreWarnings(vmi *v1.VirtualMachineInstance, timeout int) *v1.VirtualMachineInstance
func RunVMIAndExpectLaunchWithIgnoreWarningArg ¶ added in v0.30.0
func RunVMIAndExpectLaunchWithIgnoreWarningArg(vmi *v1.VirtualMachineInstance, timeout int, ignoreWarnings bool) *v1.VirtualMachineInstance
func RunVMIAndExpectScheduling ¶ added in v0.17.0
func RunVMIAndExpectScheduling(vmi *v1.VirtualMachineInstance, timeout int) *v1.VirtualMachineInstance
func SecureBootExpecter ¶ added in v0.30.4
func SecureBootExpecter(vmi *v1.VirtualMachineInstance) (expect.Expecter, error)
func ServiceMonitorEnabled ¶ added in v0.20.6
func ServiceMonitorEnabled() bool
func SkipIfNoCmd ¶ added in v0.8.0
func SkipIfNoCmd(cmdName string)
func SkipIfNoRhelImage ¶ added in v0.9.0
func SkipIfNoRhelImage(virtClient kubecli.KubevirtClient)
func SkipIfNoWindowsImage ¶ added in v0.4.1
func SkipIfNoWindowsImage(virtClient kubecli.KubevirtClient)
func SkipIfNotUseNetworkPolicy ¶ added in v0.9.0
func SkipIfNotUseNetworkPolicy(virtClient kubecli.KubevirtClient)
func SkipIfOpenShift ¶ added in v0.8.0
func SkipIfOpenShift(message string)
func SkipIfOpenShift4 ¶ added in v0.22.0
func SkipIfOpenShift4(message string)
func SkipIfOpenShiftAndBelowOrEqualVersion ¶ added in v0.20.0
func SkipIfUseFlannel ¶ added in v0.9.0
func SkipIfUseFlannel(virtClient kubecli.KubevirtClient)
func SkipIfVersionAboveOrEqual ¶ added in v0.18.0
func SkipIfVersionBelow ¶ added in v0.7.0
SkipIfVersionBelow will skip tests if it runs on an environment with k8s version below specified
func SkipNFSTestIfRunnigOnKindInfra ¶ added in v0.30.0
func SkipNFSTestIfRunnigOnKindInfra()
func SkipPVCTestIfRunnigOnKindInfra ¶ added in v0.29.0
func SkipPVCTestIfRunnigOnKindInfra()
func StartHTTPServer ¶ added in v0.11.0
func StartHTTPServer(vmi *v1.VirtualMachineInstance, port int, isFedoraVM bool)
func StartTCPServer ¶ added in v0.11.0
func StartTCPServer(vmi *v1.VirtualMachineInstance, port int)
func StartVirtualMachine ¶ added in v0.8.0
func StartVirtualMachine(vm *v1.VirtualMachine) *v1.VirtualMachine
func StartVmOnNode ¶ added in v0.6.3
func StartVmOnNode(vmi *v1.VirtualMachineInstance, nodeName string)
StartVmOnNode starts a VMI on the specified node
func StopVirtualMachine ¶ added in v0.8.0
func StopVirtualMachine(vm *v1.VirtualMachine) *v1.VirtualMachine
func UnfinishedVMIPodSelector ¶ added in v0.6.1
func UnfinishedVMIPodSelector(vmi *v1.VirtualMachineInstance) metav1.ListOptions
func UpdateClusterConfigValueAndWait ¶ added in v0.20.7
UpdateClusterConfigValueAndWait updates the given configuration in the kubevirt config map and then waits to allow the configuration events to be propagated to the consumers.
func WaitAgentConnected ¶ added in v0.19.0
func WaitAgentConnected(virtClient kubecli.KubevirtClient, vmi *v1.VirtualMachineInstance)
func WaitForAllPodsReady ¶ added in v0.12.0
func WaitForAllPodsReady(timeout time.Duration, listOptions metav1.ListOptions)
func WaitForMigrationToDisappearWithTimeout ¶ added in v0.16.0
func WaitForMigrationToDisappearWithTimeout(migration *v1.VirtualMachineInstanceMigration, seconds int)
func WaitForPodToDisappearWithTimeout ¶ added in v0.27.0
func WaitForSuccessfulDataVolumeImport ¶ added in v0.12.0
func WaitForSuccessfulDataVolumeImport(dv *cdiv1.DataVolume, seconds int)
func WaitForSuccessfulDataVolumeImportOfVMI ¶ added in v0.20.5
Block until DataVolume succeeds.
func WaitForSuccessfulVMIStart ¶ added in v0.6.1
func WaitForSuccessfulVMIStartIgnoreWarnings ¶ added in v0.6.1
func WaitForSuccessfulVMIStartWithTimeout ¶ added in v0.6.1
func WaitForSuccessfulVMIStartWithTimeoutIgnoreWarnings ¶ added in v0.19.0
func WaitForVMCondition ¶ added in v0.24.0
func WaitForVMCondition(virtClient kubecli.KubevirtClient, vm *v1.VirtualMachine, conditionType v1.VirtualMachineConditionType, timeoutSec int)
func WaitForVMConditionRemovedOrFalse ¶ added in v0.24.0
func WaitForVMConditionRemovedOrFalse(virtClient kubecli.KubevirtClient, vm *v1.VirtualMachine, conditionType v1.VirtualMachineConditionType, timeoutSec int)
func WaitForVMICondition ¶ added in v0.24.0
func WaitForVMICondition(virtClient kubecli.KubevirtClient, vmi *v1.VirtualMachineInstance, conditionType v1.VirtualMachineInstanceConditionType, timeoutSec int)
func WaitForVMIConditionRemovedOrFalse ¶ added in v0.24.0
func WaitForVMIConditionRemovedOrFalse(virtClient kubecli.KubevirtClient, vmi *v1.VirtualMachineInstance, conditionType v1.VirtualMachineInstanceConditionType, timeoutSec int)
func WaitForVirtualMachineToDisappearWithTimeout ¶ added in v0.5.0
func WaitForVirtualMachineToDisappearWithTimeout(vmi *v1.VirtualMachineInstance, seconds int)
func WaitUntilVMIReady ¶ added in v0.8.0
func WaitUntilVMIReady(vmi *v1.VirtualMachineInstance, expecterFactory VMIExpecterFactory) *v1.VirtualMachineInstance
func WaitUntilVMIReadyWithNamespace ¶ added in v0.8.0
func WaitUntilVMIReadyWithNamespace(namespace string, vmi *v1.VirtualMachineInstance, expecterFactory VMIExpecterFactory) *v1.VirtualMachineInstance
func WipeTestingInfrastructure ¶ added in v0.12.0
func WipeTestingInfrastructure()
Types ¶
type ContainerDisk ¶ added in v0.11.0
type ContainerDisk string
const ( ContainerDiskCirrosCustomLocation ContainerDisk = "cirros-custom" ContainerDiskCirros ContainerDisk = "cirros" ContainerDiskAlpine ContainerDisk = "alpine" ContainerDiskFedora ContainerDisk = "fedora-cloud" ContainerDiskMicroLiveCD ContainerDisk = "microlivecd" ContainerDiskVirtio ContainerDisk = "virtio-container-disk" ContainerDiskEmpty ContainerDisk = "empty" )
type KubeVirtTestsConfiguration ¶ added in v0.16.0
type KubeVirtTestsConfiguration struct { // StorageClass to use to create local PVCs StorageClassLocal string `json:"storageClassLocal"` // StorageClass to use to create host-path PVCs StorageClassHostPath string `json:"storageClassHostPath"` // StorageClass to use to create block-volume PVCs StorageClassBlockVolume string `json:"storageClassBlockVolume"` // StorageClass to use to create rhel PVCs StorageClassRhel string `json:"storageClassRhel"` // StorageClass to use to create windows PVCs StorageClassWindows string `json:"storageClassWindows"` // Flag if true the storageclasses are managed, false otherwise ManageStorageClasses bool `json:"manageStorageClasses"` }
KubeVirtTestsConfiguration contains the configuration for KubeVirt tests
var Config *KubeVirtTestsConfiguration
type ObjectEventWatcher ¶
type ObjectEventWatcher struct {
// contains filtered or unexported fields
}
func NewObjectEventWatcher ¶
func NewObjectEventWatcher(object runtime.Object) *ObjectEventWatcher
func (*ObjectEventWatcher) FailOnWarnings ¶
func (w *ObjectEventWatcher) FailOnWarnings() *ObjectEventWatcher
func (*ObjectEventWatcher) SinceNow ¶
func (w *ObjectEventWatcher) SinceNow() *ObjectEventWatcher
SinceNow sets a watch starting point for events, from the moment on the connection to the apiserver was established.
func (*ObjectEventWatcher) SinceObjectResourceVersion ¶
func (w *ObjectEventWatcher) SinceObjectResourceVersion(object runtime.Object) *ObjectEventWatcher
SinceObjectResourceVersion takes the resource version of the passed in runtime object and takes it as the starting point for all events to watch for.
func (*ObjectEventWatcher) SinceResourceVersion ¶
func (w *ObjectEventWatcher) SinceResourceVersion(rv string) *ObjectEventWatcher
SinceResourceVersion sets the passed in resourceVersion as the starting point for all events to watch for.
func (*ObjectEventWatcher) SinceWatchedObjectResourceVersion ¶
func (w *ObjectEventWatcher) SinceWatchedObjectResourceVersion() *ObjectEventWatcher
SinceWatchedObjectResourceVersion takes the resource version of the runtime object which is watched, and takes it as the starting point for all events to watch for.
func (*ObjectEventWatcher) Timeout ¶
func (w *ObjectEventWatcher) Timeout(duration time.Duration) *ObjectEventWatcher
func (*ObjectEventWatcher) WaitFor ¶
func (w *ObjectEventWatcher) WaitFor(stopChan chan struct{}, eventType EventType, reason interface{}) (e *k8sv1.Event)
func (*ObjectEventWatcher) WaitNotFor ¶ added in v0.11.0
func (w *ObjectEventWatcher) WaitNotFor(stopChan chan struct{}, eventType EventType, reason interface{}) (e *k8sv1.Event)
func (*ObjectEventWatcher) Watch ¶
func (w *ObjectEventWatcher) Watch(abortChan chan struct{}, processFunc ProcessFunc, watchedDescription string)
type ProcessFunc ¶
type VMIExpecterFactory ¶ added in v0.6.1
type VMIExpecterFactory func(*v1.VirtualMachineInstance) (expect.Expecter, error)