From 0bd4489bc308baea6fd832632e7ea7a5488bb183 Mon Sep 17 00:00:00 2001 From: Preston Van Loon Date: Fri, 5 Apr 2019 15:00:35 -0500 Subject: [PATCH] add span tag (#2176) --- shared/p2p/service.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/shared/p2p/service.go b/shared/p2p/service.go index 9cb7feb7dc..db70c12735 100644 --- a/shared/p2p/service.go +++ b/shared/p2p/service.go @@ -315,6 +315,9 @@ func (s *Server) emit(msg Message, feed Feed) { "msgType": fmt.Sprintf("%T", msg.Data), "msgName": proto.MessageName(msg.Data), }).Debug("Emit p2p message to feed subscribers") + if span := trace.FromContext(msg.Ctx); span != nil { + span.AddAttributes(trace.Int64Attribute("feedSubscribers", int64(i))) + } } // Subscribe returns a subscription to a feed of msg's Type and adds the channels to the feed.