virthandler

Documentation

Index

• Constants
• Variables
• func FindMigrationIP(networkStatusPath string, migrationIp string) (string, error)
• func IsoGuestVolumePath(vmi *v1.VirtualMachineInstance, volume *v1.Volume) (string, bool)
• type NetworkStatus
• type VirtualMachineController
  • func NewController(recorder record.EventRecorder, clientset kubecli.KubevirtClient, host string, ...) *VirtualMachineController
  • func (c *VirtualMachineController) Execute() bool
  • func (c *VirtualMachineController) Run(threadiness int, stopCh chan struct{})

Constants

const (
	//VolumeReadyReason is the reason set when the volume is ready.
	VolumeReadyReason = "VolumeReady"
	//VolumeUnMountedFromPodReason is the reason set when the volume is unmounted from the virtlauncher pod
	VolumeUnMountedFromPodReason = "VolumeUnMountedFromPod"
	//VolumeMountedToPodReason is the reason set when the volume is mounted to the virtlauncher pod
	VolumeMountedToPodReason = "VolumeMountedToPod"
	//VolumeUnplugged is the reason set when the volume is completely unplugged from the VMI
	VolumeUnplugged = "VolumeUnplugged"
	//VMIDefined is the reason set when a VMI is defined
	VMIDefined = "VirtualMachineInstance defined."
	//VMIStarted is the reason set when a VMI is started
	VMIStarted = "VirtualMachineInstance started."
	//VMIShutdown is the reason set when a VMI is shutdown
	VMIShutdown = "The VirtualMachineInstance was shut down."
	//VMICrashed is the reason set when a VMI crashed
	VMICrashed = "The VirtualMachineInstance crashed."
	//VMIAbortingMigration is the reason set when migration is being aborted
	VMIAbortingMigration = "VirtualMachineInstance is aborting migration."
	//VMIMigrating in the reason set when the VMI is migrating
	VMIMigrating = "VirtualMachineInstance is migrating."
	//VMIMigrationTargetPrepared is the reason set when the migration target has been prepared
	VMIMigrationTargetPrepared = "VirtualMachineInstance Migration Target Prepared."
	//VMIStopping is the reason set when the VMI is stopping
	VMIStopping = "VirtualMachineInstance stopping"
	//VMIGracefulShutdown is the reason set when the VMI is gracefully shut down
	VMIGracefulShutdown = "Signaled Graceful Shutdown"
	//VMISignalDeletion is the reason set when the VMI has signal deletion
	VMISignalDeletion = "Signaled Deletion"
)

Variables

var PasswordRelatedGuestAgentCommands = []string{
	"guest-set-user-password",
}

var RequiredGuestAgentCommands = []string{
	"guest-ping",
	"guest-get-time",
	"guest-info",
	"guest-shutdown",
	"guest-network-get-interfaces",
	"guest-get-fsinfo",
	"guest-get-host-name",
	"guest-get-users",
	"guest-get-timezone",
	"guest-get-osinfo",
}

var SSHRelatedGuestAgentCommands = []string{
	"guest-exec-status",
	"guest-exec",
	"guest-file-open",
	"guest-file-close",
	"guest-file-read",
	"guest-file-write",
}

Functions

func FindMigrationIP

func FindMigrationIP(networkStatusPath string, migrationIp string) (string, error)

FindMigrationIP looks for dedicated migration network migration0 using the downward API and, if found, sets migration IP to it

func IsoGuestVolumePath

func IsoGuestVolumePath(vmi *v1.VirtualMachineInstance, volume *v1.Volume) (string, bool)

Types

type NetworkStatus

type NetworkStatus struct {
	Name      string   `yaml:"name"`
	Ips       []string `yaml:"ips"`
	Interface string   `yaml:"interface"`
}

type VirtualMachineController

type VirtualMachineController struct {
	Queue workqueue.RateLimitingInterface
	// contains filtered or unexported fields
}

func NewController

func NewController(
	recorder record.EventRecorder,
	clientset kubecli.KubevirtClient,
	host string,
	migrationIpAddress string,
	virtShareDir string,
	virtPrivateDir string,
	vmiSourceInformer cache.SharedIndexInformer,
	vmiTargetInformer cache.SharedIndexInformer,
	domainInformer cache.SharedInformer,
	gracefulShutdownInformer cache.SharedIndexInformer,
	watchdogTimeoutSeconds int,
	maxDevices int,
	clusterConfig *virtconfig.ClusterConfig,
	podIsolationDetector isolation.PodIsolationDetector,
	migrationProxy migrationproxy.ProxyManager,
	capabilities *nodelabellerapi.Capabilities,
	hostCpuModel string,
) *VirtualMachineController

func (*VirtualMachineController) Execute

func (c *VirtualMachineController) Execute() bool

func (*VirtualMachineController) Run

func (c *VirtualMachineController) Run(threadiness int, stopCh chan struct{})