init

Signed-off-by: Yaroslav Borbat <[email protected]>

Author: yaroslavborbat

api/core/v1alpha2/vdcondition/condition.go

@@ -36,6 +36,8 @@ const (
 	StorageClassReadyType Type = "StorageClassReady"
 	// InUseType indicates whether the VirtualDisk is attached to a running VirtualMachine or is being used in a process of an image creation.
 	InUseType Type = "InUse"
+	// MigrationType indicates whether the VirtualDisk is being volume migrating.
+	MigrationType Type = "Migration"
 )
 
 type (
@@ -51,6 +53,8 @@ type (
 	StorageClassReadyReason string
 	// InUseReason represents the various reasons for the InUse condition type.
 	InUseReason string
+	// MigrationReason represents the various reasons for the Migration condition type.
+	MigrationReason string
 )
 
 func (s DatasourceReadyReason) String() string {
@@ -77,6 +81,10 @@ func (s InUseReason) String() string {
 	return string(s)
 }
 
+func (s MigrationReason) String() string {
+	return string(s)
+}
+
 const (
 	// DatasourceReady indicates that the datasource is ready for use, allowing the import process to start.
 	DatasourceReady DatasourceReadyReason = "DatasourceReady"
@@ -168,3 +176,8 @@ const (
 	// NotInUse indicates that VirtualDisk free for use.
 	NotInUse InUseReason = "NotInUse"
 )
+
+const (
+	MigratingReason        MigrationReason = "Migrating"
+	PendingMigratingReason MigrationReason = "Pending"
+)

api/core/v1alpha2/virtual_disk.go

@@ -79,6 +79,9 @@ type VirtualDiskStatus struct {
 	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
 	// Name of the StorageClass used by the PersistentVolumeClaim if `Kubernetes` storage type is used.
 	StorageClassName string `json:"storageClassName,omitempty"`
+
+	// Migration information.
+	MigrationInfo VirtualDiskMigrationInfo `json:"migrationInfo,omitempty"`
 }
 
 // VirtualDisk statistics.
@@ -198,7 +201,8 @@ type VirtualDiskList struct {
 // * `PVCLost`: The child PVC of the resource is missing. The resource cannot be used.
 // * `Exporting`: The child PV of the resource is in the process of exporting.
 // * `Terminating`: The resource is being deleted.
-// +kubebuilder:validation:Enum:={Pending,Provisioning,WaitForUserUpload,WaitForFirstConsumer,Ready,Resizing,Failed,PVCLost,Exporting,Terminating}
+// * `Migrating`: The resource is being migrating.
+// +kubebuilder:validation:Enum:={Pending,Provisioning,WaitForUserUpload,WaitForFirstConsumer,Ready,Resizing,Failed,PVCLost,Exporting,Terminating,Migrating}
 type DiskPhase string
 
 const (
@@ -212,4 +216,25 @@ const (
 	DiskLost                 DiskPhase = "PVCLost"
 	DiskExporting            DiskPhase = "Exporting"
 	DiskTerminating          DiskPhase = "Terminating"
+	DiskMigrating            DiskPhase = "Migrating"
+)
+
+type VirtualDiskMigrationInfo struct {
+	// Source PersistentVolumeClaim name.
+	SourcePVC string `json:"sourcePVC,omitempty"`
+	// Target PersistentVolumeClaim name.
+	TargetPVC      string                     `json:"targetPVC,omitempty"`
+	Result         VirtualDiskMigrationResult `json:"result,omitempty"`
+	Message        string                     `json:"message,omitempty"`
+	StartTimestamp metav1.Time                `json:"startTimestamp,omitempty"`
+	EndTimestamp   metav1.Time                `json:"endTimestamp,omitempty"`
+}
+
+// VirtualDiskMigrationResult is the result of the VirtualDisk migration.
+// +kubebuilder:validation:Enum=Succeeded;Failed
+type VirtualDiskMigrationResult string
+
+const (
+	VirtualDiskMigrationResultSucceeded VirtualDiskMigrationResult = "Succeeded"
+	VirtualDiskMigrationResultFailed    VirtualDiskMigrationResult = "Failed"
 )

api/core/v1alpha2/vmcondition/condition.go

@@ -78,21 +78,24 @@ const (
 	ReasonConfigurationApplied    Reason = "ConfigurationApplied"
 	ReasonConfigurationNotApplied Reason = "ConfigurationNotApplied"
 
+	ReasonRestartAwaitingUnexpectedState     Reason = "RestartAwaitingUnexpectedState"
 	ReasonRestartAwaitingChangesExist        Reason = "RestartAwaitingChangesExist"
 	ReasonRestartAwaitingVMClassChangesExist Reason = "RestartAwaitingVMClassChangesExist"
 	ReasonRestartNoNeed                      Reason = "NoNeedRestart"
 
-	ReasonMigratable    Reason = "VirtualMachineMigratable"
-	ReasonNotMigratable Reason = "VirtualMachineNotMigratable"
+	ReasonMigratable         Reason = "VirtualMachineMigratable"
+	ReasonNonMigratable      Reason = "VirtualMachineNonMigratable"
+	ReasonDisksNotMigratable Reason = "VirtualMachineDisksNotMigratable"
 
-	ReasonVmIsMigrating                  Reason = "VirtualMachineMigrating"
-	ReasonVmIsNotMigrating               Reason = "VirtualMachineNotMigrating"
+	ReasonMigratingPending               Reason = "Pending"
+	ReasonReadyToMigrate                 Reason = "ReadyToMigrate"
+	ReasonMigratingInProgress            Reason = "InProgress"
 	ReasonLastMigrationFinishedWithError Reason = "LastMigrationFinishedWithError"
-	ReasonVmIsNotRunning                 Reason = "VirtualMachineNotRunning"
-	ReasonVmIsRunning                    Reason = "VirtualMachineRunning"
-	ReasonInternalVirtualMachineError    Reason = "InternalVirtualMachineError"
-	ReasonPodNotStarted                  Reason = "PodNotStarted"
-	ReasonMigrationIsPending             Reason = "MigrationIsPending"
+
+	ReasonVmIsNotRunning              Reason = "VirtualMachineNotRunning"
+	ReasonVmIsRunning                 Reason = "VirtualMachineRunning"
+	ReasonInternalVirtualMachineError Reason = "InternalVirtualMachineError"
+	ReasonPodNotStarted               Reason = "PodNotStarted"
 
 	// 	ReasonFilesystemFrozen indicates that virtual machine's filesystem has been successfully frozen.
 	ReasonFilesystemFrozen Reason = "Frozen"

api/core/v1alpha2/vmopcondition/condition.go

@@ -80,6 +80,9 @@ const (
 	// ReasonQuotaExceeded is a completed reason that indicates the project's quota has been exceeded and the migration has been paused.
 	ReasonQuotaExceeded ReasonCompleted = "QuotaExceeded"
 
+	// ReasonWaitingForVirtualMachineToBeReadyToMigrate is a ReasonCompleted indicating that the virtual machine is not ready to be migrated.
+	ReasonWaitingForVirtualMachineToBeReadyToMigrate ReasonCompleted = "WaitingForVirtualMachineToBeReadyToMigrate"
+
 	// ReasonOperationFailed is a ReasonCompleted indicating that operation has failed.
 	ReasonOperationFailed ReasonCompleted = "OperationFailed"
 

api/core/v1alpha2/zz_generated.deepcopy.go

@@ -366,6 +366,32 @@ spec:
                         the cluster.
                       type: string
                   type: object
+                migrationInfo:
+                  description: Migration information.
+                  properties:
+                    endTimestamp:
+                      format: date-time
+                      type: string
+                    message:
+                      type: string
+                    result:
+                      description:
+                        VirtualDiskMigrationResult is the result of the VirtualDisk
+                        migration.
+                      enum:
+                        - Succeeded
+                        - Failed
+                      type: string
+                    sourcePVC:
+                      description: Source PersistentVolumeClaim name.
+                      type: string
+                    startTimestamp:
+                      format: date-time
+                      type: string
+                    targetPVC:
+                      description: Target PersistentVolumeClaim name.
+                      type: string
+                  type: object
                 observedGeneration:
                   description: Resource generation last processed by the controller.
                   format: int64
@@ -383,6 +409,7 @@ spec:
                     * `PVCLost`: The child PVC of the resource is missing. The resource cannot be used.
                     * `Exporting`: The child PV of the resource is in the process of exporting.
                     * `Terminating`: The resource is being deleted.
+                    * `Migrating`: The resource is being migrating.
                   enum:
                     - Pending
                     - Provisioning
@@ -394,6 +421,7 @@ spec:
                     - PVCLost
                     - Exporting
                     - Terminating
+                    - Migrating
                   type: string
                 progress:
                   description:

api/pkg/apiserver/api/generated/openapi/zz_generated.openapi.go

@@ -57,6 +57,7 @@ import (
 	"github.com/deckhouse/virtualization-controller/pkg/controller/vmop"
 	"github.com/deckhouse/virtualization-controller/pkg/controller/vmrestore"
 	"github.com/deckhouse/virtualization-controller/pkg/controller/vmsnapshot"
+	"github.com/deckhouse/virtualization-controller/pkg/controller/volumemigration"
 	workloadupdater "github.com/deckhouse/virtualization-controller/pkg/controller/workload-updater"
 	"github.com/deckhouse/virtualization-controller/pkg/featuregates"
 	"github.com/deckhouse/virtualization-controller/pkg/logger"
@@ -389,12 +390,20 @@ func main() {
 		os.Exit(1)
 	}
 
-	if err = workloadupdater.SetupController(ctx, mgr, log, firmwareImage, controllerNamespace, virtControllerName); err != nil {
+	workloadUpdaterLogger := logger.NewControllerLogger(workloadupdater.ControllerName, logLevel, logOutput, logDebugVerbosity, logDebugControllerList)
+	if err = workloadupdater.SetupController(ctx, mgr, workloadUpdaterLogger, firmwareImage, controllerNamespace, virtControllerName); err != nil {
 		log.Error(err.Error())
 		os.Exit(1)
 	}
 
-	if err = evacuation.SetupController(ctx, mgr, virtClient, log); err != nil {
+	evacuationLogger := logger.NewControllerLogger(evacuation.ControllerName, logLevel, logOutput, logDebugVerbosity, logDebugControllerList)
+	if err = evacuation.SetupController(ctx, mgr, virtClient, evacuationLogger); err != nil {
+		log.Error(err.Error())
+		os.Exit(1)
+	}
+
+	volumeMigrationLogger := logger.NewControllerLogger(volumemigration.ControllerName, logLevel, logOutput, logDebugVerbosity, logDebugControllerList)
+	if err = volumemigration.SetupController(ctx, mgr, volumeMigrationLogger); err != nil {
 		log.Error(err.Error())
 		os.Exit(1)
 	}