plan

Documentation

Index

• func CheckTLSSecretRef(ctx context.Context, cli client.Reader, namespace string, ...) error
• func CleanupClusterRestoreAnnotation(cluster *appsv1alpha1.Cluster, compName string) (bool, error)
• func ComposeTLSSecret(namespace, clusterName, componentName string) (*v1.Secret, error)
• func GenerateTLSSecretName(clusterName, componentName string) string
• func GetBackupFromClusterAnnotation(ctx context.Context, cli client.Reader, backupSource map[string]string, ...) (*dpv1alpha1.Backup, error)
• func GetTLSKeyWord(cType string) string
• func RenderConfigNScriptFiles(resourceCtx *configuration.ResourceCtx, cluster *appsv1alpha1.Cluster, ...) error
• type RestoreManager
  • func NewRestoreManager(ctx context.Context, cli client.Client, cluster *appsv1alpha1.Cluster, ...) *RestoreManager
  • func (r *RestoreManager) BuildPrepareDataRestore(comp *component.SynthesizedComponent, backupObj *dpv1alpha1.Backup, ...) (*dpv1alpha1.Restore, error)
  • func (r *RestoreManager) DoPostReady(comp *component.SynthesizedComponent, compObj *appsv1alpha1.Component, ...) error
  • func (r *RestoreManager) DoPrepareData(comp *component.SynthesizedComponent, compObj *appsv1alpha1.Component, ...) error
  • func (r *RestoreManager) DoRestore(comp *component.SynthesizedComponent, compObj *appsv1alpha1.Component, ...) error
  • func (r *RestoreManager) GetRestoreObjectMeta(comp *component.SynthesizedComponent, stage dpv1alpha1.RestoreStage, ...) metav1.ObjectMeta

Functions

func CheckTLSSecretRef

func CheckTLSSecretRef(ctx context.Context, cli client.Reader, namespace string,
	secretRef *dbaasv1alpha1.TLSSecretRef) error

func CleanupClusterRestoreAnnotation

func CleanupClusterRestoreAnnotation(cluster *appsv1alpha1.Cluster, compName string) (bool, error)

func ComposeTLSSecret

func ComposeTLSSecret(namespace, clusterName, componentName string) (*v1.Secret, error)

ComposeTLSSecret composes a TSL secret object. REVIEW/TODO:

1. missing public function doc
2. should avoid using Go template to call a function, this is too hacky & costly, should just call underlying registered Go template function.

func GenerateTLSSecretName

func GenerateTLSSecretName(clusterName, componentName string) string

func GetBackupFromClusterAnnotation

func GetBackupFromClusterAnnotation(
	ctx context.Context,
	cli client.Reader,
	backupSource map[string]string,
	compName string,
	clusterNameSpace string) (*dpv1alpha1.Backup, error)

func GetTLSKeyWord

func GetTLSKeyWord(cType string) string

func RenderConfigNScriptFiles

func RenderConfigNScriptFiles(resourceCtx *configuration.ResourceCtx,
	cluster *appsv1alpha1.Cluster,
	component *appsv1alpha1.Component,
	synthesizedComponent *component.SynthesizedComponent,
	podSpec *corev1.PodSpec,
	localObjs []client.Object) error

RenderConfigNScriptFiles generates volumes for PodTemplate, volumeMount for container, rendered configTemplate and scriptTemplate, and generates configManager sidecar for the reconfigure operation.

Types

type RestoreManager

type RestoreManager struct {
	client.Client
	Ctx     context.Context
	Cluster *appsv1alpha1.Cluster
	Scheme  *k8sruntime.Scheme
	// contains filtered or unexported fields
}

RestoreManager restores manager functions 1. support datafile/snapshot restore 2. support point in time recovery (PITR)

func NewRestoreManager

func NewRestoreManager(ctx context.Context,
	cli client.Client,
	cluster *appsv1alpha1.Cluster,
	scheme *k8sruntime.Scheme,
	restoreLabels map[string]string,
	replicas, startingIndex int32,
) *RestoreManager

func (*RestoreManager) BuildPrepareDataRestore

func (r *RestoreManager) BuildPrepareDataRestore(comp *component.SynthesizedComponent, backupObj *dpv1alpha1.Backup, templateName string) (*dpv1alpha1.Restore, error)

func (*RestoreManager) DoPostReady

func (r *RestoreManager) DoPostReady(comp *component.SynthesizedComponent,
	compObj *appsv1alpha1.Component,
	backupObj *dpv1alpha1.Backup) error

func (*RestoreManager) DoPrepareData

func (r *RestoreManager) DoPrepareData(comp *component.SynthesizedComponent,
	compObj *appsv1alpha1.Component,
	backupObj *dpv1alpha1.Backup) error

func (*RestoreManager) DoRestore

func (r *RestoreManager) DoRestore(comp *component.SynthesizedComponent, compObj *appsv1alpha1.Component, needDoPostProvision bool) error

func (*RestoreManager) GetRestoreObjectMeta

func (r *RestoreManager) GetRestoreObjectMeta(comp *component.SynthesizedComponent, stage dpv1alpha1.RestoreStage, templateName string) metav1.ObjectMeta