Method Read

pkg/redis/observability.go:71–75

(b []byte)

}

func (c *observableConn) Read(b []byte) (n int, err error) {
	n, err = c.Conn.Read(b)
	bytesRx.WithLabelValues(c.addr).Add(float64(n))
	return n, err
}

func (c *observableConn) Write(b []byte) (n int, err error) {
	n, err = c.Conn.Write(b)