revert changes by mistake

Author: Hongyu Zhou

ldb_reader.go

@@ -189,7 +189,7 @@ func (reader *LDBReader) GetRowsByKeyPrefix(ctx context.Context, familyName stri
 		if err != nil {
 			return nil, err
 		}
-		res := &Rows{rows: rows, cols: cols, familyName: familyName, tableName: tableName, start: time.Now()}
+		res := &Rows{rows: rows, cols: cols}
 		return res, nil
 	case err == sql.ErrNoRows:
 		return &Rows{}, nil

rows.go

@@ -2,39 +2,26 @@ package ctlstore
 
 import (
 	"database/sql"
-	"sync"
-	"sync/atomic"
-	"time"
 
-	"github.com/segmentio/stats/v4"
-
-	"github.com/segmentio/ctlstore/pkg/globalstats"
 	"github.com/segmentio/ctlstore/pkg/scanfunc"
 	"github.com/segmentio/ctlstore/pkg/schema"
 )
 
 // Rows composes an *sql.Rows and allows scanning ctlstore table rows into
 // structs or maps, similar to how the GetRowByKey reader method works.
-// It also keeps track of number of rows read and emits as a metric on Close
 //
 // The contract around Next/Err/Close is the same was it is for
 // *sql.Rows.
 type Rows struct {
-	rows       *sql.Rows
-	cols       []schema.DBColumnMeta
-	familyName string
-	tableName  string
-	count      uint32
-	once       sync.Once
-	start      time.Time
+	rows *sql.Rows
+	cols []schema.DBColumnMeta
 }
 
 // Next returns true if there's another row available.
 func (r *Rows) Next() bool {
 	if r.rows == nil {
 		return false
 	}
-	atomic.AddUint32(&r.count, 1)
 	return r.rows.Next()
 }
 
@@ -54,16 +41,6 @@ func (r *Rows) Close() error {
 	if r.rows == nil {
 		return nil
 	}
-	r.once.Do(func() {
-		globalstats.Observe("get_rows_by_key_prefix_row_count", atomic.LoadUint32(&r.count),
-			stats.T("family", r.familyName),
-			stats.T("table", r.tableName))
-		if !r.start.IsZero() {
-			globalstats.Observe("get_rows_by_prefix_scan_time", time.Now().Sub(r.start),
-				stats.T("family", r.familyName),
-				stats.T("table", r.tableName))
-		}
-	})
 	return r.rows.Close()
 }