Let's instrument the search string with the duration

This commit is contained in:
Las Zenow 2017-06-06 14:40:59 +00:00
parent 5eca3843cc
commit c6354c46c8
4 changed files with 7 additions and 7 deletions

View file

@ -10,5 +10,5 @@ func Init() Instrument {
return &dummyInst{} return &dummyInst{}
} }
func (i dummyInst) Visit(section string, id string, search string, fmt string) {} func (i dummyInst) Visit(section string, id string, search string, fmt string) {}
func (i dummyInst) Duration(section string, duration time.Duration) {} func (i dummyInst) Duration(section string, search string, duration time.Duration) {}

View file

@ -4,5 +4,5 @@ import "time"
type Instrument interface { type Instrument interface {
Visit(section string, id string, search string, fmt string) Visit(section string, id string, search string, fmt string)
Duration(section string, duration time.Duration) Duration(section string, search string, duration time.Duration)
} }

View file

@ -37,7 +37,7 @@ func Init() Instrument {
Name: "trantor_request_duration_seconds", Name: "trantor_request_duration_seconds",
Help: "Duration of the request in seconds.", Help: "Duration of the request in seconds.",
}, },
[]string{"section"}, []string{"section", "search"},
) )
prometheus.MustRegister(visits) prometheus.MustRegister(visits)
@ -61,6 +61,6 @@ func (in promInst) Visit(section string, id string, search string, fmt string) {
in.visits.WithLabelValues(section, id, search, fmt).Inc() in.visits.WithLabelValues(section, id, search, fmt).Inc()
} }
func (in promInst) Duration(section string, duration time.Duration) { func (in promInst) Duration(section string, search string, duration time.Duration) {
in.reqDur.WithLabelValues(section).Observe(duration.Seconds()) in.reqDur.WithLabelValues(section, search).Observe(duration.Seconds())
} }

View file

@ -120,7 +120,7 @@ func (sg StatsGatherer) worker() {
} }
sg.instrument.Visit(section, id, search, fmt) sg.instrument.Visit(section, id, search, fmt)
sg.instrument.Duration(section, req.duration*time.Microsecond) sg.instrument.Duration(section, search, req.duration)
switch section { switch section {
case "download": case "download":
err = sg.db.IncDownloads(id) err = sg.db.IncDownloads(id)