Migrate fuzzer to use shiny new metrics2 package

fuzzer/go/fuzzer-fe/main.go

 package main
 
 /*
 Runs the frontend portion of the fuzzer.  This primarily is the webserver (see DESIGN.md)
 */
 
 import (
         "bytes"
         "encoding/base64"
         "encoding/json"
@@ skipping 13 matching lines @@
         "go.skia.org/infra/fuzzer/go/config"
         "go.skia.org/infra/fuzzer/go/frontend"
         "go.skia.org/infra/fuzzer/go/frontend/data"
         "go.skia.org/infra/fuzzer/go/frontend/gsloader"
         "go.skia.org/infra/fuzzer/go/frontend/syncer"
         "go.skia.org/infra/fuzzer/go/fuzzcache"
         "go.skia.org/infra/go/auth"
         "go.skia.org/infra/go/common"
         "go.skia.org/infra/go/fileutil"
         "go.skia.org/infra/go/gs"
+        "go.skia.org/infra/go/influxdb"
         "go.skia.org/infra/go/login"
         "go.skia.org/infra/go/skiaversion"
         "go.skia.org/infra/go/util"
         "golang.org/x/net/context"
         "google.golang.org/cloud"
         "google.golang.org/cloud/storage"
 )
 
 const (
         // OAUTH2_CALLBACK_PATH is callback endpoint used for the Oauth2 flow.
         OAUTH2_CALLBACK_PATH = "/oauth2callback/"
 )
 
 var (
         // indexTemplate is the main index.html page we serve.
         indexTemplate *template.Template = nil
         // detailsTemplate is used for /category, which displays the count of fuzzes in various files
         // as well as the stacktraces.
         detailsTemplate *template.Template = nil
 
         storageClient *storage.Client = nil
 
         versionWatcher *fcommon.VersionWatcher = nil
 
         fuzzSyncer *syncer.FuzzSyncer = nil
 )
 
 var (
         // web server params
-        graphiteServer = flag.String("graphite_server", "localhost:2003", "Where is Graphite metrics ingestion server running.")
-        host           = flag.String("host", "localhost", "HTTP service host")
-        port           = flag.String("port", ":8001", "HTTP service port (e.g., ':8002')")
-        local          = flag.Bool("local", false, "Running locally if true. As opposed to in production.")
-        resourcesDir   = flag.String("resources_dir", "", "The directory to find templates, JS, and CSS files. If blank the current directory will be used.")
-        boltDBPath     = flag.String("bolt_db_path", "fuzzer-db", "The path to the bolt db to be used as a local cache.")
+        influxHost     = flag.String("influxdb_host", influxdb.DEFAULT_HOST, "The InfluxDB hostname.")
+        influxUser     = flag.String("influxdb_name", influxdb.DEFAULT_USER, "The InfluxDB username.")
+        influxPassword = flag.String("influxdb_password", influxdb.DEFAULT_PASSWORD, "The InfluxDB password.")
+        influxDatabase = flag.String("influxdb_database", influxdb.DEFAULT_DATABASE, "The InfluxDB database.")
+
+        host         = flag.String("host", "localhost", "HTTP service host")
+        port         = flag.String("port", ":8001", "HTTP service port (e.g., ':8002')")
+        local        = flag.Bool("local", false, "Running locally if true. As opposed to in production.")
+        resourcesDir = flag.String("resources_dir", "", "The directory to find templates, JS, and CSS files. If blank the current directory will be used.")
+        boltDBPath   = flag.String("bolt_db_path", "fuzzer-db", "The path to the bolt db to be used as a local cache.")
 
         // OAUTH params
         authWhiteList = flag.String("auth_whitelist", login.DEFAULT_DOMAIN_WHITELIST, "White space separated list of domains and email addresses that are allowed to login.")
         redirectURL   = flag.String("redirect_url", "https://fuzzer.skia.org/oauth2callback/", "OAuth2 redirect url. Only used when local=false.")
 
         // Scanning params
         skiaRoot          = flag.String("skia_root", "", "[REQUIRED] The root directory of the Skia source code.")
         clangPath         = flag.String("clang_path", "", "[REQUIRED] The path to the clang executable.")
         clangPlusPlusPath = flag.String("clang_p_p_path", "", "[REQUIRED] The path to the clang++ executable.")
         depotToolsPath    = flag.String("depot_tools_path", "", "The absolute path to depot_tools.  Can be empty if they are on your path.")
@@ skipping 22 matching lines @@
         detailsTemplate.Delims("{%", "%}")
         detailsTemplate = template.Must(detailsTemplate.ParseFiles(
                 filepath.Join(*resourcesDir, "templates/details.html"),
                 filepath.Join(*resourcesDir, "templates/header.html"),
         ))
 }
 
 func main() {
         defer common.LogPanic()
         // Calls flag.Parse()
-        common.InitWithMetrics("fuzzer", graphiteServer)
+        common.InitWithMetrics2("fuzzer-fe", influxHost, influxUser, influxPassword, influxDatabase, local)
 
         if err := writeFlagsToConfig(); err != nil {
                 glog.Fatalf("Problem with configuration: %s", err)
         }
 
         Init()
 
         if err := setupOAuth(); err != nil {
                 glog.Fatal(err)
         }
@@ skipping 354 matching lines @@
         }
         var t bytes.Buffer
         if err := newBugTemplate.Execute(&t, b); err != nil {
                 util.ReportError(w, r, err, fmt.Sprintf("Could not create template with %#v", b))
                 return
         }
         q.Add("comment", t.String())
         // 303 means "make a GET request to this url"
         http.Redirect(w, r, "https://bugs.chromium.org/p/skia/issues/entry?"+q.Encode(), 303)
 }