974
}
975
976
>
priorities := make(map[int32]struct{})
db.go
977
>
db.Lock()
978
>
for _, s := range db.subqueues {
979
>
priorities[s.Key.Priority] = struct{}{}
980
>
}
981
>
db.Unlock()
982
>
983
>
backlogCountGauge := metrics.ApproximateBacklogCount
984
>
backlogAgeGauge := metrics.ApproximateBacklogAgeSeconds
985
>
if attributionEnabled {
986
>
backlogCountGauge = metrics.PhysicalApproximateBacklogCount
987
>
backlogAgeGauge = metrics.PhysicalApproximateBacklogAgeSeconds
988
>
}
989
990
>
for k := range priorities {
db.go
991
>
backlogCountGauge.With(db.metricsHandler).Record(0, metrics.MatchingTaskPriorityTag(k))
992
>
}
993
>
backlogAgeGauge.With(db.metricsHandler).Record(0)
994
>
metrics.TaskLagPerTaskQueueGauge.With(db.metricsHandler).Record(0)
995
}