Function RunOrReuseProxy

internal/databases/sqlserver/sqlserver.go:553–576

(ctx context.Context, cancel context.CancelFunc, folder storage.Folder)

}

func RunOrReuseProxy(ctx context.Context, cancel context.CancelFunc, folder storage.Folder) (*LockWrapper, error) {
	bs, err := blob.NewServer(folder)
	if err != nil {
		return nil, xerrors.Errorf("proxy create error: %v", err)
	}
	reuse, _, err := conf.GetBoolSetting(conf.SQLServerReuseProxy)
	if err != nil {
		return nil, err
	}
	if reuse {
		return &LockWrapper{nil}, bs.WaitReady(ctx, blob.ProxyStartTimeout)
	}
	lock, err := bs.AcquireLock()
	if err != nil {
		return nil, err
	}

	err = bs.RunBackground(ctx, cancel)
	if err != nil {
		tracelog.ErrorLogger.PrintOnError(lock.Close())
		return nil, xerrors.Errorf("proxy run error: %v", err)
	}
	return &LockWrapper{lock}, nil
}

func GetDBRestoreLSN(db *sql.DB, databaseName string) (string, error) {
	query := `SELECT MAX(redo_start_lsn)