utils

Documentation

Index

• func AttachConsole(stdinReader, stdoutReader *io.PipeReader, ...) (err error)
• func GetExportVolumeFormat(url string, format exportv1.ExportVolumeFormat) []exportv1.VirtualMachineExportVolumeFormat
• func GetVMEStatus(volumes []exportv1.VirtualMachineExportVolume, secretName string) *exportv1.VirtualMachineExportStatus
• func HandleSecretGet(k8sClient *fakek8sclient.Clientset, secretName string)
• func HandleVMExportCreate(client *kubevirtfake.Clientset, vme *exportv1.VirtualMachineExport)
• func HandleVMExportGet(client *kubevirtfake.Clientset, vme *exportv1.VirtualMachineExport, ...)
• func VMExportSpec(name, namespace, kind, resourceName, secretName string) *exportv1.VirtualMachineExport
• func WaitExportCompleteDefault(kubecli.KubevirtClient, *vmexport.VMExportInfo, time.Duration, time.Duration) error
• func WaitExportCompleteError(kubecli.KubevirtClient, *vmexport.VMExportInfo, time.Duration, time.Duration) error
• type AtomicBool
  • func (b *AtomicBool) False()
  • func (b *AtomicBool) IsTrue() bool
  • func (b *AtomicBool) True()

Functions

func AttachConsole

func AttachConsole(stdinReader, stdoutReader *io.PipeReader, stdinWriter, stdoutWriter *io.PipeWriter, message string, resChan <-chan error) (err error)

AttachConsole attaches stdin and stdout to the console in -> stdinWriter | stdinReader -> console out <- stdoutReader | stdoutWriter <- console

func GetExportVolumeFormat

func GetExportVolumeFormat(url string, format exportv1.ExportVolumeFormat) []exportv1.VirtualMachineExportVolumeFormat

func GetVMEStatus

func GetVMEStatus(volumes []exportv1.VirtualMachineExportVolume, secretName string) *exportv1.VirtualMachineExportStatus

func HandleSecretGet

func HandleSecretGet(k8sClient *fakek8sclient.Clientset, secretName string)

func HandleVMExportCreate

func HandleVMExportCreate(client *kubevirtfake.Clientset, vme *exportv1.VirtualMachineExport)

func HandleVMExportGet

func HandleVMExportGet(client *kubevirtfake.Clientset, vme *exportv1.VirtualMachineExport, vmexportName string)

func VMExportSpec

func VMExportSpec(name, namespace, kind, resourceName, secretName string) *exportv1.VirtualMachineExport

func WaitExportCompleteDefault

func WaitExportCompleteDefault(kubecli.KubevirtClient, *vmexport.VMExportInfo, time.Duration, time.Duration) error

func WaitExportCompleteError

func WaitExportCompleteError(kubecli.KubevirtClient, *vmexport.VMExportInfo, time.Duration, time.Duration) error

Types

type AtomicBool

type AtomicBool struct {
	Lock *sync.Mutex
	// contains filtered or unexported fields
}

func (*AtomicBool) False

func (b *AtomicBool) False()

func (*AtomicBool) IsTrue

func (b *AtomicBool) IsTrue() bool

func (*AtomicBool) True

func (b *AtomicBool) True()