From a7ae7cbcb38e4a9ed9acd81cd947a4c74681fbdf Mon Sep 17 00:00:00 2001 From: Yadian Llada Lopez Date: Mon, 29 Jun 2026 09:27:30 -0400 Subject: [PATCH] fix(forwarder): set gRPC metadata type to collector instead of agent --- collectors/forwarder/serv/service.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/collectors/forwarder/serv/service.go b/collectors/forwarder/serv/service.go index 695d74cbc..df78b8074 100644 --- a/collectors/forwarder/serv/service.go +++ b/collectors/forwarder/serv/service.go @@ -88,7 +88,7 @@ func (p *program) run() { ctx = metadata.AppendToOutgoingContext(ctx, "key", cnf.CollectorKey) ctx = metadata.AppendToOutgoingContext(ctx, "id", strconv.Itoa(int(cnf.CollectorID))) - ctx = metadata.AppendToOutgoingContext(ctx, "type", "agent") + ctx = metadata.AppendToOutgoingContext(ctx, "type", "collector") p.goSafe("StartPing", func() { upstream.StartPing(cnf, ctx)