| Index: logdog/server/cmd/logdog_collector/main.go
|
| diff --git a/logdog/server/cmd/logdog_collector/main.go b/logdog/server/cmd/logdog_collector/main.go
|
| index 190655ae62dea14043b3136baba44cb2286ee850..e07015dc0b140319ba6db097425f807f55297d0d 100644
|
| --- a/logdog/server/cmd/logdog_collector/main.go
|
| +++ b/logdog/server/cmd/logdog_collector/main.go
|
| @@ -22,8 +22,9 @@ import (
|
| "github.com/luci/luci-go/logdog/server/collector/coordinator"
|
| "github.com/luci/luci-go/logdog/server/service"
|
| "golang.org/x/net/context"
|
| - "google.golang.org/cloud"
|
| - "google.golang.org/cloud/pubsub"
|
| +
|
| + "cloud.google.com/go/pubsub"
|
| + "google.golang.org/api/option"
|
| )
|
|
|
| var (
|
| @@ -87,7 +88,7 @@ func (a *application) runCollector(c context.Context) error {
|
| return err
|
| }
|
|
|
| - psClient, err := pubsub.NewClient(c, pscfg.Project, cloud.WithTokenSource(psAuth.TokenSource()))
|
| + psClient, err := pubsub.NewClient(c, pscfg.Project, option.WithTokenSource(psAuth.TokenSource()))
|
| if err != nil {
|
| log.Fields{
|
| log.ErrorKey: err,
|
|
|