virthandler

Documentation

Index

• func MapVolumes(vm *v1.VirtualMachine, clientset kubecli.KubevirtClient, namespace string) (*v1.VirtualMachine, error)
• type VirtualMachineController
  • func NewController(domainManager virtwrap.DomainManager, recorder record.EventRecorder, ...) *VirtualMachineController
  • func (c *VirtualMachineController) Execute() bool
  • func (c *VirtualMachineController) Run(threadiness int, stopCh chan struct{})

Functions

func MapVolumes

func MapVolumes(vm *v1.VirtualMachine, clientset kubecli.KubevirtClient, namespace string) (*v1.VirtualMachine, error)

Look up Volumes and PVs and translate them into their primitives (only supports ISCSI and PVs right now)

Types

type VirtualMachineController

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

func NewController

func NewController(
	domainManager virtwrap.DomainManager,
	recorder record.EventRecorder,
	clientset kubecli.KubevirtClient,
	host string,
	configDiskClient configdisk.ConfigDiskClient,
	virtShareDir string,
	watchdogTimeoutSeconds int,
	vmInformer cache.SharedIndexInformer,
	domainInformer cache.SharedInformer,
	watchdogInformer cache.SharedIndexInformer,
	gracefulShutdownInformer cache.SharedIndexInformer,
) *VirtualMachineController

func (*VirtualMachineController) Execute

func (c *VirtualMachineController) Execute() bool

func (*VirtualMachineController) Run

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