Documentation ¶
Index ¶
- func Dequeue(s cache.Store, w workqueue.RateLimitingInterface, dispatch ControllerDispatch) bool
- func HandlePanic()
- func NewListWatchFromClient(c cache.Getter, resource string, namespace string, ...) *cache.ListWatch
- func NewResourceEventHandlerFuncsForFunc(f func(interface{})) cache.ResourceEventHandlerFuncs
- func NewResourceEventHandlerFuncsForWorkqueue(queue workqueue.RateLimitingInterface) cache.ResourceEventHandlerFuncs
- type Controller
- type ControllerDispatch
- type ControllerFunc
- type KubevirtClient
- type MigrationInterface
- type MockKubevirtClient
- func (_m *MockKubevirtClient) Admissionregistration() v1alpha1.AdmissionregistrationV1alpha1Interface
- func (_m *MockKubevirtClient) AdmissionregistrationV1alpha1() v1alpha1.AdmissionregistrationV1alpha1Interface
- func (_m *MockKubevirtClient) Apps() v1beta1.AppsV1beta1Interface
- func (_m *MockKubevirtClient) AppsV1beta1() v1beta1.AppsV1beta1Interface
- func (_m *MockKubevirtClient) Authentication() v10.AuthenticationV1Interface
- func (_m *MockKubevirtClient) AuthenticationV1() v10.AuthenticationV1Interface
- func (_m *MockKubevirtClient) AuthenticationV1beta1() v1beta10.AuthenticationV1beta1Interface
- func (_m *MockKubevirtClient) Authorization() v11.AuthorizationV1Interface
- func (_m *MockKubevirtClient) AuthorizationV1() v11.AuthorizationV1Interface
- func (_m *MockKubevirtClient) AuthorizationV1beta1() v1beta11.AuthorizationV1beta1Interface
- func (_m *MockKubevirtClient) Autoscaling() v12.AutoscalingV1Interface
- func (_m *MockKubevirtClient) AutoscalingV1() v12.AutoscalingV1Interface
- func (_m *MockKubevirtClient) AutoscalingV2alpha1() v2alpha1.AutoscalingV2alpha1Interface
- func (_m *MockKubevirtClient) Batch() v13.BatchV1Interface
- func (_m *MockKubevirtClient) BatchV1() v13.BatchV1Interface
- func (_m *MockKubevirtClient) BatchV2alpha1() v2alpha10.BatchV2alpha1Interface
- func (_m *MockKubevirtClient) Certificates() v1beta12.CertificatesV1beta1Interface
- func (_m *MockKubevirtClient) CertificatesV1beta1() v1beta12.CertificatesV1beta1Interface
- func (_m *MockKubevirtClient) Core() v14.CoreV1Interface
- func (_m *MockKubevirtClient) CoreV1() v14.CoreV1Interface
- func (_m *MockKubevirtClient) Discovery() discovery.DiscoveryInterface
- func (_m *MockKubevirtClient) EXPECT() *_MockKubevirtClientRecorder
- func (_m *MockKubevirtClient) Extensions() v1beta13.ExtensionsV1beta1Interface
- func (_m *MockKubevirtClient) ExtensionsV1beta1() v1beta13.ExtensionsV1beta1Interface
- func (_m *MockKubevirtClient) Migration(namespace string) MigrationInterface
- func (_m *MockKubevirtClient) Networking() v15.NetworkingV1Interface
- func (_m *MockKubevirtClient) NetworkingV1() v15.NetworkingV1Interface
- func (_m *MockKubevirtClient) Policy() v1beta14.PolicyV1beta1Interface
- func (_m *MockKubevirtClient) PolicyV1beta1() v1beta14.PolicyV1beta1Interface
- func (_m *MockKubevirtClient) Rbac() v1beta15.RbacV1beta1Interface
- func (_m *MockKubevirtClient) RbacV1alpha1() v1alpha10.RbacV1alpha1Interface
- func (_m *MockKubevirtClient) RbacV1beta1() v1beta15.RbacV1beta1Interface
- func (_m *MockKubevirtClient) RestClient() *rest.RESTClient
- func (_m *MockKubevirtClient) Settings() v1alpha11.SettingsV1alpha1Interface
- func (_m *MockKubevirtClient) SettingsV1alpha1() v1alpha11.SettingsV1alpha1Interface
- func (_m *MockKubevirtClient) Storage() v16.StorageV1Interface
- func (_m *MockKubevirtClient) StorageV1() v16.StorageV1Interface
- func (_m *MockKubevirtClient) StorageV1beta1() v1beta16.StorageV1beta1Interface
- func (_m *MockKubevirtClient) VM(namespace string) VMInterface
- type MockMigrationInterface
- func (_m *MockMigrationInterface) Create(_param0 *v17.Migration) (*v17.Migration, error)
- func (_m *MockMigrationInterface) Delete(name string, options *v1.DeleteOptions) error
- func (_m *MockMigrationInterface) EXPECT() *_MockMigrationInterfaceRecorder
- func (_m *MockMigrationInterface) Get(name string, options v1.GetOptions) (*v17.Migration, error)
- func (_m *MockMigrationInterface) List(opts v1.ListOptions) (*v17.MigrationList, error)
- func (_m *MockMigrationInterface) Update(_param0 *v17.Migration) (*v17.Migration, error)
- type MockVMInterface
- func (_m *MockVMInterface) Create(_param0 *v17.VM) (*v17.VM, error)
- func (_m *MockVMInterface) Delete(name string, options *v1.DeleteOptions) error
- func (_m *MockVMInterface) EXPECT() *_MockVMInterfaceRecorder
- func (_m *MockVMInterface) Get(name string, options v1.GetOptions) (*v17.VM, error)
- func (_m *MockVMInterface) List(opts v1.ListOptions) (*v17.VMList, error)
- func (_m *MockVMInterface) Update(_param0 *v17.VM) (*v17.VM, error)
- type VMInterface
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Dequeue ¶
func Dequeue(s cache.Store, w workqueue.RateLimitingInterface, dispatch ControllerDispatch) bool
func HandlePanic ¶
func HandlePanic()
func NewListWatchFromClient ¶
func NewListWatchFromClient(c cache.Getter, resource string, namespace string, fieldSelector fields.Selector, labelSelector labels.Selector) *cache.ListWatch
NewListWatchFromClient creates a new ListWatch from the specified client, resource, namespace and field selector.
func NewResourceEventHandlerFuncsForFunc ¶
func NewResourceEventHandlerFuncsForFunc(f func(interface{})) cache.ResourceEventHandlerFuncs
func NewResourceEventHandlerFuncsForWorkqueue ¶
func NewResourceEventHandlerFuncsForWorkqueue(queue workqueue.RateLimitingInterface) cache.ResourceEventHandlerFuncs
Types ¶
type Controller ¶
type Controller struct {
// contains filtered or unexported fields
}
func NewController ¶
func NewController(lw cache.ListerWatcher, queue workqueue.RateLimitingInterface, objType runtime.Object, dispatch ControllerDispatch) (cache.Store, *Controller)
func NewControllerFromInformer ¶
func NewControllerFromInformer(indexer cache.Store, informer cache.Controller, queue workqueue.RateLimitingInterface, dispatch ControllerDispatch) (cache.Store, *Controller)
func (*Controller) Run ¶
func (c *Controller) Run(threadiness int, stopCh chan struct{})
func (*Controller) ShutDownQueue ¶
func (c *Controller) ShutDownQueue()
Shut down the embedded queue. After the shutdown was issued, all items already in the queue will be processed but no new items will be accepted. It is possible to wait via #WaitUntilDone() until the last item was processed.
func (*Controller) StartInformer ¶
func (c *Controller) StartInformer(stopCh chan struct{})
func (*Controller) WaitForSync ¶
func (c *Controller) WaitForSync(stopCh chan struct{})
type ControllerDispatch ¶
type ControllerDispatch interface {
Execute(cache.Store, workqueue.RateLimitingInterface, interface{})
}
type ControllerFunc ¶
type ControllerFunc func(cache.Store, workqueue.RateLimitingInterface, interface{})
type KubevirtClient ¶
type KubevirtClient interface { VM(namespace string) VMInterface Migration(namespace string) MigrationInterface RestClient() *rest.RESTClient kubernetes.Interface }
func GetKubevirtClient ¶
func GetKubevirtClient() (KubevirtClient, error)
func GetKubevirtClientFromFlags ¶
func GetKubevirtClientFromFlags(master string, kubeconfig string) (KubevirtClient, error)
type MigrationInterface ¶
type MigrationInterface interface { Get(name string, options k8smetav1.GetOptions) (*v1.Migration, error) List(opts k8smetav1.ListOptions) (*v1.MigrationList, error) Create(*v1.Migration) (*v1.Migration, error) Update(*v1.Migration) (*v1.Migration, error) Delete(name string, options *k8smetav1.DeleteOptions) error }
type MockKubevirtClient ¶
type MockKubevirtClient struct {
// contains filtered or unexported fields
}
Mock of KubevirtClient interface
func NewMockKubevirtClient ¶
func NewMockKubevirtClient(ctrl *gomock.Controller) *MockKubevirtClient
func (*MockKubevirtClient) Admissionregistration ¶
func (_m *MockKubevirtClient) Admissionregistration() v1alpha1.AdmissionregistrationV1alpha1Interface
func (*MockKubevirtClient) AdmissionregistrationV1alpha1 ¶
func (_m *MockKubevirtClient) AdmissionregistrationV1alpha1() v1alpha1.AdmissionregistrationV1alpha1Interface
func (*MockKubevirtClient) Apps ¶
func (_m *MockKubevirtClient) Apps() v1beta1.AppsV1beta1Interface
func (*MockKubevirtClient) AppsV1beta1 ¶
func (_m *MockKubevirtClient) AppsV1beta1() v1beta1.AppsV1beta1Interface
func (*MockKubevirtClient) Authentication ¶
func (_m *MockKubevirtClient) Authentication() v10.AuthenticationV1Interface
func (*MockKubevirtClient) AuthenticationV1 ¶
func (_m *MockKubevirtClient) AuthenticationV1() v10.AuthenticationV1Interface
func (*MockKubevirtClient) AuthenticationV1beta1 ¶
func (_m *MockKubevirtClient) AuthenticationV1beta1() v1beta10.AuthenticationV1beta1Interface
func (*MockKubevirtClient) Authorization ¶
func (_m *MockKubevirtClient) Authorization() v11.AuthorizationV1Interface
func (*MockKubevirtClient) AuthorizationV1 ¶
func (_m *MockKubevirtClient) AuthorizationV1() v11.AuthorizationV1Interface
func (*MockKubevirtClient) AuthorizationV1beta1 ¶
func (_m *MockKubevirtClient) AuthorizationV1beta1() v1beta11.AuthorizationV1beta1Interface
func (*MockKubevirtClient) Autoscaling ¶
func (_m *MockKubevirtClient) Autoscaling() v12.AutoscalingV1Interface
func (*MockKubevirtClient) AutoscalingV1 ¶
func (_m *MockKubevirtClient) AutoscalingV1() v12.AutoscalingV1Interface
func (*MockKubevirtClient) AutoscalingV2alpha1 ¶
func (_m *MockKubevirtClient) AutoscalingV2alpha1() v2alpha1.AutoscalingV2alpha1Interface
func (*MockKubevirtClient) Batch ¶
func (_m *MockKubevirtClient) Batch() v13.BatchV1Interface
func (*MockKubevirtClient) BatchV1 ¶
func (_m *MockKubevirtClient) BatchV1() v13.BatchV1Interface
func (*MockKubevirtClient) BatchV2alpha1 ¶
func (_m *MockKubevirtClient) BatchV2alpha1() v2alpha10.BatchV2alpha1Interface
func (*MockKubevirtClient) Certificates ¶
func (_m *MockKubevirtClient) Certificates() v1beta12.CertificatesV1beta1Interface
func (*MockKubevirtClient) CertificatesV1beta1 ¶
func (_m *MockKubevirtClient) CertificatesV1beta1() v1beta12.CertificatesV1beta1Interface
func (*MockKubevirtClient) Core ¶
func (_m *MockKubevirtClient) Core() v14.CoreV1Interface
func (*MockKubevirtClient) CoreV1 ¶
func (_m *MockKubevirtClient) CoreV1() v14.CoreV1Interface
func (*MockKubevirtClient) Discovery ¶
func (_m *MockKubevirtClient) Discovery() discovery.DiscoveryInterface
func (*MockKubevirtClient) EXPECT ¶
func (_m *MockKubevirtClient) EXPECT() *_MockKubevirtClientRecorder
func (*MockKubevirtClient) Extensions ¶
func (_m *MockKubevirtClient) Extensions() v1beta13.ExtensionsV1beta1Interface
func (*MockKubevirtClient) ExtensionsV1beta1 ¶
func (_m *MockKubevirtClient) ExtensionsV1beta1() v1beta13.ExtensionsV1beta1Interface
func (*MockKubevirtClient) Migration ¶
func (_m *MockKubevirtClient) Migration(namespace string) MigrationInterface
func (*MockKubevirtClient) Networking ¶
func (_m *MockKubevirtClient) Networking() v15.NetworkingV1Interface
func (*MockKubevirtClient) NetworkingV1 ¶
func (_m *MockKubevirtClient) NetworkingV1() v15.NetworkingV1Interface
func (*MockKubevirtClient) Policy ¶
func (_m *MockKubevirtClient) Policy() v1beta14.PolicyV1beta1Interface
func (*MockKubevirtClient) PolicyV1beta1 ¶
func (_m *MockKubevirtClient) PolicyV1beta1() v1beta14.PolicyV1beta1Interface
func (*MockKubevirtClient) Rbac ¶
func (_m *MockKubevirtClient) Rbac() v1beta15.RbacV1beta1Interface
func (*MockKubevirtClient) RbacV1alpha1 ¶
func (_m *MockKubevirtClient) RbacV1alpha1() v1alpha10.RbacV1alpha1Interface
func (*MockKubevirtClient) RbacV1beta1 ¶
func (_m *MockKubevirtClient) RbacV1beta1() v1beta15.RbacV1beta1Interface
func (*MockKubevirtClient) RestClient ¶
func (_m *MockKubevirtClient) RestClient() *rest.RESTClient
func (*MockKubevirtClient) Settings ¶
func (_m *MockKubevirtClient) Settings() v1alpha11.SettingsV1alpha1Interface
func (*MockKubevirtClient) SettingsV1alpha1 ¶
func (_m *MockKubevirtClient) SettingsV1alpha1() v1alpha11.SettingsV1alpha1Interface
func (*MockKubevirtClient) Storage ¶
func (_m *MockKubevirtClient) Storage() v16.StorageV1Interface
func (*MockKubevirtClient) StorageV1 ¶
func (_m *MockKubevirtClient) StorageV1() v16.StorageV1Interface
func (*MockKubevirtClient) StorageV1beta1 ¶
func (_m *MockKubevirtClient) StorageV1beta1() v1beta16.StorageV1beta1Interface
func (*MockKubevirtClient) VM ¶
func (_m *MockKubevirtClient) VM(namespace string) VMInterface
type MockMigrationInterface ¶
type MockMigrationInterface struct {
// contains filtered or unexported fields
}
Mock of MigrationInterface interface
func NewMockMigrationInterface ¶
func NewMockMigrationInterface(ctrl *gomock.Controller) *MockMigrationInterface
func (*MockMigrationInterface) Delete ¶
func (_m *MockMigrationInterface) Delete(name string, options *v1.DeleteOptions) error
func (*MockMigrationInterface) EXPECT ¶
func (_m *MockMigrationInterface) EXPECT() *_MockMigrationInterfaceRecorder
func (*MockMigrationInterface) Get ¶
func (_m *MockMigrationInterface) Get(name string, options v1.GetOptions) (*v17.Migration, error)
func (*MockMigrationInterface) List ¶
func (_m *MockMigrationInterface) List(opts v1.ListOptions) (*v17.MigrationList, error)
type MockVMInterface ¶
type MockVMInterface struct {
// contains filtered or unexported fields
}
Mock of VMInterface interface
func NewMockVMInterface ¶
func NewMockVMInterface(ctrl *gomock.Controller) *MockVMInterface
func (*MockVMInterface) Delete ¶
func (_m *MockVMInterface) Delete(name string, options *v1.DeleteOptions) error
func (*MockVMInterface) EXPECT ¶
func (_m *MockVMInterface) EXPECT() *_MockVMInterfaceRecorder
func (*MockVMInterface) Get ¶
func (_m *MockVMInterface) Get(name string, options v1.GetOptions) (*v17.VM, error)
func (*MockVMInterface) List ¶
func (_m *MockVMInterface) List(opts v1.ListOptions) (*v17.VMList, error)
Click to show internal directories.
Click to hide internal directories.