mirror of
https://github.com/jwetzell/showbridge-go.git
synced 2026-04-27 05:15:47 +00:00
logging tweaks
This commit is contained in:
@@ -24,7 +24,7 @@ type Router struct {
|
|||||||
func NewRouter(ctx context.Context, config Config) (*Router, []ModuleError, []RouteError) {
|
func NewRouter(ctx context.Context, config Config) (*Router, []ModuleError, []RouteError) {
|
||||||
|
|
||||||
logger := slog.New(slog.NewTextHandler(os.Stdout, &slog.HandlerOptions{
|
logger := slog.New(slog.NewTextHandler(os.Stdout, &slog.HandlerOptions{
|
||||||
Level: slog.LevelDebug,
|
Level: slog.LevelInfo,
|
||||||
}))
|
}))
|
||||||
|
|
||||||
slog.SetDefault(logger)
|
slog.SetDefault(logger)
|
||||||
@@ -117,6 +117,7 @@ func NewRouter(ctx context.Context, config Config) (*Router, []ModuleError, []Ro
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (r *Router) Run() {
|
func (r *Router) Run() {
|
||||||
|
slog.Info("running router")
|
||||||
for _, moduleInstance := range r.ModuleInstances {
|
for _, moduleInstance := range r.ModuleInstances {
|
||||||
moduleInstance.RegisterRouter(r)
|
moduleInstance.RegisterRouter(r)
|
||||||
r.moduleWait.Add(1)
|
r.moduleWait.Add(1)
|
||||||
@@ -130,7 +131,7 @@ func (r *Router) Run() {
|
|||||||
}
|
}
|
||||||
<-r.Context.Done()
|
<-r.Context.Done()
|
||||||
r.moduleWait.Wait()
|
r.moduleWait.Wait()
|
||||||
slog.Info("router context done")
|
slog.Info("router done")
|
||||||
}
|
}
|
||||||
|
|
||||||
func (r *Router) Stop() {
|
func (r *Router) Stop() {
|
||||||
|
|||||||
Reference in New Issue
Block a user