(requestLatency time.Duration)
| 1862 | } |
| 1863 | |
| 1864 | func (b *Broker) updateRequestLatencyAndInFlightMetrics(requestLatency time.Duration) { |
| 1865 | requestLatencyInMs := int64(requestLatency / time.Millisecond) |
| 1866 | b.requestLatency.Update(requestLatencyInMs) |
| 1867 | |
| 1868 | if b.brokerRequestLatency != nil { |
| 1869 | b.brokerRequestLatency.Update(requestLatencyInMs) |
| 1870 | } |
| 1871 | |
| 1872 | b.addRequestInFlightMetrics(-1) |
| 1873 | } |
| 1874 | |
| 1875 | func (b *Broker) addRequestInFlightMetrics(i int64) { |
| 1876 | b.requestsInFlight.Inc(i) |
no test coverage detected