init clone

Signed-off-by: Daniil Antoshin <[email protected]>

Author: danilrwx

api/core/v1alpha2/virtual_machine_operation.go

@@ -46,6 +46,7 @@ type VirtualMachineOperation struct {
 // +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."
 // +kubebuilder:validation:XValidation:rule="self.type == 'Restore' ? has(self.restore) : true",message="Restore requires restore field."
+// +kubebuilder:validation:XValidation:rule="self.type == 'Clone' ? has(self.clone) : true",message="Clone requires clone field."
 type VirtualMachineOperationSpec struct {
 	Type VMOPType `json:"type"`
 	// Name of the virtual machine the operation is performed for.
@@ -57,6 +58,8 @@ type VirtualMachineOperationSpec struct {
 	Force *bool `json:"force,omitempty"`
 	// Restore defines the restore operation.
 	Restore *VirtualMachineOperationRestoreSpec `json:"restore,omitempty"`
+	// Clone defines the clone operation.
+	Clone *VirtualMachineOperationCloneSpec `json:"clone,omitempty"`
 }
 
 // VirtualMachineOperationRestoreSpec defines the restore operation.
@@ -66,6 +69,14 @@ type VirtualMachineOperationRestoreSpec struct {
 	VirtualMachineSnapshotName string `json:"virtualMachineSnapshotName"`
 }
 
+// VirtualMachineOperationCloneSpec defines the clone operation.
+type VirtualMachineOperationCloneSpec struct {
+	Mode VMOPRestoreMode `json:"mode"`
+	// NameReplacement defines rules for renaming resources during cloning.
+	// Note: This references the NameReplacement type from virtual_machine_restore.go
+	NameReplacement []NameReplacement `json:"nameReplacement,omitempty"`
+}
+
 // VMOPRestoreMode defines the kind of the restore operation.
 // * `DryRun`: DryRun run without any changes. Compatibility shows in status.
 // * `Strict`: Strict restore as is in the snapshot.
@@ -160,7 +171,8 @@ const (
 // * `Migrate` (deprecated): Migrate the virtual machine to another node where it can be started.
 // * `Evict`: Migrate the virtual machine to another node where it can be started.
 // * `Restore`: Restore the virtual machine from a snapshot.
-// +kubebuilder:validation:Enum={Restart,Start,Stop,Migrate,Evict,Restore}
+// * `Clone`: Clone the virtual machine to a new virtual machine.
+// +kubebuilder:validation:Enum={Restart,Start,Stop,Migrate,Evict,Restore,Clone}
 type VMOPType string
 
 const (
@@ -170,4 +182,5 @@ const (
 	VMOPTypeMigrate VMOPType = "Migrate"
 	VMOPTypeEvict   VMOPType = "Evict"
 	VMOPTypeRestore VMOPType = "Restore"
+	VMOPTypeClone   VMOPType = "Clone"
 )

api/core/v1alpha2/vmopcondition/condition.go

@@ -32,6 +32,9 @@ const (
 	// TypeRestoreCompleted is a type for condition that indicates success of restore.
 	TypeRestoreCompleted Type = "RestoreCompleted"
 
+	// TypeCloneCompleted is a type for condition that indicates success of clone.
+	TypeCloneCompleted Type = "CloneCompleted"
+
 	// TypeMaintenanceMode is a type for condition that indicates VMOP has put VM in maintenance mode.
 	TypeMaintenanceMode Type = "MaintenanceMode"
 )
@@ -71,6 +74,9 @@ const (
 	// ReasonRestoreInProgress is a ReasonCompleted indicating that the restore operation is in progress.
 	ReasonRestoreInProgress ReasonCompleted = "RestoreInProgress"
 
+	// ReasonCloneInProgress is a ReasonCompleted indicating that the clone operation is in progress.
+	ReasonCloneInProgress ReasonCompleted = "CloneInProgress"
+
 	// ReasonMigrationPending is a ReasonCompleted indicating that the migration process has been initiated but not yet started.
 	ReasonMigrationPending ReasonCompleted = "MigrationPending"
 
@@ -117,6 +123,24 @@ const (
 	ReasonRestoreOperationFailed ReasonRestoreCompleted = "RestoreFailed"
 )
 
+// ReasonCloneCompleted represents specific reasons for the 'CloneCompleted' condition type.
+type ReasonCloneCompleted string
+
+func (r ReasonCloneCompleted) String() string {
+	return string(r)
+}
+
+const (
+	// ReasonCloneOperationInProgress is a ReasonCloneCompleted indicating that the clone operation is in progress.
+	ReasonCloneOperationInProgress ReasonCloneCompleted = "CloneInProgress"
+
+	// ReasonCloneOperationCompleted is a ReasonCloneCompleted indicating that the clone operation has completed successfully.
+	ReasonCloneOperationCompleted ReasonCloneCompleted = "CloneCompleted"
+
+	// ReasonCloneOperationFailed is a ReasonCloneCompleted indicating that clone operation has failed.
+	ReasonCloneOperationFailed ReasonCloneCompleted = "CloneFailed"
+)
+
 // ReasonCompleted represents specific reasons for the 'SignalSent' condition type.
 type ReasonSignalSent string
 

api/core/v1alpha2/zz_generated.deepcopy.go

@@ -66,6 +66,52 @@ spec:
               type: object
             spec:
               properties:
+                clone:
+                  description: Clone defines the clone operation.
+                  properties:
+                    mode:
+                      description: |-
+                        VMOPRestoreMode defines the kind of the restore operation.
+                        * `DryRun`: DryRun run without any changes. Compatibility shows in status.
+                        * `Strict`: Strict restore as is in the snapshot.
+                        * `BestEffort`: BestEffort restore without deleted external missing dependencies.
+                      enum:
+                        - DryRun
+                        - Strict
+                        - BestEffort
+                      type: string
+                    nameReplacement:
+                      description: |-
+                        NameReplacement defines rules for renaming resources during cloning.
+                        Note: This references the NameReplacement type from virtual_machine_restore.go
+                      items:
+                        description:
+                          NameReplacement represents a rule for redefining
+                          the virtual machine resource names.
+                        properties:
+                          from:
+                            description: Selector to choose resources for name replacement.
+                            properties:
+                              kind:
+                                description: Kind of a resource to rename.
+                                type: string
+                              name:
+                                description: Current name of a resource to rename.
+                                type: string
+                            required:
+                              - name
+                            type: object
+                          to:
+                            description: New resource name.
+                            type: string
+                        required:
+                          - from
+                          - to
+                        type: object
+                      type: array
+                  required:
+                    - mode
+                  type: object
                 force:
                   description: |-
                     Force execution of an operation.
@@ -105,13 +151,15 @@ spec:
                     * `Migrate` (deprecated): Migrate the virtual machine to another node where it can be started.
                     * `Evict`: Migrate the virtual machine to another node where it can be started.
                     * `Restore`: Restore the virtual machine from a snapshot.
+                    * `Clone`: Clone the virtual machine to a new virtual machine.
                   enum:
                     - Restart
                     - Start
                     - Stop
                     - Migrate
                     - Evict
                     - Restore
+                    - Clone
                   type: string
                 virtualMachineName:
                   description:
@@ -133,6 +181,8 @@ spec:
                     true"
                 - message: Restore requires restore field.
                   rule: "self.type == 'Restore' ? has(self.restore) : true"
+                - message: Clone requires clone field.
+                  rule: "self.type == 'Clone' ? has(self.clone) : true"
             status:
               properties:
                 conditions:

crds/virtualmachineoperations.yaml

@@ -0,0 +1,65 @@
+/*
+Copyright 2025 Flant JSC
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+     http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+package common
+
+import (
+	"errors"
+	"fmt"
+)
+
+var (
+	ErrVirtualMachineAlreadyExists      = errors.New("VirtualMachine already exists")
+	ErrVirtualDiskAlreadyExists         = errors.New("VirtualDisk already exists")
+	ErrVirtualDiskAttachedToDifferentVM = errors.New("VirtualDisk is attached to different VirtualMachine")
+	ErrVMBDAAlreadyExists               = errors.New("VirtualMachineBlockDeviceAttachment already exists")
+	ErrVMBDAAttachedToDifferentVM       = errors.New("VirtualMachineBlockDeviceAttachment is attached to different VirtualMachine")
+	ErrVMIPAttachedToDifferentVM        = errors.New("VirtualMachineIPAddress is attached to different VirtualMachine")
+	ErrImageResourceNotFound            = errors.New("image resource is used by VirtualMachine but absent in cluster")
+	ErrSecretContentDifferent           = errors.New("secret content is different from that in the snapshot")
+)
+
+func FormatVirtualMachineConflictError(vmName string) error {
+	return fmt.Errorf("VirtualMachine with name %s already exists", vmName)
+}
+
+func FormatVirtualDiskConflictError(vdName string) error {
+	return fmt.Errorf("VirtualDisk with name %s already exists", vdName)
+}
+
+func FormatVirtualDiskAttachedError(vdName, attachedVM string) error {
+	return fmt.Errorf("VirtualDisk with name %s attached to VirtualMachine %s", vdName, attachedVM)
+}
+
+func FormatVMBDAConflictError(vmbdaName string) error {
+	return fmt.Errorf("VirtualMachineBlockDeviceAttachment with name %s already exists", vmbdaName)
+}
+
+func FormatVMBDAAttachedError(vmbdaName, attachedVM string) error {
+	return fmt.Errorf("VirtualMachineBlockDeviceAttachment with name %s already exists and attached to VirtualMachine %s", vmbdaName, attachedVM)
+}
+
+func FormatVMIPAttachedError(vmipName, attachedVM string) error {
+	return fmt.Errorf("VirtualMachineIPAddress with name %s already exists and attached to VirtualMachine %s", vmipName, attachedVM)
+}
+
+func FormatImageResourceNotFoundError(resourceType, resourceName, vmName string) error {
+	return fmt.Errorf("%s %s is used by VirtualMachine %s but absent in cluster", resourceType, resourceName, vmName)
+}
+
+func FormatSecretContentDifferentError(secretName string) error {
+	return fmt.Errorf("content of the secret %s is different from that in the snapshot", secretName)
+}

images/virtualization-artifact/pkg/apiserver/api/generated/openapi/zz_generated.openapi.go

@@ -20,6 +20,8 @@ import (
 	"context"
 
 	"sigs.k8s.io/controller-runtime/pkg/client"
+
+	"github.com/deckhouse/virtualization/api/core/v1alpha2"
 )
 
 //go:generate go tool moq -rm -out mock.go . ObjectHandler
@@ -29,4 +31,5 @@ type ObjectHandler interface {
 	ProcessRestore(ctx context.Context) error
 	ValidateClone(ctx context.Context) error
 	ProcessClone(ctx context.Context) error
+	Override(rules []v1alpha2.NameReplacement)
 }