(reg prometheus.Registerer)
| 83 | } |
| 84 | |
| 85 | func (m Metrics) register(reg prometheus.Registerer) { |
| 86 | if reg != nil { |
| 87 | reg.MustRegister(m.BatchUtilization) |
| 88 | reg.MustRegister(m.BatchSize) |
| 89 | reg.MustRegister(m.FlushDuration) |
| 90 | reg.MustRegister(m.DroppedKeysTotal) |
| 91 | reg.MustRegister(m.BatchesTotal) |
| 92 | reg.MustRegister(m.MetadataTotal) |
| 93 | reg.MustRegister(m.PublishErrors) |
| 94 | } |
| 95 | } |
no outgoing calls
no test coverage detected