(i int64)
| 1873 | } |
| 1874 | |
| 1875 | func (b *Broker) addRequestInFlightMetrics(i int64) { |
| 1876 | b.requestsInFlight.Inc(i) |
| 1877 | if b.brokerRequestsInFlight != nil { |
| 1878 | b.brokerRequestsInFlight.Inc(i) |
| 1879 | } |
| 1880 | } |
| 1881 | |
| 1882 | func (b *Broker) updateOutgoingCommunicationMetrics(bytes int) { |
| 1883 | b.requestRate.Mark(1) |
no outgoing calls
no test coverage detected