plan

Documentation

Index

• func CheckTLSSecretRef(ctx context.Context, cli client2.ReadonlyClient, namespace string, ...) error
• func ComposeTLSSecret(namespace, clusterName, componentName string) (*v1.Secret, error)
• func DoPITR(ctx context.Context, cli client.Client, cluster *appsv1alpha1.Cluster, ...) error
• func DoRestore(ctx context.Context, cli client.Client, cluster *appsv1alpha1.Cluster, ...) error
• func GenServiceReferences(reqCtx intctrlutil.RequestCtx, cli client.Client, ...) (map[string]*appsv1alpha1.ServiceDescriptor, error)
• func GenerateTLSSecretName(clusterName, componentName string) string
• func GetTLSKeyWord(cType string) string
• func RenderConfigNScriptFiles(resourceCtx *intctrlutil.ResourceCtx, ...) error
• type RestoreManager
  • func NewRestoreManager(ctx context.Context, cli client.Client, cluster *appsv1alpha1.Cluster, ...) *RestoreManager
  • func (p *RestoreManager) BuildDatafileRestoreJob(synthesizedComponent *component.SynthesizedComponent, ...) (objs []client.Object, err error)
  • func (p *RestoreManager) BuildDatafileRestoreJobByPVCS(synthesizedComponent *component.SynthesizedComponent, ...) (objs []client.Object, err error)
  • func (p *RestoreManager) GetDatafileRestoreJobName(pvcName string) string

Functions

func CheckTLSSecretRef

func CheckTLSSecretRef(ctx context.Context, cli client2.ReadonlyClient, namespace string,
	secretRef *dbaasv1alpha1.TLSSecretRef) 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 DoPITR

func DoPITR(ctx context.Context, cli client.Client, cluster *appsv1alpha1.Cluster,
	component *component.SynthesizedComponent, schema *k8sruntime.Scheme) error

DoPITR prepares PITR jobs

func DoRestore

func DoRestore(ctx context.Context, cli client.Client, cluster *appsv1alpha1.Cluster,
	component *component.SynthesizedComponent, schema *k8sruntime.Scheme) error

DoRestore prepares restore jobs

func GenServiceReferences

func GenServiceReferences(reqCtx intctrlutil.RequestCtx,
	cli client.Client,
	cluster *appsv1alpha1.Cluster,
	clusterCompDef *appsv1alpha1.ClusterComponentDefinition,
	clusterCompSpec *appsv1alpha1.ClusterComponentSpec,
) (map[string]*appsv1alpha1.ServiceDescriptor, error)

func GenerateTLSSecretName

func GenerateTLSSecretName(clusterName, componentName string) string

func GetTLSKeyWord

func GetTLSKeyWord(cType string) string

func RenderConfigNScriptFiles

func RenderConfigNScriptFiles(resourceCtx *intctrlutil.ResourceCtx,
	clusterVersion *appsv1alpha1.ClusterVersion,
	cluster *appsv1alpha1.Cluster,
	component *component.SynthesizedComponent,
	compObject client.Object,
	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) *RestoreManager

func (*RestoreManager) BuildDatafileRestoreJob

func (p *RestoreManager) BuildDatafileRestoreJob(synthesizedComponent *component.SynthesizedComponent, backup *dpv1alpha1.Backup, backupTool *dpv1alpha1.BackupTool) (objs []client.Object, err error)

func (*RestoreManager) BuildDatafileRestoreJobByPVCS

func (p *RestoreManager) BuildDatafileRestoreJobByPVCS(synthesizedComponent *component.SynthesizedComponent,
	backup *dpv1alpha1.Backup,
	backupTool *dpv1alpha1.BackupTool,
	pvcNames []string,
	labels map[string]string) (objs []client.Object, err error)

func (*RestoreManager) GetDatafileRestoreJobName

func (p *RestoreManager) GetDatafileRestoreJobName(pvcName string) string