| 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..07b9829fff11f1a6075fdcff4b3928b3ff7aeed6 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{types.Milliseconds},
|
| distribution.DefaultBucketer)
|
| )
|
|
|
|
|