Golang

Kas nutinka su įvykių siuntimu, jei Kafka nukrinta?

Ar žinote šešiakampę architektūrą? Papasakokite apie jos struktūrą.

Ar modelis su JSON žymėmis (pvz., RegisterUserRequest) yra domeno modelis? Kaip teisingai atskirti DTO ir domeno vienetą?

Kaip įeinantis užklausa per handlerį apdorojama iki domeno modelio heksagoninėje architektūroje, kuri sudaryta iš trijų elementų: adapterio, uosto ir centrinės programos?

Kaip įgyvendinti atvirkštinę pusę — Inbox modelį notification paslaugos pusėje? Kaip užtikrinti įvykių apdorojimo idempotentiškumą?

// Pataisykite kodą taip, kad užklausos būtų konkurencingos ir būtų rodomas atsakymo kodas // ir klaidos atveju, įrašykite ją į žurnalą ir tęskite apdorojimą package main import "net/http" var addrs = []string{"[link]"} func main() { for _, url := range addrs { resp, err := http.Get(url) if err != nil { log.Error(err) continue } // Apdorokite resp, jei reikia } }

Ar kada nors dirbote su DDD ir CQRS? Papasakokite apie tai.

// Pakeiskite kodą taip, kad užklausos būtų konkurencingos ir būtų rodomas atsakymo kodas // ir klaidos atveju, parodykite jos žurnalą ir tęskite apdorojimą package main import "net/http" var addrs = []string{"[link] "[link] "[link] "[link] "[link] "[link] "[link] func main() { var wg sync.WaitGroup data := make(map[string]bool) for _, url := range addrs { wg.Add(1) if !data[url] { data[url] = true go func(url string) { defer wg.Done() resp, err := http.Get(url) if err != nil { log.Println(err) return } log.Println(resp.StatusCode) }(url) } } wg.Wait() }

Mikroservisų architektūroje kiekvienas servisas turi savo duomenų bazę. Kaip veikia Outbox modelis šiame kontekste, jei Kafka dar nėra gavo žinutės?

Papaskinkite apie Transactional Outbox modelį — kaip jis veikia ir kam jis naudojamas?

Agregatas visada veikia vienos operacijos lygyje. Kas dar svarbu žinoti apie agregatus DDD?