feat(vmop): add operation to migrate vm

api/client/kubeclient/client.go

@@ -82,6 +82,7 @@ type VirtualMachineInterface interface {
 	PortForward(name string, opts v1alpha2.VirtualMachinePortForward) (StreamInterface, error)
 	Freeze(ctx context.Context, name string, opts v1alpha2.VirtualMachineFreeze) error
 	Unfreeze(ctx context.Context, name string) error
+	Migrate(ctx context.Context, name string, opts v1alpha2.VirtualMachineMigrate) error
 }
 
 type client struct {

api/client/kubeclient/request.go

@@ -28,7 +28,7 @@ import (
 	"k8s.io/client-go/rest"
 )
 
-const operationURLTpl = "/apis/subresources.virtualization.deckhouse.io/v1alpha2/namespaces/%s/%s/%s/%s"
+const subresourceURLTpl = "/apis/subresources.virtualization.deckhouse.io/v1alpha2/namespaces/%s/%s/%s/%s"
 
 func RequestFromConfig(config *rest.Config, resource, name, namespace, subresource string,
 	queryParams url.Values) (*http.Request, error) {
@@ -48,7 +48,7 @@ func RequestFromConfig(config *rest.Config, resource, name, namespace, subresour
 
 	u.Path = path.Join(
 		u.Path,
-		fmt.Sprintf(operationURLTpl, namespace, resource, name, subresource),
+		fmt.Sprintf(subresourceURLTpl, namespace, resource, name, subresource),
 	)
 	if len(queryParams) > 0 {
 		u.RawQuery = queryParams.Encode()

api/client/kubeclient/vm.go

@@ -112,7 +112,7 @@ func (v vm) PortForward(name string, opts v1alpha2.VirtualMachinePortForward) (S
 }
 
 func (v vm) Freeze(ctx context.Context, name string, opts v1alpha2.VirtualMachineFreeze) error {
-	path := fmt.Sprintf(operationURLTpl, v.namespace, v.resource, name, "freeze")
+	path := fmt.Sprintf(subresourceURLTpl, v.namespace, v.resource, name, "freeze")
 
 	unfreezeTimeout := virtv1.FreezeUnfreezeTimeout{
 		UnfreezeTimeout: &metav1.Duration{},
@@ -127,21 +127,25 @@ func (v vm) Freeze(ctx context.Context, name string, opts v1alpha2.VirtualMachin
 		return err
 	}
 
-	err = v.restClient.Put().AbsPath(path).Body(body).Do(ctx).Error()
-	if err != nil {
-		return err
-	}
-
-	return nil
+	return v.restClient.Put().AbsPath(path).Body(body).Do(ctx).Error()
 }
 
 func (v vm) Unfreeze(ctx context.Context, name string) error {
-	path := fmt.Sprintf(operationURLTpl, v.namespace, v.resource, name, "unfreeze")
+	path := fmt.Sprintf(subresourceURLTpl, v.namespace, v.resource, name, "unfreeze")
+
+	return v.restClient.Put().AbsPath(path).Do(ctx).Error()
+}
+
+func (v vm) Migrate(ctx context.Context, name string, opts v1alpha2.VirtualMachineMigrate) error {
+	path := fmt.Sprintf(subresourceURLTpl, v.namespace, v.resource, name, "migrate")
 
-	err := v.restClient.Put().AbsPath(path).Do(ctx).Error()
+	migrateOpts := virtv1.MigrateOptions{
+		DryRun: opts.DryRun,
+	}
+
+	body, err := json.Marshal(&migrateOpts)
 	if err != nil {
 		return err
 	}
-
-	return nil
+	return v.restClient.Put().AbsPath(path).Body(body).Do(ctx).Error()
 }

api/core/v1alpha2/virtual_machine_operation.go

@@ -23,7 +23,15 @@ const (
 	VMOPResource = "virtualmachineoperations"
 )
 
-// VirtualMachineOperation is operation performed on the VirtualMachine.
+// VirtualMachineOperation resource provides the ability to declaratively manage state changes of virtual machines.
+// +kubebuilder:object:root=true
+// +kubebuilder:metadata:labels={heritage=deckhouse,module=virtualization}
+// +kubebuilder:subresource:status
+// +kubebuilder:resource:categories={virtualization,all},scope=Namespaced,shortName={vmop,vmops},singular=virtualmachineoperation
+// +kubebuilder:printcolumn:name="Phase",type="string",JSONPath=".status.phase",description="VirtualMachineOperation phase."
+// +kubebuilder:printcolumn:name="Type",type="string",JSONPath=".spec.type",description="VirtualMachineOperation type."
+// +kubebuilder:printcolumn:name="VirtualMachine",type="string",JSONPath=".spec.virtualMachineName",description="VirtualMachine name."
+// +kubebuilder:printcolumn:name="Age",type="date",JSONPath=".metadata.creationTimestamp",description="Time of creation resource."
 // +genclient
 // +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
 type VirtualMachineOperation struct {
@@ -34,16 +42,22 @@ type VirtualMachineOperation struct {
 	Status VirtualMachineOperationStatus `json:"status,omitempty"`
 }
 
+// +kubebuilder:validation:XValidation:rule="self.type == 'Start' ? !has(self.force) || !self.force : true",message="The `Start` operation cannot be performed forcibly."
+// +kubebuilder:validation:XValidation:rule="self.type == 'Migrate' ? !has(self.force) || !self.force : true",message="The `Migrate` operation cannot be performed forcibly."
 type VirtualMachineOperationSpec struct {
-	Type           VMOPType `json:"type"`
-	VirtualMachine string   `json:"virtualMachineName"`
-	Force          bool     `json:"force,omitempty"`
+	Type VMOPType `json:"type"`
+	// The name of the virtual machine for which the operation is performed.
+	VirtualMachine string `json:"virtualMachineName"`
+	// Force the execution of the operation. Applies only for Restart and Stop. In this case, the action on the virtual machine is performed immediately.
+	Force bool `json:"force,omitempty"`
 }
 
 type VirtualMachineOperationStatus struct {
-	Phase              VMOPPhase          `json:"phase"`
-	Conditions         []metav1.Condition `json:"conditions,omitempty"`
-	ObservedGeneration int64              `json:"observedGeneration,omitempty"`
+	Phase VMOPPhase `json:"phase"`
+	// The latest detailed observations of the VirtualMachineOperation resource.
+	Conditions []metav1.Condition `json:"conditions,omitempty"`
+	//  The generation last processed by the controller.
+	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
 }
 
 // VirtualMachineOperationList contains a list of VirtualMachineOperation
@@ -54,6 +68,13 @@ type VirtualMachineOperationList struct {
 	Items           []VirtualMachineOperation `json:"items"`
 }
 
+// Represents the current phase of resource:
+// * Pending - the operation is queued for execution.
+// * InProgress - operation in progress.
+// * Completed - the operation was successful.
+// * Failed - the operation failed. Check conditions and events for more information.
+// * Terminating - the operation is deleted.
+// +kubebuilder:validation:Enum={Pending,InProgress,Completed,Failed,Terminating}
 type VMOPPhase string
 
 const (
@@ -64,10 +85,17 @@ const (
 	VMOPPhaseTerminating VMOPPhase = "Terminating"
 )
 
+// Type is operation over the virtualmachine:
+// * Start - start the virtualmachine.
+// * Stop - stop the virtualmachine.
+// * Restart - restart the virtualmachine.
+// * Migrate - migrate the virtualmachine.
+// +kubebuilder:validation:Enum={Restart,Start,Stop,Migrate}
 type VMOPType string
 
 const (
 	VMOPTypeRestart VMOPType = "Restart"
 	VMOPTypeStart   VMOPType = "Start"
 	VMOPTypeStop    VMOPType = "Stop"
+	VMOPTypeMigrate VMOPType = "Migrate"
 )

api/core/v1alpha2/vmopcondition/condition.go

@@ -61,6 +61,9 @@ const (
 	// ReasonStopInProgress is a ReasonCompleted indicating that the stop signal has been sent and stop is in progress.
 	ReasonStopInProgress ReasonCompleted = "StopInProgress"
 
+	// ReasonMigrationInProgress is a ReasonCompleted indicating that the migrate signal has been sent and stop is in progress.
+	ReasonMigrationInProgress ReasonCompleted = "MigrationInProgress"
+
 	// ReasonOperationFailed is a ReasonCompleted indicating that operation has failed.
 	ReasonOperationFailed ReasonCompleted = "OperationFailed"
 

api/scripts/update-codegen.sh

@@ -32,7 +32,9 @@ function source::settings {
   MODULE="github.com/deckhouse/virtualization/api"
   PREFIX_GROUP="virtualization.deckhouse.io_"
   # TODO: Temporary filter until all CRDs become auto-generated.
-  ALLOWED_RESOURCE_GEN_CRD=("VirtualMachineClass" "VirtualMachineBlockDeviceAttachment" "ExampleKind1" "ExampleKind2")
+  ALLOWED_RESOURCE_GEN_CRD=("VirtualMachineClass"
+                            "VirtualMachineBlockDeviceAttachment"
+                            "VirtualMachineOperation")
   source "${CODEGEN_PKG}/kube_codegen.sh"
 }
 

api/subresources/register.go

@@ -58,6 +58,7 @@ func addKnownTypes(scheme *runtime.Scheme) error {
 		&VirtualMachineRemoveVolume{},
 		&VirtualMachineFreeze{},
 		&VirtualMachineUnfreeze{},
+		&VirtualMachineMigrate{},
 		&virtv2.VirtualMachine{},
 		&virtv2.VirtualMachineList{},
 	)

api/subresources/types.go

@@ -78,3 +78,12 @@ type VirtualMachineFreeze struct {
 type VirtualMachineUnfreeze struct {
 	metav1.TypeMeta
 }
+
+// +genclient
+// +genclient:readonly
+// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
+
+type VirtualMachineMigrate struct {
+	metav1.TypeMeta
+	DryRun []string
+}

api/subresources/v1alpha2/register.go

@@ -58,6 +58,7 @@ func addKnownTypes(scheme *runtime.Scheme) error {
 		&VirtualMachineRemoveVolume{},
 		&VirtualMachineFreeze{},
 		&VirtualMachineUnfreeze{},
+		&VirtualMachineMigrate{},
 		&virtv2.VirtualMachine{},
 		&virtv2.VirtualMachineList{},
 	)

api/subresources/v1alpha2/types.go

@@ -85,3 +85,13 @@ type VirtualMachineFreeze struct {
 type VirtualMachineUnfreeze struct {
 	metav1.TypeMeta `json:",inline"`
 }
+
+// +genclient
+// +genclient:readonly
+// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
+// +k8s:conversion-gen:explicit-from=net/url.Values
+
+type VirtualMachineMigrate struct {
+	metav1.TypeMeta `json:",inline"`
+	DryRun          []string `json:"dryRun,omitempty"`
+}