virthandler

Documentation

Index

• func MapPersistentVolumes(vm *v1.VM, restClient cache.Getter, namespace string) (*v1.VM, error)
• func NewDomainController(vmQueue workqueue.RateLimitingInterface, vmStore cache.Store, ...) (cache.Store, *kubecli.Controller)
• func NewDomainDispatch(vmQueue workqueue.RateLimitingInterface, vmStore cache.Store, ...) kubecli.ControllerDispatch
• func NewVMController(lw cache.ListerWatcher, domainManager virtwrap.DomainManager, ...) (cache.Store, workqueue.RateLimitingInterface, *kubecli.Controller)
• func NewVMHandlerDispatch(domainManager virtwrap.DomainManager, recorder record.EventRecorder, ...) kubecli.ControllerDispatch
• type DomainDispatch
  • func (d *DomainDispatch) Execute(indexer cache.Store, queue workqueue.RateLimitingInterface, key interface{})
• type VMHandlerDispatch
  • func (d *VMHandlerDispatch) Execute(store cache.Store, queue workqueue.RateLimitingInterface, key interface{})

Functions

func MapPersistentVolumes

func MapPersistentVolumes(vm *v1.VM, restClient cache.Getter, namespace string) (*v1.VM, error)

Almost everything in the VM object maps exactly to its domain counterpart One exception is persistent volume claims. This function looks up each PV and inserts a corrected disk entry into the VM's device map.

func NewDomainController

func NewDomainController(vmQueue workqueue.RateLimitingInterface, vmStore cache.Store, informer cache.SharedInformer, restClient rest.RESTClient, recorder record.EventRecorder) (cache.Store, *kubecli.Controller)

TODO: Define the exact scope of this controller. For now it looks like we should use domain events to detect unexpected domain changes like crashes or vms going into pause mode because of resource shortage or cut off connections to storage.

func NewDomainDispatch

func NewDomainDispatch(vmQueue workqueue.RateLimitingInterface, vmStore cache.Store, restClient rest.RESTClient, recorder record.EventRecorder) kubecli.ControllerDispatch

func NewVMController

func NewVMController(lw cache.ListerWatcher, domainManager virtwrap.DomainManager, recorder record.EventRecorder, restClient rest.RESTClient, clientset *kubernetes.Clientset, host string) (cache.Store, workqueue.RateLimitingInterface, *kubecli.Controller)

func NewVMHandlerDispatch

func NewVMHandlerDispatch(domainManager virtwrap.DomainManager, recorder record.EventRecorder, restClient *rest.RESTClient, clientset *kubernetes.Clientset, host string) kubecli.ControllerDispatch

Types

type DomainDispatch

type DomainDispatch struct {
	// contains filtered or unexported fields
}

func (*DomainDispatch) Execute

func (d *DomainDispatch) Execute(indexer cache.Store, queue workqueue.RateLimitingInterface, key interface{})

type VMHandlerDispatch

type VMHandlerDispatch struct {
	// contains filtered or unexported fields
}

func (*VMHandlerDispatch) Execute

func (d *VMHandlerDispatch) Execute(store cache.Store, queue workqueue.RateLimitingInterface, key interface{})