You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Since Refinery records metrics separately for sending spans to upstream honeycomb and to its peers, we should ensure that the peerTransmission is used when forwarding spans to peers in collector.
VinozzZ
changed the title
Use PeerTransmission to forward spans to peers during shutdown
Use PeerTransmission when forwarding spans to peers during shutdown
Sep 12, 2024
VinozzZ
changed the title
Use PeerTransmission when forwarding spans to peers during shutdown
Use PeerTransmission when forwarding spans to peers
Sep 12, 2024
…1332)
## Which problem is this PR solving?
Updates the collector use the configured peer transmission to send spans
to peers during redistribute and shutdown events. This ensures metrics
for sending to Honeycomb and peers are accurate.
The peer transmission is already configured and used by the router when
receiving spans that should be sent to a peer. This is used the same
transmission object after a span was originally accepted but then should
be forwarded to a peer.
- Closes#1324
## Short description of the changes
- Inject the already configured peer transmission during collector init
- Update redistribute and shutdown logic to use the peer transmission
- Update tests throughout to verify the peer transmission is used
correctly and also verify it can be injected correctly
- note: there were existing tests to verify redistribute and shutdown
behaviour and have been updated
Since Refinery records metrics separately for sending spans to upstream honeycomb and to its peers, we should ensure that the
peerTransmission
is used when forwarding spans to peers incollector
.trace redistribution on peer membership change:
refinery/collect/collect.go
Line 434 in 8d916ed
trace redistribution during shutdown:
refinery/collect/collect.go
Line 1034 in 8d916ed
The text was updated successfully, but these errors were encountered: