setup embedded NATS cluster
1 file changed, 9 insertions(+), 0 deletions(-)
changed files
M cmd/server/main.go → cmd/server/main.go
@@ -6,6 +6,7 @@ "fmt" "os" "os/signal" + "go.alanpearce.eu/website/internal/nats" "go.alanpearce.eu/website/internal/server" "go.alanpearce.eu/x/log"@@ -52,8 +53,16 @@ log.Fatal("error starting server", err) } }() + go func() { + err := nats.Start(log.Named("nats")) + if err != nil { + log.Warn("could not start NATS server", "error", err) + } + }() + <-ctx.Done() log.Debug("calling stop") <-sv.Stop() + nats.Stop() log.Debug("done") }