Golang

Cosa succede con l'invio degli eventi se Kafka si blocca?

Conosci l'architettura esagonale? Racconta della sua struttura.

Un modello con tag JSON (ad esempio, RegisterUserRequest) è un modello di dominio? Come separare correttamente DTO e entità di dominio?

Come viene gestita la richiesta in ingresso tramite l'handler fino al modello di dominio in un'architettura esagonale, composta da tre elementi: adattatore, porta e applicazione centrale?

Come implementare il lato opposto — il pattern della casella di posta sul servizio di notifica? Come garantire l'idempotenza nell'elaborazione degli eventi?

// Correggere il codice in modo che le richieste siano concorrenti e venga visualizzato il codice di risposta // e in caso di errore, registrarlo e continuare l'elaborazione 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 } // Elaborare resp se necessario } }

Hai mai lavorato con DDD e CQRS? Raccontaci.

// Correggere il codice in modo che le richieste siano concorrenti e venga visualizzato il codice di risposta // e in caso di errore, visualizzare il log e continuare l'elaborazione 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 un'architettura a microservizi, ogni servizio ha il proprio database. Come funziona il pattern Outbox in questo contesto se Kafka non ha ancora ricevuto il messaggio?

Parli del pattern Transactional Outbox — come funziona e a cosa serve?

L'aggregato funziona sempre a livello di una singola transazione. Cos'altro è importante sapere sugli aggregati in DDD?