diff --git a/Godeps/Godeps.json b/Godeps/Godeps.json index a16b456eb55..5cdf4f43e7d 100644 --- a/Godeps/Godeps.json +++ b/Godeps/Godeps.json @@ -212,83 +212,83 @@ }, { "ImportPath": "github.com/google/cadvisor/api", - "Comment": "0.10.1-92-g41a0c30", - "Rev": "41a0c30fbf4df4d5d711b752785febb6ed5330a4" + "Comment": "0.10.1-103-gbfaf70b", + "Rev": "bfaf70b2555fcaba212130da04a21302344e38f5" }, { "ImportPath": "github.com/google/cadvisor/container", - "Comment": "0.10.1-92-g41a0c30", - "Rev": "41a0c30fbf4df4d5d711b752785febb6ed5330a4" + "Comment": "0.10.1-103-gbfaf70b", + "Rev": "bfaf70b2555fcaba212130da04a21302344e38f5" }, { "ImportPath": "github.com/google/cadvisor/events", - "Comment": "0.10.1-92-g41a0c30", - "Rev": "41a0c30fbf4df4d5d711b752785febb6ed5330a4" + "Comment": "0.10.1-103-gbfaf70b", + "Rev": "bfaf70b2555fcaba212130da04a21302344e38f5" }, { "ImportPath": "github.com/google/cadvisor/fs", - "Comment": "0.10.1-92-g41a0c30", - "Rev": "41a0c30fbf4df4d5d711b752785febb6ed5330a4" + "Comment": "0.10.1-103-gbfaf70b", + "Rev": "bfaf70b2555fcaba212130da04a21302344e38f5" }, { "ImportPath": "github.com/google/cadvisor/healthz", - "Comment": "0.10.1-92-g41a0c30", - "Rev": "41a0c30fbf4df4d5d711b752785febb6ed5330a4" + "Comment": "0.10.1-103-gbfaf70b", + "Rev": "bfaf70b2555fcaba212130da04a21302344e38f5" }, { "ImportPath": "github.com/google/cadvisor/http", - "Comment": "0.10.1-92-g41a0c30", - "Rev": "41a0c30fbf4df4d5d711b752785febb6ed5330a4" + "Comment": "0.10.1-103-gbfaf70b", + "Rev": "bfaf70b2555fcaba212130da04a21302344e38f5" }, { "ImportPath": "github.com/google/cadvisor/info/v1", - "Comment": "0.10.1-92-g41a0c30", - "Rev": "41a0c30fbf4df4d5d711b752785febb6ed5330a4" + "Comment": "0.10.1-103-gbfaf70b", + "Rev": "bfaf70b2555fcaba212130da04a21302344e38f5" }, { "ImportPath": "github.com/google/cadvisor/info/v2", - "Comment": "0.10.1-92-g41a0c30", - "Rev": "41a0c30fbf4df4d5d711b752785febb6ed5330a4" + "Comment": "0.10.1-103-gbfaf70b", + "Rev": "bfaf70b2555fcaba212130da04a21302344e38f5" }, { "ImportPath": "github.com/google/cadvisor/manager", - "Comment": "0.10.1-92-g41a0c30", - "Rev": "41a0c30fbf4df4d5d711b752785febb6ed5330a4" + "Comment": "0.10.1-103-gbfaf70b", + "Rev": "bfaf70b2555fcaba212130da04a21302344e38f5" }, { "ImportPath": "github.com/google/cadvisor/metrics", - "Comment": "0.10.1-92-g41a0c30", - "Rev": "41a0c30fbf4df4d5d711b752785febb6ed5330a4" + "Comment": "0.10.1-103-gbfaf70b", + "Rev": "bfaf70b2555fcaba212130da04a21302344e38f5" }, { "ImportPath": "github.com/google/cadvisor/pages", - "Comment": "0.10.1-92-g41a0c30", - "Rev": "41a0c30fbf4df4d5d711b752785febb6ed5330a4" + "Comment": "0.10.1-103-gbfaf70b", + "Rev": "bfaf70b2555fcaba212130da04a21302344e38f5" }, { "ImportPath": "github.com/google/cadvisor/storage", - "Comment": "0.10.1-92-g41a0c30", - "Rev": "41a0c30fbf4df4d5d711b752785febb6ed5330a4" + "Comment": "0.10.1-103-gbfaf70b", + "Rev": "bfaf70b2555fcaba212130da04a21302344e38f5" }, { "ImportPath": "github.com/google/cadvisor/summary", - "Comment": "0.10.1-92-g41a0c30", - "Rev": "41a0c30fbf4df4d5d711b752785febb6ed5330a4" + "Comment": "0.10.1-103-gbfaf70b", + "Rev": "bfaf70b2555fcaba212130da04a21302344e38f5" }, { "ImportPath": "github.com/google/cadvisor/utils", - "Comment": "0.10.1-92-g41a0c30", - "Rev": "41a0c30fbf4df4d5d711b752785febb6ed5330a4" + "Comment": "0.10.1-103-gbfaf70b", + "Rev": "bfaf70b2555fcaba212130da04a21302344e38f5" }, { "ImportPath": "github.com/google/cadvisor/validate", - "Comment": "0.10.1-92-g41a0c30", - "Rev": "41a0c30fbf4df4d5d711b752785febb6ed5330a4" + "Comment": "0.10.1-103-gbfaf70b", + "Rev": "bfaf70b2555fcaba212130da04a21302344e38f5" }, { "ImportPath": "github.com/google/cadvisor/version", - "Comment": "0.10.1-92-g41a0c30", - "Rev": "41a0c30fbf4df4d5d711b752785febb6ed5330a4" + "Comment": "0.10.1-103-gbfaf70b", + "Rev": "bfaf70b2555fcaba212130da04a21302344e38f5" }, { "ImportPath": "github.com/google/gofuzz", diff --git a/Godeps/_workspace/src/github.com/google/cadvisor/storage/bigquery/bigquery.go b/Godeps/_workspace/src/github.com/google/cadvisor/storage/bigquery/bigquery.go index fe4edf74c01..5f5761efd85 100644 --- a/Godeps/_workspace/src/github.com/google/cadvisor/storage/bigquery/bigquery.go +++ b/Godeps/_workspace/src/github.com/google/cadvisor/storage/bigquery/bigquery.go @@ -73,7 +73,7 @@ const ( // TODO(jnagal): Infer schema through reflection. (See bigquery/client/example) func (self *bigqueryStorage) GetSchema() *bigquery.TableSchema { - fields := make([]*bigquery.TableFieldSchema, 18) + fields := make([]*bigquery.TableFieldSchema, 19) i := 0 fields[i] = &bigquery.TableFieldSchema{ Type: typeTimestamp, diff --git a/Godeps/_workspace/src/github.com/google/cadvisor/storage/bigquery/client/client.go b/Godeps/_workspace/src/github.com/google/cadvisor/storage/bigquery/client/client.go index 8ead5000965..4187db7d09e 100644 --- a/Godeps/_workspace/src/github.com/google/cadvisor/storage/bigquery/client/client.go +++ b/Godeps/_workspace/src/github.com/google/cadvisor/storage/bigquery/client/client.go @@ -18,12 +18,11 @@ import ( "flag" "fmt" "io/ioutil" - "net/http" "strings" - "code.google.com/p/goauth2/oauth" - "code.google.com/p/goauth2/oauth/jwt" bigquery "code.google.com/p/google-api-go-client/bigquery/v2" + "golang.org/x/oauth2" + "golang.org/x/oauth2/jwt" ) var ( @@ -42,13 +41,13 @@ const ( type Client struct { service *bigquery.Service - token *oauth.Token + token *oauth2.Token datasetId string tableId string } // Helper method to create an authenticated connection. -func connect() (*oauth.Token, *bigquery.Service, error) { +func connect() (*oauth2.Token, *bigquery.Service, error) { if *clientId == "" { return nil, nil, fmt.Errorf("no client id specified") } @@ -67,25 +66,30 @@ func connect() (*oauth.Token, *bigquery.Service, error) { return nil, nil, fmt.Errorf("could not access credential file %v - %v", pemFile, err) } - t := jwt.NewToken(*serviceAccount, authScope, pemBytes) - token, err := t.Assert(&http.Client{}) + jwtConfig := &jwt.Config{ + Email: *serviceAccount, + Scopes: []string{authScope}, + PrivateKey: pemBytes, + TokenURL: "https://accounts.google.com/o/oauth2/token", + } + token, err := jwtConfig.TokenSource(oauth2.NoContext).Token() if err != nil { - fmt.Printf("Invalid token: %v\n", err) return nil, nil, err } - config := &oauth.Config{ - ClientId: *clientId, - ClientSecret: *clientSecret, - Scope: authScope, - AuthURL: "https://accounts.google.com/o/oauth2/auth", - TokenURL: "https://accounts.google.com/o/oauth2/token", + if !token.Valid() { + return nil, nil, fmt.Errorf("invalid token for BigQuery oauth") } - transport := &oauth.Transport{ - Token: token, - Config: config, + config := &oauth2.Config{ + ClientID: *clientId, + ClientSecret: *clientSecret, + Scopes: []string{authScope}, + Endpoint: oauth2.Endpoint{ + AuthURL: "https://accounts.google.com/o/oauth2/auth", + TokenURL: "https://accounts.google.com/o/oauth2/token", + }, } - client := transport.Client() + client := config.Client(oauth2.NoContext, token) service, err := bigquery.New(client) if err != nil { @@ -122,7 +126,7 @@ func (c *Client) getService() (*bigquery.Service, error) { } // Refresh expired token. - if c.token.Expired() { + if !c.token.Valid() { token, service, err := connect() if err != nil { return nil, err