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 HandlePodList(k8sClient *fakek8sclient.Clientset, podName string)
• func HandleSecretGet(k8sClient *fakek8sclient.Clientset, secretName string)
• func HandleServiceGet(k8sClient *fakek8sclient.Clientset, serviceName string, port int)
• func HandleVMExportCreate(client *kubevirtfake.Clientset, vme *exportv1.VirtualMachineExport)
• func HandleVMExportGet(client *kubevirtfake.Clientset, vme *exportv1.VirtualMachineExport, ...)
• func VMExportSpecLocalObjectResource(name, namespace, secretName string, source *v1.TypedLocalObjectReference) *exportv1.VirtualMachineExport
• func VMExportSpecPVC(name, namespace, resourceName, secretName string) *exportv1.VirtualMachineExport
• func VMExportSpecSnapshot(name, namespace, resourceName, secretName string) *exportv1.VirtualMachineExport
• func VMExportSpecVM(name, namespace, resourceName, secretName string) *exportv1.VirtualMachineExport
• 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 HandlePodList

func HandlePodList(k8sClient *fakek8sclient.Clientset, podName string)

func HandleSecretGet

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

func HandleServiceGet

func HandleServiceGet(k8sClient *fakek8sclient.Clientset, serviceName string, port int)

func HandleVMExportCreate

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

func HandleVMExportGet

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

func VMExportSpecLocalObjectResource

func VMExportSpecLocalObjectResource(name, namespace, secretName string, source *v1.TypedLocalObjectReference) *exportv1.VirtualMachineExport

func VMExportSpecPVC

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

func VMExportSpecSnapshot

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

func VMExportSpecVM

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

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()