Function ClonePgData

pkg/management/postgres/join.go:40–74

ClonePgData clones an existing server, given its connection string, to a certain data directory

(ctx context.Context, connectionString, targetPgData, walDir string)

// ClonePgData clones an existing server, given its connection string,
// to a certain data directory
func ClonePgData(ctx context.Context, connectionString, targetPgData, walDir string) error {
	log.Info("Waiting for server to be available", "connectionString", connectionString)

	db, err := pool.NewDBConnection(connectionString, pool.ConnectionProfilePostgresqlPhysicalReplication)
	if err != nil {
		return err
	}
	defer func() {
		_ = db.Close()
	}()

	err = waitForStreamingConnectionAvailable(ctx, db)
	if err != nil {
		return fmt.Errorf("source server not available: %v", connectionString)
	}

	options := []string{
		"-D", targetPgData,
		"-v",
		"-w",
		"-d", connectionString,
	}

	if walDir != "" {
		options = append(options, "--waldir", walDir)
	}

	pgBaseBackupCmd := exec.Command(pgBaseBackupName, options...) // #nosec
	err = execlog.RunStreaming(pgBaseBackupCmd, pgBaseBackupName)
	if err != nil {
		return fmt.Errorf("error in pg_basebackup, %w", err)
	}

	return nil
}

// Join creates a new instance joined to an existing PostgreSQL cluster
func (info InitInfo) Join(ctx context.Context, cluster *apiv1.Cluster) error {