Запустить целевой сервер с указанными параметрами командной строки. Если он уже запущен, pg_createsubscriber завершится с ошибкой.

Проверить, можно ли преобразовать целевой сервер. Также выполняется несколько проверок исходного сервера. Если какое-либо из предварительных требований не выполнено, pg_createsubscriber завершится ошибкой.

Создать публикацию и слот репликации для каждой указанной базы данных на исходном сервере. Каждая публикация создаётся с использованием параметра FOR ALL TABLES. Если параметр --publication не указан, имя публикации задаётся по следующему шаблону: «pg_createsubscriber_%u_%x» (параметры: oid базы данных, случайное целое число int). Если параметр --replication-slot не указан, имя слота репликации задаётся по следующему шаблону: «pg_createsubscriber_%u_%x» (параметры: oid базы данных, случайное целое число int). Эти слоты репликации будут использоваться подписками на следующем шаге. Последний LSN для слота репликации используется в качестве точки остановки в параметре recovery_target_lsn, а подписками используется в качестве начальной точки репликации. Таким образом гарантируется, что ни одна транзакция не будет потеряна.

Записать параметры восстановления в целевой каталог данных и перезапустить целевой сервер. Указывает LSN (recovery_target_lsn) позиции в журнале предзаписи, до которой должно выполняться восстановление. Также указывает promote в качестве действия, которое должен выполнить сервер после достижения точки восстановления. Добавляются дополнительные параметры восстановления, чтобы избежать непредвиденного поведения во время процесса восстановления, например завершения восстановления при достижении согласованного состояния (WAL должен применяться до точки начала репликации) или появления множественных точек восстановления, которые могут привести к сбою. Этот шаг завершается после выхода сервера из режима резерва и начала приёма транзакций чтения-записи. При заданном параметре --recovery-timeout утилита pg_createsubscriber завершает работу, если восстановление не заканчивается до истечения указанного количества секунд.

Создать подписку для каждой указанной базы данных на целевом сервере. Если параметр --subscription не указан, имя подписки задаётся по следующему шаблону: «pg_createsubscriber_%u_%x» (параметры: oid базы данных, случайное целое число int). Подписка не копирует существующие данные с исходного сервера и не создаёт слот репликации. Она использует слот репликации, который был создан на предыдущем этапе. Подписка создана, но ещё не активирована, потому что, прежде чем начать репликацию, её положение нужно установить на начальную точку.

Удалить на целевом сервере публикации, изменения которых были реплицированы, так как они были созданы до точки начала репликации. Подписчик не сможет их использовать.

Установить положение репликации в начальную точку репликации для всех подписок. Когда целевой сервер начинает восстановление, он нагоняет начальную точку репликации. Именно этот LSN должен использоваться в качестве исходного положения репликации для всех подписок. Имя источника репликации поступает из-за создания подписки. Имя источника репликации и начальная точка репликации используются функцией pg_replication_origin_advance(), чтобы установить исходное положение репликации.

Активировать подписку для каждой указанной базы данных на целевом сервере. Подписка начинает применять транзакции с начальной точки репликации.

Если на резервном сервере был установлен параметр primary_slot_name, теперь его можно удалить за ненадобностью.

Если на резервном сервере есть слоты репликации для отработки отказа, их можно удалить из-за невозможности дальнейшей синхронизации.

Обновить системный идентификатор на целевом сервере. Для его изменения запускается утилита pg_resetwal. Целевой сервер останавливается — это обязательное условие для выполнения команды pg_resetwal.