Chromium Code Reviews| Index: server/cmd/logdog_collector/main.go |
| diff --git a/server/cmd/logdog_collector/main.go b/server/cmd/logdog_collector/main.go |
| index 809e6c7b42f08be19afcd39d9e13ca466d405fb2..ec86b89f8d67c4618502b0dc11c06091673aa69d 100644 |
| --- a/server/cmd/logdog_collector/main.go |
| +++ b/server/cmd/logdog_collector/main.go |
| @@ -17,6 +17,7 @@ import ( |
| "github.com/luci/luci-go/common/tsmon/distribution" |
| "github.com/luci/luci-go/common/tsmon/field" |
| "github.com/luci/luci-go/common/tsmon/metric" |
| + "github.com/luci/luci-go/common/tsmon/types" |
| "github.com/luci/luci-go/server/internal/logdog/collector" |
| "github.com/luci/luci-go/server/internal/logdog/collector/coordinator" |
| "github.com/luci/luci-go/server/internal/logdog/service" |
| @@ -42,12 +43,14 @@ var ( |
| // "transient_failure". |
| tsPubsubCount = metric.NewCounter("logdog/collector/subscription/count", |
| "The number of Pub/Sub messages pulled.", |
| + types.MetricMetadata{}, |
| field.String("result")) |
| // tsTaskProcessingTime tracks the amount of time a single subscription |
| // message takes to process, in milliseconds. |
| tsTaskProcessingTime = metric.NewCumulativeDistribution("logdog/collector/subscription/processing_time_ms", |
| "Amount of time in milliseconds that a single Pub/Sub message takes to process.", |
| + types.MetricMetadata{}, |
|
Sergey Berezin
2016/07/06 21:39:12
Should this be Units: types.Milliseconds ?
ddoman
2016/07/07 04:47:57
Good catch!
Fixed.
|
| distribution.DefaultBucketer) |
| ) |