backup/showbridge-go
1
0
Fork 0
mirror of https://github.com/jwetzell/showbridge-go.git synced 2026-04-26 21:05:30 +00:00
Code Issues Packages Projects Releases Wiki Activity

cleanup logging in router

Browse Source
This commit is contained in:
Joel Wetzell
2025-12-26 10:19:29 -06:00
parent e96913230b
commit 6968539c59
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
router.go
View File

@@ -32,7 +32,7 @@ func NewRouter(ctx context.Context, config config.Config) (*Router, []module.Mod
logger: slog.Default().With("component", "router"), logger: slog.Default().With("component", "router"),
} }
router.logger.Debug("creating router") router.logger.Debug("creating")
var moduleErrors []module.ModuleError var moduleErrors []module.ModuleError
@@ -107,7 +107,7 @@ func NewRouter(ctx context.Context, config config.Config) (*Router, []module.Mod
} }
func (r *Router) Run() { func (r *Router) Run() {
r.logger.Info("running router") r.logger.Info("running")
for _, moduleInstance := range r.ModuleInstances { for _, moduleInstance := range r.ModuleInstances {
r.moduleWait.Add(1) r.moduleWait.Add(1)
go func() { go func() {
@@ -120,7 +120,7 @@ func (r *Router) Run() {
} }
<-r.Context.Done() <-r.Context.Done()
r.moduleWait.Wait() r.moduleWait.Wait()
r.logger.Info("router done") r.logger.Info("done")
} }
func (r *Router) Stop() { func (r *Router) Stop() {
@@ -140,7 +140,7 @@ func (r *Router) HandleInput(sourceId string, payload any) []route.RouteIOError
Index: routeIndex, Index: routeIndex,
Error: err, Error: err,
}) })
r.logger.Error("router unable to route input", "route", routeIndex, "source", sourceId, "error", err) r.logger.Error("unable to route input", "route", routeIndex, "source", sourceId, "error", err)
} }
} }
} }