Method Write

pkg/redis/observability.go:77–81

(b []byte)

}

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