datamigrate

Documentation

Index

• Constants
• type DataMigrateInfo
• type DataMigrateValue
• type ParallelOptions

Constants

const (
	DataMigrateLockName = "DataMigrate"

	DataMigrateFinalizer = "fluid-datamigrate-controller-finalizer"
	DataMigrateChart     = "fluid-datamigrate"

	SSHSecretName          = "sshSecretName"
	SSHPort                = "sshPort"
	SSHReadyTimeoutSeconds = "sshReadyTimeoutSeconds"

	DefaultSSHReadyTimeoutSeconds = 180
	DefaultSSHPort                = 22
)

Types

type DataMigrateInfo

type DataMigrateInfo struct {
	// Policy for migrate, including None, Once, Cron, OnEvent
	Policy string `json:"policy"`

	// Schedule The schedule in Cron format, only set when policy is cron, see https://en.wikipedia.org/wiki/Cron.
	Schedule string `json:"schedule,omitempty"`

	// BackoffLimit specifies the upper limit times when the DataMigrate job fails
	BackoffLimit int32 `json:"backoffLimit,omitempty"`

	// TargetDataset specifies the dataset that the DataLoad targets
	TargetDataset string `json:"targetDataset,omitempty"`

	// MigrateFrom specifies the data that the DataMigrate migrate from
	MigrateFrom string `json:"migrateFrom,omitempty"`

	// MigrateTo specifies the data that the DataMigrate migrate to
	MigrateTo string `json:"migrateTo,omitempty"`

	// EncryptOptions specifies the encrypt options that the DataMigrate job uses
	EncryptOptions []v1alpha1.EncryptOption `json:"encryptOptions,omitempty"`

	// Image specifies the image that the DataMigrate job uses
	Image string `json:"image,omitempty"`

	// Options specifies the extra dataMigrate properties for runtime
	Options map[string]string `json:"options,omitempty"`

	// Labels defines labels in DataMigrate's pod metadata
	Labels map[string]string `json:"labels,omitempty"`

	// Annotations defines annotations in DataMigrate's pod metadata
	Annotations map[string]string `json:"annotations,omitempty"`

	// image pull secrets
	ImagePullSecrets []corev1.LocalObjectReference `json:"imagePullSecrets,omitempty"`

	// specifies local:// and pvc:// volume
	NativeVolumes []corev1.Volume `json:"nativeVolumes,omitempty"`

	// specifies local:// and pvc:// volume mount
	NativeVolumeMounts []corev1.VolumeMount `json:"nativeVolumeMounts,omitempty"`

	// specifies pod affinity
	Affinity *corev1.Affinity `json:"affinity,omitempty"`

	// specifies node selector
	NodeSelector map[string]string `json:"nodeSelector,omitempty"`

	// specifies pod tolerations
	Tolerations []corev1.Toleration `json:"tolerations,omitempty"`

	// specifies scheduler name
	SchedulerName string `json:"schedulerName,omitempty"`

	// Resources that will be requested by DataMigrate job.
	Resources corev1.ResourceRequirements `json:"resources,omitempty"`

	// Parallelism defines the parallel tasks.
	Parallelism int32 `json:"parallelism,omitempty"`

	// ParallelOptions used when Parallelism is greater than 1.
	ParallelOptions ParallelOptions `json:"parallelOptions,omitempty"`
}

type DataMigrateValue

type DataMigrateValue struct {
	Name            string                 `json:"name"`
	Owner           *common.OwnerReference `json:"owner,omitempty"`
	DataMigrateInfo DataMigrateInfo        `json:"datamigrate"`
}

type ParallelOptions

type ParallelOptions struct {
	SSHPort int `json:"sshPort,omitempty"`

	SSHReadyTimeoutSeconds int `json:"readyTimeoutSeconds,omitempty"`

	SSHSecretName string `json:"sshSecretName,omitempty"`
}