datacopy

Documentation

Overview

Design for copy data from source PVC to destination PVC, continuously push statue into status channel for notifications

Index

• Constants
• type DataCopyManager
  • func NewDataCopyManager(ctx context.Context, dataCopyJobStatusAnnotationName string, ...) (*DataCopyManager, error)
  • func (dcm *DataCopyManager) DeregisterRelatedJob(jobName string)
  • func (dcm *DataCopyManager) RegisterRelatedJob(jobName string, resultCh chan *DataCopyStatus)
  • func (dcm *DataCopyManager) Run()
  • func (dcm *DataCopyManager) UseRclone(rcloneImage, rcloneConfigMapName, rcloneKeyConfigMapName, ... string) *Rclone
• type DataCopyStatus
• type Progress
• type Rclone
  • func (rcl *Rclone) EnsureRcloneConfigMapToTargetNamespace(targetNamespace string) error
  • func (rcl *Rclone) GenerateRcloneKeyConfigMap(ns string) *corev1.ConfigMap
  • func (rcl *Rclone) SrcMountPointToRemoteMountPoint(jobName, namespace, lvPoolName, lvName, srcNodeName, dstNodeName string, ...) error
  • func (rcl *Rclone) WaitMigrateJobTaskDone(jobName, lvName string, waitUntilSuccess bool, timeout time.Duration) error

Constants

const (
	RcloneSrcName    = "source"
	RcloneRemoteName = "remote"
)

const (
	DataCopyStatusPending = "pending"
	DataCopyStatusSuccess = "success"
	DataCopyStatusRunning = "running"
	DataCopyStatusFailed  = "failed"
)

const (
	DefaultCopyTimeout = time.Hour * 48
)

Types

type DataCopyManager

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

func NewDataCopyManager

func NewDataCopyManager(ctx context.Context,
	dataCopyJobStatusAnnotationName string,
	client k8sclient.Client,
	statusCh chan *DataCopyStatus) (*DataCopyManager, error)

NewDataCopyManager return DataCopyManager instance

It will feedback copy process status continuously through statusCh, so it dose not need ResourceReady to poll resource status

func (*DataCopyManager) DeregisterRelatedJob

func (dcm *DataCopyManager) DeregisterRelatedJob(jobName string)

func (*DataCopyManager) RegisterRelatedJob

func (dcm *DataCopyManager) RegisterRelatedJob(jobName string, resultCh chan *DataCopyStatus)

func (*DataCopyManager) Run

func (dcm *DataCopyManager) Run()

func (*DataCopyManager) UseRclone

func (dcm *DataCopyManager) UseRclone(
	rcloneImage,
	rcloneConfigMapName,
	rcloneKeyConfigMapName,
	rcloneConfigMapNamespace,
	rcloneConfigMapKey, rcloneCrtKey string) *Rclone

type DataCopyStatus

type DataCopyStatus struct {
	UserData string
	JobName  string
	Phase    string
	Event    string
	Message  string
	// TODO
	Progress *Progress
}

type Progress

type Progress struct{}

TODO

type Rclone

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

func (*Rclone) EnsureRcloneConfigMapToTargetNamespace

func (rcl *Rclone) EnsureRcloneConfigMapToTargetNamespace(targetNamespace string) error

func (*Rclone) GenerateRcloneKeyConfigMap

func (rcl *Rclone) GenerateRcloneKeyConfigMap(ns string) *corev1.ConfigMap

func (*Rclone) SrcMountPointToRemoteMountPoint

func (rcl *Rclone) SrcMountPointToRemoteMountPoint(jobName, namespace, lvPoolName, lvName, srcNodeName, dstNodeName string, waitUntilSuccess bool, timeout time.Duration) error

func (*Rclone) WaitMigrateJobTaskDone

func (rcl *Rclone) WaitMigrateJobTaskDone(jobName, lvName string, waitUntilSuccess bool, timeout time.Duration) error