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,7 @@ const (
 	// NotInUse indicates that VirtualDisk free for use.
 	NotInUse InUseReason = "NotInUse"
 )
+
+const (
+	MigratingReason MigrationReason = "Migrating"
+)

api/core/v1alpha2/virtual_disk.go

@@ -79,6 +79,11 @@ 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"`
+	// Migration requests.
+	MigrationRequests []VirtualDiskMigrationRequest `json:"migrationRequest,omitempty"`
 }
 
 // VirtualDisk statistics.
@@ -198,6 +203,7 @@ 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.
+// * `Migrating`: The resource is being migrating.
 // +kubebuilder:validation:Enum:={Pending,Provisioning,WaitForUserUpload,WaitForFirstConsumer,Ready,Resizing,Failed,PVCLost,Exporting,Terminating}
 type DiskPhase string
 
@@ -212,4 +218,27 @@ 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"`
+	Completed bool   `json:"completed"`
+	Failed    bool   `json:"failed"`
+}
+
+type VirtualDiskMigrationRequest struct {
+	Action           VirtualDiskMigrationRequestAction `json:"action"`
+	Requester        string                            `json:"requester"`
+	StorageClassName string                            `json:"storageClassName"`
+}
+
+type VirtualDiskMigrationRequestAction string
+
+const (
+	VirtualDiskMigrationRequestActionMigrate VirtualDiskMigrationRequestAction = "migrate"
+	VirtualDiskMigrationRequestActionRevert  VirtualDiskMigrationRequestAction = "revert"
 )

api/core/v1alpha2/zz_generated.deepcopy.go

@@ -366,6 +366,39 @@ spec:
                         the cluster.
                       type: string
                   type: object
+                migrationInfo:
+                  description: Migration information.
+                  properties:
+                    completed:
+                      type: boolean
+                    failed:
+                      type: boolean
+                    sourcePVC:
+                      description: Source PersistentVolumeClaim name.
+                      type: string
+                    targetPVC:
+                      description: Target PersistentVolumeClaim name.
+                      type: string
+                  required:
+                    - completed
+                    - failed
+                  type: object
+                migrationRequest:
+                  description: Migration requests.
+                  items:
+                    properties:
+                      action:
+                        type: string
+                      requester:
+                        type: string
+                      storageClassName:
+                        type: string
+                    required:
+                      - action
+                      - requester
+                      - storageClassName
+                    type: object
+                  type: array
                 observedGeneration:
                   description: Resource generation last processed by the controller.
                   format: int64
@@ -383,6 +416,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

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

@@ -155,6 +155,9 @@ const (
 	AnnNetworksSpec = "network.deckhouse.io/networks-spec"
 	// AnnNetworksStatus is the annotation for view current network configuration into Pod.
 	AnnNetworksStatus = "network.deckhouse.io/networks-status"
+
+	AnnVolumeMigrationRequest = "virtualization.deckhouse.io/volume-migration-request"
+	AnnVolumeMigrationStatus  = "virtualization.deckhouse.io/volume-migration-status"
 )
 
 // AddAnnotation adds an annotation to an object

crds/virtualdisks.yaml

@@ -39,3 +39,7 @@ func generateString(length int, chars string) string {
 func AlphaNum(length int) string {
 	return generateString(length, alphaNum)
 }
+
+func LowerAlpha(length int) string {
+	return generateString(length, lowercaseAlpha)
+}

images/virtualization-artifact/pkg/common/annotations/annotations.go

@@ -235,7 +235,7 @@ func (ds HTTPDataSource) Validate(_ context.Context, _ *virtv2.ClusterVirtualIma
 	return nil
 }
 
-func (ds HTTPDataSource) getEnvSettings(cvi *virtv2.ClusterVirtualImage, supgen *supplements.Generator) *importer.Settings {
+func (ds HTTPDataSource) getEnvSettings(cvi *virtv2.ClusterVirtualImage, supgen supplements.Generator) *importer.Settings {
 	var settings importer.Settings
 
 	importer.ApplyHTTPSourceSettings(&settings, cvi.Spec.DataSource.HTTP, supgen)

images/virtualization-artifact/pkg/common/pwgen/pwgen.go

@@ -23,6 +23,7 @@ import (
 	netv1 "k8s.io/api/networking/v1"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/types"
+	"sigs.k8s.io/controller-runtime/pkg/client"
 
 	"github.com/deckhouse/virtualization-controller/pkg/common/datasource"
 	"github.com/deckhouse/virtualization-controller/pkg/controller/importer"
@@ -35,23 +36,23 @@ import (
 //go:generate go tool moq -rm -out mock.go . Importer Uploader Stat
 
 type Importer interface {
-	Start(ctx context.Context, settings *importer.Settings, obj service.ObjectKind, sup *supplements.Generator, caBundle *datasource.CABundle, opts ...service.Option) error
-	StartWithPodSetting(ctx context.Context, settings *importer.Settings, sup *supplements.Generator, caBundle *datasource.CABundle, podSettings *importer.PodSettings) error
-	CleanUp(ctx context.Context, sup *supplements.Generator) (bool, error)
-	CleanUpSupplements(ctx context.Context, sup *supplements.Generator) (bool, error)
-	GetPod(ctx context.Context, sup *supplements.Generator) (*corev1.Pod, error)
-	DeletePod(ctx context.Context, obj service.ObjectKind, controllerName string) (bool, error)
+	Start(ctx context.Context, settings *importer.Settings, obj client.Object, sup supplements.Generator, caBundle *datasource.CABundle, opts ...service.Option) error
+	StartWithPodSetting(ctx context.Context, settings *importer.Settings, sup supplements.Generator, caBundle *datasource.CABundle, podSettings *importer.PodSettings) error
+	CleanUp(ctx context.Context, sup supplements.Generator) (bool, error)
+	CleanUpSupplements(ctx context.Context, sup supplements.Generator) (bool, error)
+	GetPod(ctx context.Context, sup supplements.Generator) (*corev1.Pod, error)
+	DeletePod(ctx context.Context, obj client.Object, controllerName string) (bool, error)
 	Protect(ctx context.Context, pod *corev1.Pod) error
 	Unprotect(ctx context.Context, pod *corev1.Pod) error
-	GetPodSettingsWithPVC(ownerRef *metav1.OwnerReference, sup *supplements.Generator, pvcName, pvcNamespace string) *importer.PodSettings
+	GetPodSettingsWithPVC(ownerRef *metav1.OwnerReference, sup supplements.Generator, pvcName, pvcNamespace string) *importer.PodSettings
 }
 
 type Uploader interface {
-	Start(ctx context.Context, settings *uploader.Settings, obj service.ObjectKind, sup *supplements.Generator, caBundle *datasource.CABundle, opts ...service.Option) error
-	CleanUp(ctx context.Context, sup *supplements.Generator) (bool, error)
-	GetPod(ctx context.Context, sup *supplements.Generator) (*corev1.Pod, error)
-	GetIngress(ctx context.Context, sup *supplements.Generator) (*netv1.Ingress, error)
-	GetService(ctx context.Context, sup *supplements.Generator) (*corev1.Service, error)
+	Start(ctx context.Context, settings *uploader.Settings, obj client.Object, sup supplements.Generator, caBundle *datasource.CABundle, opts ...service.Option) error
+	CleanUp(ctx context.Context, sup supplements.Generator) (bool, error)
+	GetPod(ctx context.Context, sup supplements.Generator) (*corev1.Pod, error)
+	GetIngress(ctx context.Context, sup supplements.Generator) (*netv1.Ingress, error)
+	GetService(ctx context.Context, sup supplements.Generator) (*corev1.Service, error)
 	Protect(ctx context.Context, pod *corev1.Pod, svc *corev1.Service, ing *netv1.Ingress) error
 	Unprotect(ctx context.Context, pod *corev1.Pod, svc *corev1.Service, ing *netv1.Ingress) error
 	GetExternalURL(ctx context.Context, ing *netv1.Ingress) string