👣 Go Migrate

⏩Go Migrate — это инструмент для управления миграциями базы данных, написанный на языке Go. Он может использоваться как интерфейс командной строки (CLI), так и импортироваться в качестве библиотеки для проектов Go.
Go Migrate может считывать файлы миграции из различных источников и применять их к базе данных в правильном порядке. Он поддерживает различные драйверы баз данных и источники миграции.

⏩Go Migrate поддерживает множество драйверов базы данных, включая:
PostgreSQL • Cassandra • SQLite • MariaDB • MongoDB • ClickHouse

⏩Чтобы использовать Go Migrate в вашем проекте Go, вам нужно импортировать необходимые пакеты и библиотеки. Вот пример:

import (
    "github.com/golang-migrate/migrate/v4"
    _ "github.com/golang-migrate/migrate/v4/database/postgres"
    _ "github.com/golang-migrate/migrate/v4/source/github"
)

func main() {
    m, err := migrate.New(
        "github://mattes:personal-access-token@mattes/migrate_test",
        "postgres://localhost:5432/database?sslmode=enable")
    m.Steps(2)
}

Этот код инициализирует Go Migrate с указанным источником и базой данных, затем применяет 2 миграции, используя метод Steps.

📎 Подробнее
📎 GitHub 13.8k ⭐️

@Golang_google

👣 Go повышение производительности в версиях с 1.0 по 1.22 #golang

https://benhoyt.com/writings/go-version-performance-2024/

@Golang_google

👣 Тэги структур в Go

▶️В Go при сериализации JSON в структуру используются мета-теги, которые записываются рядом с полями структуры:

type Response2 struct {
    Page   int      `json:"page"`
    Fruits []string `json:"fruits"`
}

В данном случае это ``json:"page"`` и ``json:"fruits"``.

Но иногда, вместо JSON используются другие стандарты, BSON и др. Так вот, что делать в случае других стандартов?


▶️Сразу можно сказать, что в теге может быть несколько полей для разных стандартов, например, тут одновременно можно обращаться со структурой как с JSON, и как с YAML:

type Response2 struct {
    Page   int      `json:"page" yaml:"page" validation:"min:1,max:10"`
    Fruits []string `json:"fruits" yaml:"fruits,omitempty" validation:"nonempty"`
}

r := &Response2{}
json.Read("file.json", r)
validator.Validate(r)
yaml.Write("file.yaml", r)

⏩Также тэги можно разбирать самостоятельно и использовать в своих библиотеках, подробнее об этом тут.
⏩Дополнительно о тэгах структур почитать можно здесь.

@Golang_google

👣 Маршалинг и анмаршалинг нестандартных форматов дат в Go

⏩Думаю, многие согласятся, что работа с датами практически в любом языке — это невероятная головная боль. Дата и время не десятичны и конечно же бесчисленное множество форматов даты и времени.
Вдобавок к этому ISO 8601 не всегда соблюдается в сторонних API, что создает неприятности.

⏩О том, как можно всё это героически решить, и пойдёт речь в статье.
Если коротко, то решение проблемы заключается в использовании кастомных типов и функций Unmarshaler для парсинга нестандартных дат.
Этот подход также может быть использован для успешного парсинга любого нестандартного контента, кстати.

📎 Статья

@Golang_google

👣 Прервать функцию с горутинами, если выполняется слишком долго

▶️Задача: в функции нужно запустить несколько горутин с вычислениями и дождаться их окончания.
При этом, если функция будет работать больше указанного количества секунд, нужно прервать ее выполнение.
Таким образом нужно прервать выполнение этой функции fun() ниже, что можно сделать?

package main

import (
"fmt"
"sync"
)

func FibonacciRecursion(n int) int {
    if n <= 1 {
        return n
    }
    return FibonacciRecursion(n-1) + FibonacciRecursion(n-2)
}

func f(i int, wg *sync.WaitGroup) {
    defer wg.Done()
    fmt.Println(FibonacciRecursion(45 + i))
}

func fun() {
    var wg sync.WaitGroup
    for i := 0; i < 3; i++ {
        go f(i, &wg)
       wg.Add(1)
    }
    wg.Wait()
    println("Function ended")
}

func main() {
    fun()
}

▶️Что ж, для этих целей как раз и используется пакет context.
С помощью context код выше можно переписать так:

package main

import (
    "context"
    "fmt"
    "sync"
    "time"
)

func main() {
    timeLimit := time.Second * 10
    ctx, cancel := context.WithTimeout(context.Background(), timeLimit)
    defer cancel()
    fun(ctx)
}

func isDone(ctx context.Context) bool {
    select {
    case <-ctx.Done():
        return true
    default:
        return false
    }
}

func FibonacciRecursion(ctx context.Context, n int) int {
    if n <= 1 || isDone(ctx) {
        return n
    }
    return FibonacciRecursion(ctx, n-1) + FibonacciRecursion(ctx, n-2)
}

func f(ctx context.Context, i int, wg *sync.WaitGroup) {
    defer wg.Done()
    fmt.Println(FibonacciRecursion(ctx, 45+i))
}

func fun(ctx context.Context) {
    var wg sync.WaitGroup
    for i := 0; i < 3; i++ {
        wg.Add(1)
        go f(ctx, i, &wg)
    }
    wg.Wait()
    println("Function ended")
}

Такие вот дела

@Golang_google

👣 Mongo-driver Golang - реконнект к серверу Mongo

▶️Вопрос: как реализовано переподключение приложения на Golang к MongoDB в случае потери соединения в библиотеке go.mongodb.org/mongo-driver/mongo?

На локальном компьютере при отключении Mongo приложение в течение 30 секунд висит (видимо пытается подключиться).

Это время — оно задается в настройках клиента библиотеки или в самой Mongo или от чего еще зависит? Mongo поднята в контейнере, код подключения такой:

ctx, _ := context.WithTimeout(context.Background(), timeoutSecond*time.Second)

client, err := mongo.Connect(ctx, options.Client().ApplyURI(connString))

Сам запрос вот:

err := mr.client.Database(mr.dbName).Collection(mr.collName).FindOne(ctx, filter).Decode(&p)

▶️Ответ: можно контролировать работу этого приложения с помощью context.WithTimeout или context.WithCancel(ctx). Помимо этого, у вас имеется возможность настроить клиент к базе.
У клиента есть ряд параметров с таймаутами, одни для выполнения одной операции, другие отвечают за время подключения к серверу (можно сказать время отклика сервера).

⏩Когда мы кладём БД и исполняем запрос, то висит канал (go channel), который ожидает выполнения функции, либо завершения контекста, истечения timeout этого запроса.

select {
case <-ctx.Done():
    return nil, ctx.Err()
case <-selectionState.timeoutChan:
    return nil, wrapServerSelectionError(ErrServerSelectionTimeout, t)
case current = <-subscriptionCh:
}

срабатывает <-selectionState.timeoutChan, по умолчанию его значение 30 секунд

⏩Документация говорит, что клиент нужно настроить следующим образом, чтобы продлить время ожидания отклика:

client, err := mongo.NewClient(options.Client().ApplyURI("mongodb://localhost:27017"),
        options.Client().SetConnectTimeout(time.Second * myTimeout),
        options.Client().SetServerSelectionTimeout(time.Second * myServerTimeout))

@Golang_google

👣 Как написать и запустить миграцию базы данных в Golang

При работе с базой данных миграция схемы является одной из важных задач, которую нам часто приходится выполнять на протяжении всего жизненного цикла приложения, чтобы адаптироваться к новым бизнес-требованиям.
И в этой статье речь пойдёт о том, как написать и запустить миграцию схемы базы данных в Golang, используя библиотеку golang-migrate, уверен, будет полезно

📎 Туториал
📎 YouTube

@Golang_google

👣 Аутентификация и OAuth с помощью Go

Держите полезные библиотеки для реализации схем аутентификации. Вы готовы? Их немало)

🟡 authboss — Модульная система аутентификации для Интернета. Он пытается удалить как можно больше шаблонов и «сложных вещей», чтобы каждый раз, когда вы запускаете новый веб-проект в Go, вы могли подключить его, настроить и начать создавать свое приложение без необходимости каждый раз создавать систему аутентификации.

🟡 branca — реализация спецификации токена branca для Golang 1.15+.

🟡 casbin — библиотека авторизации, поддерживающая такие модели управления доступом, как ACL, RBAC и ABAC.

🟡 cookietxt — предоставляет анализатор файлов формата cookie.txt.

🟡 go-guardian — Go-Guardian — это библиотека golang, которая предоставляет простой, понятный и идиоматический способ создания мощного современного API и веб-аутентификации, поддерживающей LDAP, базовую аутентификацию, аутентификацию на основе токена и сертификата.

🟡 go-jose — довольно полная реализация спецификаций JSON Web Token, JSON Web Signatures и JSON Web Encryption рабочей группы JOSE.

🟡 gologin — цепочки обработчиков для входа в систему с помощью поставщиков аутентификации OAuth1 и OAuth2.

🟡 gorbac — предоставляет облегченную реализацию управления доступом на основе ролей (RBAC) в Golang.

🟡 gosession — это быстрый сеанс для net/http в GoLang. Этот пакет, возможно, является лучшей реализацией механизма сеансов или, по крайней мере, пытается им стать.

🟡 goth — предоставляет простой, понятный и идиоматический способ использования OAuth и OAuth2. Обрабатывает несколько провайдеров «из коробки».

🟡 jeff — Простое, гибкое, безопасное и идиоматичное управление веб-сессиями с помощью подключаемых серверных частей.

🟡 jwt — безопасные, простые и быстрые веб-токены JSON для Go.

🟡 jwt-auth — промежуточное программное обеспечение JWT для http-серверов Golang со множеством параметров конфигурации.

🟡 jwt-go — полнофункциональная реализация веб-токенов JSON (JWT). Эта библиотека поддерживает синтаксический анализ и проверку, а также генерацию и подписание JWT.

@Golang_google

👣 Получение параметров при использовании ssl

▶️Итак, реальный кейс, связанный с использованием ssl/tls сертификатов. В коде есть фрагменты передачи данных из форм такого типа

http://localhost:8080/?param1=value

Сейчас, без использования шифрования транспорта, можно получить значение param1 так

r.FormValue("param1")

Вопрос: если начать шифровать транспорт, сами данные останутся незашифрованны ведь? Или придётся изменить способ получения параметров из запроса и сперва эти параметры расшифровать?


▶️Вообще, здесь не важно, происходит шифрование транспорта или нет, в хендлер придут данные в расшифровоном виде. Вот простой пример:

package main

import (
   "fmt"
    "log"
    "net/http"
)

func handler(w http.ResponseWriter, r *http.Request) {
    w.WriteHeader(http.StatusOK)
    w.Header().Set("Content-Type", "text/plain")
    w.Write([]byte(fmt.Sprintf("param1=%s", r.FormValue("param1"))))
}

func main() {
    http.HandleFunc("/", handler)
    http.NewServeMux()
    err := http.ListenAndServeTLS(":8080", "server.crt", "server.key", nil)
    if err != nil {
        log.Fatal("ListenAndServe: ", err)
    }
}

А вот команда генерации сертификатов:

openssl req -x509 -nodes -newkey rsa:2048 -keyout server.key -out server.crt -days 3650

Такие дела

@Golang_google

👣 Как загрузить пакет из приватного репозитория?

⏩Итак, ситуация. Есть приватный репозиторий. Можно склонировать себе данный репозититорий по ssh, но через go get / go install происходит ошибка:

go: unrecognized import path "private.gitlab.ru/repositoryName": https fetch: Get "https://private.gitlab.ru/repositoryName?go-get=1": dial tcp 255.255.255.255:443(левый IP адрес): i/o timeout

Попытки установить хост данного репозитория себе в переменные GONOPROXY / GOPRIVATE / GONOSUMDB не помогли, ошибка остаётся той же.


⏩Возможно, у кого-то тоже была такая проблема, надеюсь, этот совет ещё кому-то пригодится. Итак, если есть доступ по SSH, можно использовать такой вариант:

git config --global url."[email protected]".insteadOf "https://private.gitlab.ru"

🟡Или используя access-токен

git config --global url."https://${user}:${personal_access_token}@private.gitlab.ru".insteadOf"https://private.gitlab.ru"

После этого go get / go install будут работать с приватными репозиториями.

@Golang_google

👣 Разработка простого DNS сервера на Go, согласно RFC

О чём речь в статье?
🟡Небольшое введение в DNS в целом, как эти серверы позволяют связать IP и URL; о том, что DNS протокол является прикладным протоколом, работающим поверх UDP

🟡В протоколе реализуется один формат сообщения, его размер — 512 байт; описывается структура сообщения и его заголовок

🟡Описывается процесс распарсивания заголовка запроса и кодирования его для ответа

🟡В общем, по итогу создаётся минимальный рабочий DNS сервер на Go, что можно без проблем повторить

📎 Статья

@Golang_google