Remove OpenTelemetry metrics for now

vmihailenco · vmihailenco · commit a7ead1cf74a0 · 2021-06-30T11:14:35.000+03:00
diff --git a/internal/instruments.go b/internal/instruments.go
diff --git a/internal/pool/conn.go b/internal/pool/conn.go
@@ -7,7 +7,6 @@ import (
 	"sync/atomic"
 	"time"
 
-	"github.com/go-redis/redis/v8/internal"
 	"github.com/go-redis/redis/v8/internal/proto"
 )
 
@@ -86,13 +85,7 @@ func (cn *Conn) WithWriter(
 		return err
 	}
 
-	if err := cn.bw.Flush(); err != nil {
-		return err
-	}
-
-	internal.WritesCounter.Add(ctx, 1)
-
-	return nil
+	return cn.bw.Flush()
 }
 
 func (cn *Conn) Close() error {
diff --git a/internal/pool/pool.go b/internal/pool/pool.go
@@ -188,7 +188,6 @@ func (p *ConnPool) dialConn(ctx context.Context, pooled bool) (*Conn, error) {
 		return nil, err
 	}
 
-	internal.NewConnectionsCounter.Add(ctx, 1)
 	cn := NewConn(netConn)
 	cn.pooled = pooled
 	return cn, nil

Original file line number	Diff line number	Diff line change
`@@ -7,7 +7,6 @@ import (`
`7`	`7`	`"sync/atomic"`
`8`	`8`	`"time"`
`9`	`9`
`10`		`- "github.com/go-redis/redis/v8/internal"`
`11`	`10`	`"github.com/go-redis/redis/v8/internal/proto"`
`12`	`11`	`)`
`13`	`12`
`@@ -86,13 +85,7 @@ func (cn *Conn) WithWriter(`
`86`	`85`	`return err`
`87`	`86`	`}`
`88`	`87`
`89`		`- if err := cn.bw.Flush(); err != nil {`
`90`		`- return err`
`91`		`- }`
`92`		`-`
`93`		`- internal.WritesCounter.Add(ctx, 1)`
`94`		`-`
`95`		`- return nil`
	`88`	`+ return cn.bw.Flush()`
`96`	`89`	`}`
`97`	`90`
`98`	`91`	`func (cn *Conn) Close() error {`
Original file line number	Diff line number	Diff line change
`@@ -188,7 +188,6 @@ func (p ConnPool) dialConn(ctx context.Context, pooled bool) (Conn, error) {`
`188`	`188`	`return nil, err`
`189`	`189`	`}`
`190`	`190`
`191`		`- internal.NewConnectionsCounter.Add(ctx, 1)`
`192`	`191`	`cn := NewConn(netConn)`
`193`	`192`	`cn.pooled = pooled`
`194`	`193`	`return cn, nil`