(ctx context.Context, rs stats.RPCStats)
| 129 | } |
| 130 | |
| 131 | func (h *peerStatsHandler) HandleRPC(ctx context.Context, rs stats.RPCStats) { |
| 132 | p, _ := peer.FromContext(ctx) |
| 133 | h.mu.Lock() |
| 134 | defer h.mu.Unlock() |
| 135 | h.args = append(h.args, peerStats{rs, p}) |
| 136 | } |
| 137 | |
| 138 | func (h *peerStatsHandler) TagConn(ctx context.Context, _ *stats.ConnTagInfo) context.Context { |
| 139 | return ctx |
nothing calls this directly
no test coverage detected