datacopy

Documentation

Overview

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

Index

• Constants
• func GetConfigMapName(str1, str2 string) string
• 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 string, rcloneConfigMapNamespace string) *Rclone
• type DataCopyStatus
• type Progress
• type Rclone
  • func (rcl *Rclone) GenerateRcloneKeyConfigMap() *corev1.ConfigMap
  • func (rcl *Rclone) StartRCloneJob(jobName, lvName, srcNodeName string, waitUntilSuccess bool, ...) error

Constants

const (
	RcloneSrcName    = "source"
	RcloneRemoteName = "remote"
	RCloneKeyDir     = "/root/.ssh"
	RCloneKeyComment = "RClonePubKey"

	RCloneSrcMountPoint      = "/mnt/hwameistor/src/"
	RCloneDstMountPoint      = "/mnt/hwameistor/dst/"
	RClonePubKeyFileName     = "rclone.pub"
	RClonePrivateKeyFileName = "rclone"
	RCloneKeyConfigMapName   = "rclone-key-config"
	RCloneConfigMapName      = "rclone-config"
	RCloneConfigMapKey       = "rclone.conf"
	RCloneCertKey            = "rclone-ssh-keys"
	RcloneJobLabelApp        = "hwameistor-datasync-rclone"

	RCloneConfigSrcNodeNameKey     = "sourceNode"
	RCloneConfigDstNodeNameKey     = "targetNode"
	RCloneConfigVolumeNameKey      = "localVolume"
	RCloneConfigSourceNodeReadyKey = "sourceReady"
	RCloneConfigRemoteNodeReadyKey = "targetReady"
	RCloneConfigSyncDoneKey        = "completed"

	RCloneTrue  string = "yes"
	RCloneFalse string = "no"

	RCloneJobFinalizer = "hwameistor.io/rclone-job-protect"
)

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

const (
	DefaultCopyTimeout = time.Hour * 48
)

Functions

func GetConfigMapName

func GetConfigMapName(str1, str2 string) string

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, namespace string) (*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 string, rcloneConfigMapNamespace 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) GenerateRcloneKeyConfigMap

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

func (*Rclone) StartRCloneJob

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