Index: common/tsmon/monitor/pubsub.go |
diff --git a/common/tsmon/monitor/pubsub.go b/common/tsmon/monitor/pubsub.go |
index 7345924c8efde41c8be5ba083547c472e8cd7cff..a08bf7e738486d3304d2ea7c428967e8adf1845b 100644 |
--- a/common/tsmon/monitor/pubsub.go |
+++ b/common/tsmon/monitor/pubsub.go |
@@ -7,10 +7,10 @@ package monitor |
import ( |
"net/http" |
+ "cloud.google.com/go/pubsub" |
"github.com/golang/protobuf/proto" |
"golang.org/x/net/context" |
- "google.golang.org/cloud" |
- "google.golang.org/cloud/pubsub" |
+ "google.golang.org/api/option" |
gcps "github.com/luci/luci-go/common/gcloud/pubsub" |
"github.com/luci/luci-go/common/logging" |
@@ -29,7 +29,7 @@ type pubSubMonitor struct { |
func NewPubsubMonitor(ctx context.Context, client *http.Client, topic gcps.Topic) (Monitor, error) { |
project, name := topic.Split() |
- psClient, err := pubsub.NewClient(ctx, project, cloud.WithBaseHTTP(client)) |
+ psClient, err := pubsub.NewClient(ctx, project, option.WithHTTPClient(client)) |
if err != nil { |
return nil, err |
} |