diff --git a/fragment.go b/fragment.go index 149749230..d24c856d2 100644 --- a/fragment.go +++ b/fragment.go @@ -691,7 +691,6 @@ func (f *fragment) unprotectedSetRow(row *Row, rowID uint64) (changed bool, err // Snapshot storage. f.snapshotQueue.Enqueue(f) - f.stats.Count(MetricSetRow, 1, 1.0) return changed, nil } @@ -733,8 +732,6 @@ func (f *fragment) unprotectedClearRow(rowID uint64) (changed bool, err error) { // Snapshot storage. f.snapshotQueue.Enqueue(f) - f.stats.Count(MetricClearRow, 1, 1.0) - return changed, nil } diff --git a/metrics.go b/metrics.go index a8afa8e41..0e3ce1208 100644 --- a/metrics.go +++ b/metrics.go @@ -28,11 +28,9 @@ const ( MetricRowBSI = "query_row_bsi_total" MetricSetRowAttrs = "query_setrowattrs_total" MetricSetColumnAttrs = "query_setcolumnattrs_total" - MetricMaximumRow = "maximum_row" + MetricMaximumRow = "shard_maximum_row" MetricSetBit = "set_bit_total" MetricClearBit = "clear_bit_total" - MetricSetRow = "set_row_total" - MetricClearRow = "clear_row_total" MetricImportingN = "importing_total" MetricImportedN = "imported_total" MetricClearingN = "clearing_total" diff --git a/prometheus/prometheus.go b/prometheus/prometheus.go index 4567d0f11..551996fb9 100644 --- a/prometheus/prometheus.go +++ b/prometheus/prometheus.go @@ -252,8 +252,7 @@ func (c *prometheusClient) Set(name string, value string, rate float64) { // Timing tracks timing information for a metric. func (c *prometheusClient) Timing(name string, value time.Duration, rate float64) { - durationS := float64(value) / float64(time.Second) - c.Histogram(name, float64(durationS), rate) + c.Histogram(name, value.Seconds(), rate) } // SetLogger sets the logger for client.