Track expiry rate on pduCountTotal
parent
99d8e1c107
commit
bcd3ef38d0
|
@ -358,6 +358,7 @@ func (t *inputWorker) run() {
|
|||
select {
|
||||
case <-task.ctx.Done():
|
||||
task.err = context.DeadlineExceeded
|
||||
pduCountTotal.WithLabelValues("expired").Inc()
|
||||
return
|
||||
default:
|
||||
evStart := time.Now()
|
||||
|
|
Loading…
Reference in New Issue