Можете ли да разкажете как сте приложили патърна Saga във вашите проекти?

Моделът Saga се използва за управление на разпределени транзакции и осигуряване на съгласуваност на данните в архитектурата на микросервиси. В проекти на Go съм прилагал Saga за координиране на няколко услуги, където всяка операция е отделна стъпка с възможност за компенсация при грешка.

Основни моменти при реализирането:

• Всяка операция в Saga е отделна функция или метод, който изпълнява действие и връща грешка при неуспех.
• За всяка операция има компенсаторна функция, която отменя промените, ако следващата стъпка не успее.
• Контролерът на Saga последователно извиква операциите и при грешка извиква компенсаторните функции в обратен ред.

Пример за опростена структура:

func Saga() error {
    if err := Step1(); err != nil {
        return err
    }
    if err := Step2(); err != nil {
        compensateStep1()
        return err
    }
    if err := Step3(); err != nil {
        compensateStep2()
        compensateStep1()
        return err
    }
    return nil
}

В реалните проекти се използват библиотеки или собствени реализации с опашки и обработка на събития за асинхронност и устойчивост.