buildstats: update to new bigquery client surface
Changes for the new cloud.google.com/go/bigquery surface that came out a
couple of weeks ago.
Change-Id: I4e9d66c606df67fe24058e72665bde10bde5ca8d
Reviewed-on: https://go-review.googlesource.com/32444
Reviewed-by: Brad Fitzpatrick <bradfitz@golang.org>
diff --git a/cmd/buildstats/buildstats.go b/cmd/buildstats/buildstats.go
index 52d3634..dbc4aa2 100644
--- a/cmd/buildstats/buildstats.go
+++ b/cmd/buildstats/buildstats.go
@@ -19,6 +19,7 @@
"cloud.google.com/go/bigquery"
"cloud.google.com/go/datastore"
+ "google.golang.org/api/iterator"
)
var (
@@ -60,12 +61,12 @@
log.Fatalf("Read: %v", err)
}
var values bigquery.ValueList
- if !it.Next(ctx) {
+ err = it.Next(&values)
+ if err == iterator.Done {
log.Fatalf("No result.")
}
- err = it.Get(&values)
if err != nil {
- log.Fatalf("Get: %v", err)
+ log.Fatalf("Next: %v", err)
}
t, ok := values[0].(time.Time)
if !ok {
@@ -78,7 +79,7 @@
log.Fatalf("datastore.NewClient: %v", err)
}
- up := buildsTable.NewUploader()
+ up := buildsTable.Uploader()
log.Printf("Max: %v", t)
dsit := ds.Run(ctx, datastore.NewQuery("Build").Filter("EndTime >", t).Filter("EndTime <", t.Add(24*90*time.Hour)).Order("EndTime"))
