Commit 59278361 authored by Hamdi Allam's avatar Hamdi Allam

nit

parent 30e1b1fb
......@@ -10,6 +10,8 @@ import (
var (
MetricsNamespace string = "etl"
_ Metricer = &metricer{}
)
type Metrics interface {
......@@ -137,7 +139,7 @@ func (m *metricer) RecordInterval() func(error) {
timer := prometheus.NewTimer(m.metrics.intervalDuration.WithLabelValues(m.etl))
return func(err error) {
if err != nil {
//m.metrics.RecordBatchFailure()
m.RecordBatchFailure()
}
timer.ObserveDuration()
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment