Function startAllReplication

pgserver/backup_handler.go:161–175

(sqlCtx *sql.Context)

}

func startAllReplication(sqlCtx *sql.Context) error {
	if err := logrepl.UpdateAllSubscriptionStatus(sqlCtx, true); err != nil {
		return err
	}

	if err := adapter.CommitAndCloseTxn(sqlCtx); err != nil {
		return err
	}

	if err := logrepl.UpdateSubscriptions(sqlCtx); err != nil {
		return fmt.Errorf("failed to update subscriptions: %w", err)
	}

	return nil
}