From ed225048ff62aae89ba8966c1d7cd2dbc5014c87 Mon Sep 17 00:00:00 2001 From: ltdk Date: Mon, 25 May 2026 14:23:34 -0400 Subject: [PATCH] Emit network address in health events --- modules/caddyhttp/reverseproxy/healthchecks.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/modules/caddyhttp/reverseproxy/healthchecks.go b/modules/caddyhttp/reverseproxy/healthchecks.go index a737f116e..de93afb19 100644 --- a/modules/caddyhttp/reverseproxy/healthchecks.go +++ b/modules/caddyhttp/reverseproxy/healthchecks.go @@ -476,7 +476,7 @@ func (h *Handler) doActiveHealthCheck(dialInfo DialInfo, hostAddr string, networ if upstream.Host.activeHealthFails() >= h.HealthChecks.Active.Fails { // dispatch an event that the host newly became unhealthy if upstream.setHealthy(false) { - h.events.Emit(h.ctx, "unhealthy", map[string]any{"host": hostAddr}) + h.events.Emit(h.ctx, "unhealthy", map[string]any{"host": hostAddr, "addr": networkAddr}) upstream.Host.resetHealth() } } @@ -499,7 +499,7 @@ func (h *Handler) doActiveHealthCheck(dialInfo DialInfo, hostAddr string, networ if c := h.HealthChecks.Active.logger.Check(zapcore.InfoLevel, "host is up"); c != nil { c.Write(zap.String("host", hostAddr)) } - h.events.Emit(h.ctx, "healthy", map[string]any{"host": hostAddr}) + h.events.Emit(h.ctx, "healthy", map[string]any{"host": hostAddr, "addr": networkAddr}) upstream.Host.resetHealth() } }