Documentation
¶
Index ¶
- Constants
- func AfterTestSuitCleanup()
- func BeforeTestCleanup()
- func BeforeTestSuitSetup()
- func GetReadyNodes() []k8sv1.Node
- func NewRandomMigrationForVm(vm *v1.VM) *v1.Migration
- func NewRandomVM() *v1.VM
- func NewRandomVMWithDirectLun(lun int) *v1.VM
- func NewRandomVMWithEphemeralDisk(containerImage string) *v1.VM
- func NewRandomVMWithNS(namespace string) *v1.VM
- func NewRandomVMWithPVC(claimName string) *v1.VM
- func NewRandomVMWithSerialConsole() *v1.VM
- func NewRandomVMWithSpice() *v1.VM
- func PanicOnError(err error)
- func WaitForSuccessfulVMStart(vm runtime.Object) (nodeName string)
- type EventType
- 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(eventType EventType, reason interface{}) (e *k8sv1.Event)
- func (w *ObjectEventWatcher) Watch(processFunc ProcessFunc)
- type ProcessFunc
Constants ¶
View Source
const ( // tests.NamespaceTestDefault is the default namespace, to test non-infrastructure related KubeVirt objects. NamespaceTestDefault string = "kubevirt-test-default" // NamespaceTestAlternative is used to test controller-namespace independency. NamespaceTestAlternative string = "kubevirt-test-alternative" )
Variables ¶
This section is empty.
Functions ¶
func AfterTestSuitCleanup ¶
func AfterTestSuitCleanup()
func BeforeTestCleanup ¶
func BeforeTestCleanup()
func BeforeTestSuitSetup ¶
func BeforeTestSuitSetup()
func GetReadyNodes ¶
func NewRandomVM ¶
func NewRandomVMWithNS ¶
func NewRandomVMWithPVC ¶
func NewRandomVMWithSpice ¶
func PanicOnError ¶
func PanicOnError(err error)
func WaitForSuccessfulVMStart ¶
Block until the specified VM started and return the target node name.
Types ¶
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 ¶
Click to show internal directories.
Click to hide internal directories.