From 6968539c59c51eb6e261e1efae00f44c24b079a3 Mon Sep 17 00:00:00 2001 From: Joel Wetzell Date: Fri, 26 Dec 2025 10:19:29 -0600 Subject: [PATCH] cleanup logging in router --- router.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/router.go b/router.go index ca4f348..f7cf44b 100644 --- a/router.go +++ b/router.go @@ -32,7 +32,7 @@ func NewRouter(ctx context.Context, config config.Config) (*Router, []module.Mod logger: slog.Default().With("component", "router"), } - router.logger.Debug("creating router") + router.logger.Debug("creating") var moduleErrors []module.ModuleError @@ -107,7 +107,7 @@ func NewRouter(ctx context.Context, config config.Config) (*Router, []module.Mod } func (r *Router) Run() { - r.logger.Info("running router") + r.logger.Info("running") for _, moduleInstance := range r.ModuleInstances { r.moduleWait.Add(1) go func() { @@ -120,7 +120,7 @@ func (r *Router) Run() { } <-r.Context.Done() r.moduleWait.Wait() - r.logger.Info("router done") + r.logger.Info("done") } func (r *Router) Stop() { @@ -140,7 +140,7 @@ func (r *Router) HandleInput(sourceId string, payload any) []route.RouteIOError Index: routeIndex, 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) } } }