type Segment … const SegmentFromClient … const SegmentToClient … const SegmentFromAgent … const SegmentToAgent … func MakeStreamPacketsTotalMetric(namespace, subsystem string) *prometheus.CounterVec { … } func MakeStreamErrorsTotalMetric(namespace, subsystem string) *prometheus.CounterVec { … } func ObservePacket(m *prometheus.CounterVec, segment Segment, packetType client.PacketType) { … } func ObserveStreamErrorNoPacket(m *prometheus.CounterVec, segment Segment, err error) { … } func ObserveStreamError(m *prometheus.CounterVec, segment Segment, err error, packetType client.PacketType) { … }