refactor(proxy): improve request logging verbosity
- commit
- 1013c8d2d5c534a6ce912f2080b1651b6b62987c
- author
- bnema · · 2026-01-16 20:52 UTC
- parent
- bddd8da
- signature
- unsigned
1 file · +5 -2
M internal/usecase/proxy/service.go +5 -2
| @@ -89,6 +89,7 @@ func (s *Service) ServeHTTP(w http.ResponseWriter, r *http.Request) { | |||
| 89 | 89 | } | |
| 90 | 90 | ||
| 91 | 91 | // Get target for this domain | |
| 92 | + | log.Info().Str("resolving_target_for", r.Host).Msg("looking up proxy target") | |
| 92 | 93 | target, err := s.GetTarget(ctx, r.Host) | |
| 93 | 94 | if err != nil { | |
| 94 | 95 | log.Warn().Err(err).Msg("no route found for domain") | |
| @@ -96,7 +97,7 @@ func (s *Service) ServeHTTP(w http.ResponseWriter, r *http.Request) { | |||
| 96 | 97 | return | |
| 97 | 98 | } | |
| 98 | 99 | ||
| 99 | - | log.Debug(). | |
| 100 | + | log.Info(). | |
| 100 | 101 | Str("host", target.Host). | |
| 101 | 102 | Int("port", target.Port). | |
| 102 | 103 | Str("container_id", target.ContainerID). | |
| @@ -302,9 +303,11 @@ func (s *Service) proxyToTarget(w http.ResponseWriter, r *http.Request, target * | |||
| 302 | 303 | return | |
| 303 | 304 | } | |
| 304 | 305 | ||
| 306 | + | log.Info().Str("target_url", targetURL.String()).Msg("proxying to target") | |
| 307 | + | ||
| 305 | 308 | proxy := newReverseProxy(targetURL, | |
| 306 | 309 | func(w http.ResponseWriter, _ *http.Request, err error) { | |
| 307 | - | log.Error().Err(err).Str("target", targetURL.String()).Msg("proxy error") | |
| 310 | + | log.Error().Err(err).Str("target", targetURL.String()).Msg("PROXY ERROR - connection failed") | |
| 308 | 311 | http.Error(w, "Service Unavailable", http.StatusServiceUnavailable) | |
| 309 | 312 | }, | |
| 310 | 313 | func(resp *http.Response) error { | |
| @@ -89,6 +89,7 @@ func (s *Service) ServeHTTP(w http.ResponseWriter, r *http.Request) { | |||||
| 89 | } | 89 | } | ||
| 90 | 90 | ||||
| 91 | // Get target for this domain | 91 | // Get target for this domain | ||
| 92 | + | log.Info().Str("resolving_target_for", r.Host).Msg("looking up proxy target") | |||
| 92 | target, err := s.GetTarget(ctx, r.Host) | 93 | target, err := s.GetTarget(ctx, r.Host) | ||
| 93 | if err != nil { | 94 | if err != nil { | ||
| 94 | log.Warn().Err(err).Msg("no route found for domain") | 95 | log.Warn().Err(err).Msg("no route found for domain") | ||
| @@ -96,7 +97,7 @@ func (s *Service) ServeHTTP(w http.ResponseWriter, r *http.Request) { | |||||
| 96 | return | 97 | return | ||
| 97 | } | 98 | } | ||
| 98 | 99 | ||||
| 99 | - | log.Debug(). | 100 | + | log.Info(). |
| 100 | Str("host", target.Host). | 101 | Str("host", target.Host). | ||
| 101 | Int("port", target.Port). | 102 | Int("port", target.Port). | ||
| 102 | Str("container_id", target.ContainerID). | 103 | Str("container_id", target.ContainerID). | ||
| @@ -302,9 +303,11 @@ func (s *Service) proxyToTarget(w http.ResponseWriter, r *http.Request, target * | |||||
| 302 | return | 303 | return | ||
| 303 | } | 304 | } | ||
| 304 | 305 | ||||
| 306 | + | log.Info().Str("target_url", targetURL.String()).Msg("proxying to target") | |||
| 307 | + | ||||
| 305 | proxy := newReverseProxy(targetURL, | 308 | proxy := newReverseProxy(targetURL, | ||
| 306 | func(w http.ResponseWriter, _ *http.Request, err error) { | 309 | func(w http.ResponseWriter, _ *http.Request, err error) { | ||
| 307 | - | log.Error().Err(err).Str("target", targetURL.String()).Msg("proxy error") | 310 | + | log.Error().Err(err).Str("target", targetURL.String()).Msg("PROXY ERROR - connection failed") |
| 308 | http.Error(w, "Service Unavailable", http.StatusServiceUnavailable) | 311 | http.Error(w, "Service Unavailable", http.StatusServiceUnavailable) | ||
| 309 | }, | 312 | }, | ||
| 310 | func(resp *http.Response) error { | 313 | func(resp *http.Response) error { | ||