()
| 1964 | } |
| 1965 | |
| 1966 | func (b *Broker) registerMetrics() { |
| 1967 | b.brokerIncomingByteRate = b.registerMeter("incoming-byte-rate") |
| 1968 | b.brokerRequestRate = b.registerMeter("request-rate") |
| 1969 | b.brokerFetchRate = b.registerMeter("consumer-fetch-rate") |
| 1970 | b.brokerRequestSize = b.registerHistogram("request-size") |
| 1971 | b.brokerRequestLatency = b.registerHistogram("request-latency-in-ms") |
| 1972 | b.brokerOutgoingByteRate = b.registerMeter("outgoing-byte-rate") |
| 1973 | b.brokerResponseRate = b.registerMeter("response-rate") |
| 1974 | b.brokerResponseSize = b.registerHistogram("response-size") |
| 1975 | b.brokerRequestsInFlight = b.registerCounter("requests-in-flight") |
| 1976 | b.brokerThrottleTime = b.registerHistogram("throttle-time-in-ms") |
| 1977 | b.brokerProtocolRequestsRate = map[int16]metrics.Meter{} |
| 1978 | } |
| 1979 | |
| 1980 | func (b *Broker) registerMeter(name string) metrics.Meter { |
| 1981 | nameForBroker := getMetricNameForBroker(name, b) |
no test coverage detected