(name string, broker *Broker)
| 24 | } |
| 25 | |
| 26 | func getMetricNameForBroker(name string, broker *Broker) string { |
| 27 | // Use broker id like the Java client as it does not contain '.' or ':' characters that |
| 28 | // can be interpreted as special character by monitoring tool (e.g. Graphite) |
| 29 | return name + "-for-broker-" + strconv.FormatInt(int64(broker.ID()), 10) |
| 30 | } |
| 31 | |
| 32 | func getMetricNameForTopic(name string, topic string) string { |
| 33 | // Convert dot to _ since reporters like Graphite typically use dot to represent hierarchy |