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
- type VMHandlerDispatch
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func MapPersistentVolumes ¶
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{})
Click to show internal directories.
Click to hide internal directories.