Golang

Wat gebeurt er met het verzenden van gebeurtenissen als Kafka uitvalt?

Is een model met JSON-tags (bijvoorbeeld RegisterUserRequest) een domeinmodel? Hoe scheid je correct DTO en domeinentiteit?

Bent u bekend met de Hexagonale Architectuur? Vertel over de structuur ervan.

Hexagonale Architectuur bestaat uit drie elementen: adapter, poort en centrale applicatie. Hoe wordt een inkomend verzoek via de handler verwerkt tot het domeinmodel?

Hoe implementeer je de andere kant — Inbox-patroon aan de kant van de notificatieservice? Hoe zorg je voor idempotentie bij het verwerken van gebeurtenissen?

// Corrigeer die kode zodat de verzoeken concurrerend zijn en de antwoordcode wordt weergegeven // en in geval van fout, log deze en ga door met verwerken 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 } // Verwerk resp indien nodig } }

Heeft u ooit met DDD en CQRS gewerkt? Vertel erover.

// Corrigeer de code zodat de verzoeken concurrerend zijn en de antwoordcode wordt weergegeven // en in geval van fout, toon de log en ga door met verwerken 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() }

In een microservices-architectuur heeft elke service zijn eigen database. Hoe werkt het Outbox-patroon in deze context als Kafka nog geen bericht heeft ontvangen?

Vertel ons over het patroon Transactional Outbox — hoe het werkt en waarvoor het wordt gebruikt.

Het aggregaat werkt altijd op transactie niveau. Wat is nog meer belangrijk om te weten over aggregaten in DDD?