tests

package
v0.6.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 4, 2018 License: Apache-2.0 Imports: 34 Imported by: 0

README

Integration tests

Integration tests require a running Kubevirt cluster. Once you have a running Kubevirt cluster, you can use the -master and the -kubeconfig flags to point the tests to the cluster.

Run them on an arbitrary KubeVirt installation

cd tests # from the git repo root folder
go test -kubeconfig=path/to/my/config

Run them on one of the core KubeVirt providers

There is a make target to run this with the config taken from hack/config.sh:

# from the git repo root folder
make functest

Documentation

Index

Constants

View Source 
const (
	SubresourceServiceAccountName = "kubevirt-subresource-test-sa"
	AdminServiceAccountName       = "kubevirt-admin-test-sa"
	EditServiceAccountName        = "kubevirt-edit-test-sa"
	ViewServiceAccountName        = "kubevirt-view-test-sa"
)
View Source 
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"
)
View Source 
const (
	HostPathAlpine = "/tmp/hostImages/alpine"
	HostPathCustom = "/tmp/hostImages/custom"
)
View Source 
const (
	DiskAlpineHostPath = "disk-alpine-host-path"
	DiskWindows        = "disk-windows"
	DiskCustomHostPath = "disk-custom-host-path"
)
View Source 
const (
	CustomHostPath = "custom-host-path"
)
View Source 
const (
	SecretLabel = "kubevirt.io/secret"
)
View Source 
const SubresourceTestLabel = "subresource-access-test-pod"
View Source 
const VMIResource = "virtualmachineinstances"

Variables

View Source 
var KubeVirtInstallNamespace = "kube-system"
View Source 
var KubeVirtKubectlPath = ""
View Source 
var KubeVirtRepoPrefix = "kubevirt"
View Source 
var KubeVirtVersionTag = "latest"

Functions

func AddBootOrderToDisk added in v0.6.0 

func AddBootOrderToDisk(vmi *v1.VirtualMachineInstance, diskName string, bootorder *uint) *v1.VirtualMachineInstance

func AddEphemeralDisk 

func AddEphemeralDisk(vmi *v1.VirtualMachineInstance, name string, bus string, image string) *v1.VirtualMachineInstance

func AddEphemeralFloppy 

func AddEphemeralFloppy(vmi *v1.VirtualMachineInstance, name string, image string) *v1.VirtualMachineInstance

func AddPVCDisk added in v0.5.0 

func AddPVCDisk(vmi *v1.VirtualMachineInstance, name string, bus string, claimName string) *v1.VirtualMachineInstance

func AfterTestSuitCleanup 

func AfterTestSuitCleanup()

func BeforeAll added in v0.4.1 

func BeforeAll(fn func())

func BeforeTestCleanup 

func BeforeTestCleanup()

func BeforeTestSuitSetup 

func BeforeTestSuitSetup()

func CheckForTextExpecter added in v0.6.0 

func CheckForTextExpecter(vmi *v1.VirtualMachineInstance, text string, wait int) error

func CreateHostPathPv added in v0.6.1 

func CreateHostPathPv(os string, hostPath string)

func CreatePVC added in v0.5.0 

func CreatePVC(os string, size string)

func DeletePV added in v0.5.0 

func DeletePV(os string)

func DeletePVC added in v0.5.0 

func DeletePVC(os string)

func ExecuteCommandOnPod added in v0.4.1 

func ExecuteCommandOnPod(virtCli kubecli.KubevirtClient, pod *k8sv1.Pod, containerName string, command []string) (string, error)

func GenerateVMIJson added in v0.6.1 

func GenerateVMIJson(vmi *v1.VirtualMachineInstance) (string, error)

func GetNodeLibvirtCapabilities added in v0.6.2 

func GetNodeLibvirtCapabilities(nodeName string) string

GetNodeLibvirtCapabilities returns node libvirt capabilities

func GetNodeWithHugepages added in v0.6.1 

func GetNodeWithHugepages(virtClient kubecli.KubevirtClient, hugepages k8sv1.ResourceName) *k8sv1.Node

func GetRunningPodByLabel 

func GetRunningPodByLabel(label string, labelType string, namespace string) *k8sv1.Pod

func LoggedInAlpineExpecter added in v0.6.0 

func LoggedInAlpineExpecter(vmi *v1.VirtualMachineInstance) (expect.Expecter, error)

func LoggedInCirrosExpecter 

func LoggedInCirrosExpecter(vmi *v1.VirtualMachineInstance) (expect.Expecter, error)

func NewBool 

func NewBool(x bool) *bool

func NewConsoleExpecter 

func NewConsoleExpecter(virtCli kubecli.KubevirtClient, vmi *v1.VirtualMachineInstance, timeout time.Duration, opts ...expect.Option) (expect.Expecter, <-chan error, error)

func NewHelloWorldJob added in v0.6.0 

func NewHelloWorldJob(host string, port string) *k8sv1.Pod

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 NewHelloWorldJobUDP added in v0.6.0 

func NewHelloWorldJobUDP(host string, port string) *k8sv1.Pod

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 NewInt32 

func NewInt32(x int32) *int32

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 NewRandomVMIWithEphemeralDisk added in v0.6.1 

func NewRandomVMIWithEphemeralDisk(containerImage string) *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 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 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 NewRandomVMIWithWatchdog added in v0.6.1 

func NewRandomVMIWithWatchdog() *v1.VirtualMachineInstance

func NewRandomVMIWithe1000NetworkInterface added in v0.6.1 

func NewRandomVMIWithe1000NetworkInterface() *v1.VirtualMachineInstance

func NewRepeatableVirtctlCommand added in v0.4.0 

func NewRepeatableVirtctlCommand(args ...string) func() error

func NewVirtctlCommand added in v0.4.0 

func NewVirtctlCommand(args ...string) *cobra.Command

func NotDeleted added in v0.5.0 

func NotDeleted(vmis *v1.VirtualMachineInstanceList) (notDeleted []v1.VirtualMachineInstance)

func PanicOnError 

func PanicOnError(err error)

func RegistryDiskFor 

func RegistryDiskFor(name RegistryDisk) string

RegistryDiskFor takes the name of an image and returns the full registry diks image path. Supported values are: cirros, fedora, alpine

func RenderJob 

func RenderJob(name string, cmd []string, args []string) *k8sv1.Pod

func RunKubectlCommand added in v0.4.1 

func RunKubectlCommand(args ...string) (string, error)

func SkipIfNoKubectl added in v0.4.1 

func SkipIfNoKubectl()

func SkipIfNoWindowsImage added in v0.4.1 

func SkipIfNoWindowsImage(virtClient kubecli.KubevirtClient)

func UnfinishedVMIPodSelector added in v0.6.1 

func UnfinishedVMIPodSelector(vmi *v1.VirtualMachineInstance) metav1.ListOptions

func WaitForSuccessfulVMIStart added in v0.6.1 

func WaitForSuccessfulVMIStart(vmi runtime.Object) string

func WaitForSuccessfulVMIStartIgnoreWarnings added in v0.6.1 

func WaitForSuccessfulVMIStartIgnoreWarnings(vmi runtime.Object) string

func WaitForSuccessfulVMIStartWithTimeout added in v0.6.1 

func WaitForSuccessfulVMIStartWithTimeout(vmi runtime.Object, seconds int) (nodeName string)

func WaitForVirtualMachineToDisappearWithTimeout added in v0.5.0 

func WaitForVirtualMachineToDisappearWithTimeout(vmi *v1.VirtualMachineInstance, seconds int)

Types

type EventType 

type EventType string
const (
	NormalEvent  EventType = "Normal"
	WarningEvent EventType = "Warning"
)

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(eventType EventType, reason interface{}) (e *k8sv1.Event)

func (*ObjectEventWatcher) Watch 

func (w *ObjectEventWatcher) Watch(processFunc ProcessFunc)

type ProcessFunc 

type ProcessFunc func(event *k8sv1.Event) (done bool)

type RegistryDisk 

type RegistryDisk string
const (
	RegistryDiskCirros RegistryDisk = "cirros"
	RegistryDiskAlpine RegistryDisk = "alpine"
	RegistryDiskFedora RegistryDisk = "fedora-cloud"
)

type VMIExpecterFactory added in v0.6.1 

type VMIExpecterFactory func(*v1.VirtualMachineInstance) (expect.Expecter, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.
JackTT - Gopher 🇻🇳