services

Documentation

Index

• func UnfinishedVMPodSelector(vm *corev1.VirtualMachine) metav1.ListOptions
• type MockVMService
  • func NewMockVMService(ctrl *gomock.Controller) *MockVMService
  • func (_m *MockVMService) CreateMigrationTargetPod(migration *v10.Migration, vm *v10.VirtualMachine) error
  • func (_m *MockVMService) DeleteMigrationTargetPods(_param0 *v10.Migration) error
  • func (_m *MockVMService) DeleteVMPod(_param0 *v10.VirtualMachine) error
  • func (_m *MockVMService) EXPECT() *_MockVMServiceRecorder
  • func (_m *MockVMService) FetchMigration(namespace string, migrationName string) (*v10.Migration, bool, error)
  • func (_m *MockVMService) FetchVM(namespace string, vmName string) (*v10.VirtualMachine, bool, error)
  • func (_m *MockVMService) GetMigrationJob(migration *v10.Migration) (*v1.Pod, bool, error)
  • func (_m *MockVMService) GetRunningMigrationPods(_param0 *v10.Migration) (*v1.PodList, error)
  • func (_m *MockVMService) GetRunningVMPods(_param0 *v10.VirtualMachine) (*v1.PodList, error)
  • func (_m *MockVMService) PutVm(vm *v10.VirtualMachine) (*v10.VirtualMachine, error)
  • func (_m *MockVMService) StartMigration(migration *v10.Migration, vm *v10.VirtualMachine, sourceNode *v1.Node, ...) error
  • func (_m *MockVMService) StartVMPod(_param0 *v10.VirtualMachine) error
  • func (_m *MockVMService) UpdateMigration(migration *v10.Migration) error
• type TemplateService
  • func NewTemplateService(launcherImage string, migratorImage string, socketDir string) (TemplateService, error)
• type VMService
  • func NewVMService(KubeCli kubecli.KubevirtClient, RestClient *rest.RESTClient, ...) VMService

Functions

func UnfinishedVMPodSelector

func UnfinishedVMPodSelector(vm *corev1.VirtualMachine) metav1.ListOptions

Types

type MockVMService

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

Mock of VMService interface

func NewMockVMService

func NewMockVMService(ctrl *gomock.Controller) *MockVMService

func (*MockVMService) CreateMigrationTargetPod

func (_m *MockVMService) CreateMigrationTargetPod(migration *v10.Migration, vm *v10.VirtualMachine) error

func (*MockVMService) DeleteMigrationTargetPods

func (_m *MockVMService) DeleteMigrationTargetPods(_param0 *v10.Migration) error

func (*MockVMService) DeleteVMPod

func (_m *MockVMService) DeleteVMPod(_param0 *v10.VirtualMachine) error

func (*MockVMService) EXPECT

func (_m *MockVMService) EXPECT() *_MockVMServiceRecorder

func (*MockVMService) FetchMigration

func (_m *MockVMService) FetchMigration(namespace string, migrationName string) (*v10.Migration, bool, error)

func (*MockVMService) FetchVM

func (_m *MockVMService) FetchVM(namespace string, vmName string) (*v10.VirtualMachine, bool, error)

func (*MockVMService) GetMigrationJob

func (_m *MockVMService) GetMigrationJob(migration *v10.Migration) (*v1.Pod, bool, error)

func (*MockVMService) GetRunningMigrationPods

func (_m *MockVMService) GetRunningMigrationPods(_param0 *v10.Migration) (*v1.PodList, error)

func (*MockVMService) GetRunningVMPods

func (_m *MockVMService) GetRunningVMPods(_param0 *v10.VirtualMachine) (*v1.PodList, error)

func (*MockVMService) PutVm

func (_m *MockVMService) PutVm(vm *v10.VirtualMachine) (*v10.VirtualMachine, error)

func (*MockVMService) StartMigration

func (_m *MockVMService) StartMigration(migration *v10.Migration, vm *v10.VirtualMachine, sourceNode *v1.Node, targetNode *v1.Node, targetPod *v1.Pod) error

func (*MockVMService) StartVMPod

func (_m *MockVMService) StartVMPod(_param0 *v10.VirtualMachine) error

func (*MockVMService) UpdateMigration

func (_m *MockVMService) UpdateMigration(migration *v10.Migration) error

type TemplateService

type TemplateService interface {
	RenderLaunchManifest(*v1.VirtualMachine) (*kubev1.Pod, error)
	RenderMigrationJob(*v1.VirtualMachine, *kubev1.Node, *kubev1.Node, *kubev1.Pod, *v1.MigrationHostInfo) (*kubev1.Pod, error)
}

func NewTemplateService

func NewTemplateService(launcherImage string, migratorImage string, socketDir string) (TemplateService, error)

type VMService

type VMService interface {
	StartVMPod(*corev1.VirtualMachine) error
	DeleteVMPod(*corev1.VirtualMachine) error
	GetRunningVMPods(*corev1.VirtualMachine) (*v1.PodList, error)
	DeleteMigrationTargetPods(*corev1.Migration) error
	GetRunningMigrationPods(*corev1.Migration) (*v1.PodList, error)
	CreateMigrationTargetPod(migration *corev1.Migration, vm *corev1.VirtualMachine) error
	UpdateMigration(migration *corev1.Migration) error
	FetchVM(namespace string, vmName string) (*corev1.VirtualMachine, bool, error)
	FetchMigration(namespace string, migrationName string) (*corev1.Migration, bool, error)
	StartMigration(migration *corev1.Migration, vm *corev1.VirtualMachine, sourceNode *v1.Node, targetNode *v1.Node, targetPod *v1.Pod) error
	GetMigrationJob(migration *corev1.Migration) (*v1.Pod, bool, error)
	PutVm(vm *corev1.VirtualMachine) (*corev1.VirtualMachine, error)
}

func NewVMService

func NewVMService(KubeCli kubecli.KubevirtClient,
	RestClient *rest.RESTClient,
	TemplateService TemplateService) VMService