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, syncToolName string, ...) (*DataCopyManager, error)
  • func (dcm *DataCopyManager) DeregisterRelatedJob(jobName string)
  • func (dcm *DataCopyManager) GenerateSyncKeyConfigMap() *corev1.ConfigMap
  • func (dcm *DataCopyManager) RegisterRelatedJob(jobName string, resultCh chan *DataCopyStatus)
  • func (dcm *DataCopyManager) Run()
  • func (dcm *DataCopyManager) Sync(jobName, srcNodeName, dstNodeName, volName string) error
• type DataCopyStatus
• type DataSyncer
  • func NewSyncer(syncerName string, namespace string, client k8sclient.Client) DataSyncer
• type JuiceSync
  • func (js *JuiceSync) Prepare(targetNodeName, sourceNodeName, volName string) (err error)
  • func (js *JuiceSync) StartSync(jobName, volName, excludedRunningNodeName, runningNodeName string) error
• type Progress

Constants

const (
	DefaultCopyTimeout = time.Hour * 48

	SyncKeyComment = "SyncPubKey"

	SyncPubKeyFileName     = "key.pub"
	SyncPrivateKeyFileName = "key"
	SyncKeyConfigMapName   = "sync-key-config"

	SyncCertKey = "keys-pair"
)

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

const (
	SyncSrcName        = "source"
	SyncRemoteName     = "remote"
	SyncConfigMapName  = "sync-config"
	SyncJobLabelApp    = "hwameistor-datasync"
	SyncJobAffinityKey = "kubernetes.io/hostname"

	SyncSourceMountPoint = "/mnt/hwameistor/src/"
	SyncTargetMountPoint = "/mnt/hwameistor/dst/"

	SyncConfigSourceMountPointKey   = "sourceMountPoint"
	SyncConfigTargetMountPointKey   = "targetMountPoint"
	SyncConfigSourceNodeNameKey     = "sourceNode"
	SyncConfigTargetNodeNameKey     = "targetNode"
	SyncConfigVolumeNameKey         = "localVolume"
	SyncConfigSourceNodeReadyKey    = "sourceReady"
	SyncConfigTargetNodeReadyKey    = "targetReady"
	SyncConfigSourceNodeCompleteKey = "sourceCompleted"
	SyncConfigTargetNodeCompleteKey = "targetCompleted"
	SyncConfigSyncCompleteKey       = "syncCompleted"

	SyncTrue  string = "yes"
	SyncFalse string = "no"

	SyncJobFinalizer = "hwameistor.io/sync-job-protect"

	SyncToolJuiceSync = "juicesync"
)

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, syncToolName string, 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) GenerateSyncKeyConfigMap

func (dcm *DataCopyManager) GenerateSyncKeyConfigMap() *corev1.ConfigMap

func (*DataCopyManager) RegisterRelatedJob

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

func (*DataCopyManager) Run

func (dcm *DataCopyManager) Run()

func (*DataCopyManager) Sync

func (dcm *DataCopyManager) Sync(jobName, srcNodeName, dstNodeName, volName string) error

type DataCopyStatus

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

type DataSyncer

type DataSyncer interface {
	Prepare(targetNodeName, sourceNodeName, lvName string) error
	StartSync(jobName, lvName, excludedRunningNodeName, runningNodeName string) error
}

func NewSyncer

func NewSyncer(syncerName string, namespace string, client k8sclient.Client) DataSyncer

type JuiceSync

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

func (*JuiceSync) Prepare

func (js *JuiceSync) Prepare(targetNodeName, sourceNodeName, volName string) (err error)

func (*JuiceSync) StartSync

func (js *JuiceSync) StartSync(jobName, volName, excludedRunningNodeName, runningNodeName string) error

type Progress

type Progress struct{}

TODO