Function doCheckpoint

pgserver/backup_handler.go:133–143

(sqlCtx *sql.Context)

}

func doCheckpoint(sqlCtx *sql.Context) error {
	if _, err := adapter.ExecCatalogInTxn(sqlCtx, "CHECKPOINT"); err != nil {
		return err
	}

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

	return nil
}

func stopAllReplication(sqlCtx *sql.Context) error {
	if err := logrepl.UpdateAllSubscriptionStatus(sqlCtx, false); err != nil {