Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(135)

Side by Side Diff: monitoring/go/datahopper/main.go

Issue 777413002: Add new tests to presubmit, fix errors (Closed) Base URL: https://skia.googlesource.com/buildbot@master
Patch Set: rebase Created 6 years ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
« no previous file with comments | « monitoring/go/buildbot_ingest/bycommit.go ('k') | monitoring/go/prober/main.go » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 /* 1 /*
2 Pulls data from multiple sources and funnels into InfluxDB. 2 Pulls data from multiple sources and funnels into InfluxDB.
3 */ 3 */
4 4
5 package main 5 package main
6 6
7 import "flag" 7 import "flag"
8 8
9 import ( 9 import (
10 "github.com/golang/glog" 10 "github.com/golang/glog"
(...skipping 21 matching lines...) Expand all
32 ) 32 )
33 33
34 func main() { 34 func main() {
35 common.InitWithMetrics("datahopper", *graphiteServer) 35 common.InitWithMetrics("datahopper", *graphiteServer)
36 36
37 // Prepare the InfluxDB credentials. Load from metadata if appropriate. 37 // Prepare the InfluxDB credentials. Load from metadata if appropriate.
38 if *useMetadata { 38 if *useMetadata {
39 *influxDbName = metadata.MustGet(INFLUXDB_NAME_METADATA_KEY) 39 *influxDbName = metadata.MustGet(INFLUXDB_NAME_METADATA_KEY)
40 *influxDbPassword = metadata.MustGet(INFLUXDB_PASSWORD_METADATA_ KEY) 40 *influxDbPassword = metadata.MustGet(INFLUXDB_PASSWORD_METADATA_ KEY)
41 } 41 }
42 » dbClient, err := influxdb.New(&influxdb.ClientConfig{*influxDbHost, *inf luxDbName, *influxDbPassword, *influxDbDatabase, nil, false, false}) 42 » dbClient, err := influxdb.New(&influxdb.ClientConfig{
43 » » Host: *influxDbHost,
44 » » Username: *influxDbName,
45 » » Password: *influxDbPassword,
46 » » Database: *influxDbDatabase,
47 » » HttpClient: nil,
48 » » IsSecure: false,
49 » » IsUDP: false,
50 » })
43 if err != nil { 51 if err != nil {
44 glog.Fatalf("Failed to initialize InfluxDB client: %s", err) 52 glog.Fatalf("Failed to initialize InfluxDB client: %s", err)
45 } 53 }
46 54
47 // Data generation goroutines. 55 // Data generation goroutines.
48 go autoroll_ingest.LoadAutoRollData(dbClient, *workdir) 56 go autoroll_ingest.LoadAutoRollData(dbClient, *workdir)
49 go buildbot_ingest.LoadBuildbotDetailsData(dbClient) 57 go buildbot_ingest.LoadBuildbotDetailsData(dbClient)
50 go buildbot_ingest.LoadBuildbotByCommitData(dbClient, *workdir) 58 go buildbot_ingest.LoadBuildbotByCommitData(dbClient, *workdir)
51 59
52 // Wait while the above goroutines generate data. 60 // Wait while the above goroutines generate data.
53 select {} 61 select {}
54 } 62 }
OLDNEW
« no previous file with comments | « monitoring/go/buildbot_ingest/bycommit.go ('k') | monitoring/go/prober/main.go » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698