kubecli

package
v0.0.1-alpha.6 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 21, 2017 License: Apache-2.0 Imports: 40 Imported by: 0

Documentation

Index

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) Create 

func (_m *MockMigrationInterface) Create(_param0 *v17.Migration) (*v17.Migration, error)

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)

func (*MockMigrationInterface) Update 

func (_m *MockMigrationInterface) Update(_param0 *v17.Migration) (*v17.Migration, 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) Create 

func (_m *MockVMInterface) Create(_param0 *v17.VM) (*v17.VM, error)

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)

func (*MockVMInterface) Update 

func (_m *MockVMInterface) Update(_param0 *v17.VM) (*v17.VM, error)

type VMInterface 

type VMInterface interface {
	Get(name string, options k8smetav1.GetOptions) (*v1.VM, error)
	List(opts k8smetav1.ListOptions) (*v1.VMList, error)
	Create(*v1.VM) (*v1.VM, error)
	Update(*v1.VM) (*v1.VM, error)
	Delete(name string, options *k8smetav1.DeleteOptions) error
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.