OLD | NEW |
1 // Copyright 2016 The LUCI Authors. All rights reserved. | 1 // Copyright 2016 The LUCI Authors. All rights reserved. |
2 // Use of this source code is governed under the Apache License, Version 2.0 | 2 // Use of this source code is governed under the Apache License, Version 2.0 |
3 // that can be found in the LICENSE file. | 3 // that can be found in the LICENSE file. |
4 | 4 |
5 package service | 5 package service |
6 | 6 |
7 import ( | 7 import ( |
8 "errors" | 8 "errors" |
9 "flag" | 9 "flag" |
10 "fmt" | 10 "fmt" |
(...skipping 14 matching lines...) Expand all Loading... |
25 "github.com/luci/luci-go/common/logging/gologger" | 25 "github.com/luci/luci-go/common/logging/gologger" |
26 "github.com/luci/luci-go/common/tsmon" | 26 "github.com/luci/luci-go/common/tsmon" |
27 "github.com/luci/luci-go/common/tsmon/target" | 27 "github.com/luci/luci-go/common/tsmon/target" |
28 "github.com/luci/luci-go/grpc/prpc" | 28 "github.com/luci/luci-go/grpc/prpc" |
29 "github.com/luci/luci-go/logdog/api/config/svcconfig" | 29 "github.com/luci/luci-go/logdog/api/config/svcconfig" |
30 "github.com/luci/luci-go/logdog/api/endpoints/coordinator/services/v1" | 30 "github.com/luci/luci-go/logdog/api/endpoints/coordinator/services/v1" |
31 "github.com/luci/luci-go/logdog/common/storage" | 31 "github.com/luci/luci-go/logdog/common/storage" |
32 "github.com/luci/luci-go/logdog/common/storage/bigtable" | 32 "github.com/luci/luci-go/logdog/common/storage/bigtable" |
33 "github.com/luci/luci-go/logdog/server/retryServicesClient" | 33 "github.com/luci/luci-go/logdog/server/retryServicesClient" |
34 "github.com/luci/luci-go/logdog/server/service/config" | 34 "github.com/luci/luci-go/logdog/server/service/config" |
| 35 |
| 36 "cloud.google.com/go/compute/metadata" |
35 "golang.org/x/net/context" | 37 "golang.org/x/net/context" |
36 » "google.golang.org/cloud" | 38 » "google.golang.org/api/option" |
37 » "google.golang.org/cloud/compute/metadata" | |
38 ) | 39 ) |
39 | 40 |
40 var ( | 41 var ( |
41 // ErrInvalidConfig is an error that is returned when the supplied | 42 // ErrInvalidConfig is an error that is returned when the supplied |
42 // configuration is invalid. | 43 // configuration is invalid. |
43 ErrInvalidConfig = errors.New("invalid configuration") | 44 ErrInvalidConfig = errors.New("invalid configuration") |
44 | 45 |
45 // CoordinatorScopes is the set of OAuth2 scopes to use for the Coordina
tor | 46 // CoordinatorScopes is the set of OAuth2 scopes to use for the Coordina
tor |
46 // client. | 47 // client. |
47 CoordinatorScopes = []string{ | 48 CoordinatorScopes = []string{ |
(...skipping 337 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
385 }) | 386 }) |
386 if err != nil { | 387 if err != nil { |
387 log.WithError(err).Errorf(c, "Failed to create BigTable Authenti
cator.") | 388 log.WithError(err).Errorf(c, "Failed to create BigTable Authenti
cator.") |
388 return nil, err | 389 return nil, err |
389 } | 390 } |
390 | 391 |
391 bt, err := bigtable.New(c, bigtable.Options{ | 392 bt, err := bigtable.New(c, bigtable.Options{ |
392 Project: btcfg.Project, | 393 Project: btcfg.Project, |
393 Instance: btcfg.Instance, | 394 Instance: btcfg.Instance, |
394 LogTable: btcfg.LogTableName, | 395 LogTable: btcfg.LogTableName, |
395 » » ClientOptions: []cloud.ClientOption{ | 396 » » ClientOptions: []option.ClientOption{ |
396 » » » cloud.WithTokenSource(a.TokenSource()), | 397 » » » option.WithTokenSource(a.TokenSource()), |
397 }, | 398 }, |
398 }) | 399 }) |
399 if err != nil { | 400 if err != nil { |
400 return nil, err | 401 return nil, err |
401 } | 402 } |
402 return bt, nil | 403 return bt, nil |
403 } | 404 } |
404 | 405 |
405 // GSClient returns an authenticated Google Storage client instance. | 406 // GSClient returns an authenticated Google Storage client instance. |
406 func (s *Service) GSClient(c context.Context) (gs.Client, error) { | 407 func (s *Service) GSClient(c context.Context) (gs.Client, error) { |
(...skipping 47 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
454 // | 455 // |
455 // An optional permutation functon can be provided to modify those Options | 456 // An optional permutation functon can be provided to modify those Options |
456 // before the Authenticator is created. | 457 // before the Authenticator is created. |
457 func (s *Service) AuthenticatedClient(c context.Context, f func(o *auth.Options)
) (*http.Client, error) { | 458 func (s *Service) AuthenticatedClient(c context.Context, f func(o *auth.Options)
) (*http.Client, error) { |
458 a, err := s.Authenticator(c, f) | 459 a, err := s.Authenticator(c, f) |
459 if err != nil { | 460 if err != nil { |
460 return nil, err | 461 return nil, err |
461 } | 462 } |
462 return a.Client() | 463 return a.Client() |
463 } | 464 } |
OLD | NEW |