feat(pubsub): support AuthorityOption (#8460)

coryan · web-flow · commit ea8c65239ad9 · 2022-02-25T20:08:16.000-05:00
By default use `pubsub.googleapis.com` as the `authority` in all
requests, regardless of the `EndpointOption` value.  This improves the
support for PSC and VPC-SC.
diff --git a/google/cloud/pubsub/internal/publisher_metadata.cc b/google/cloud/pubsub/internal/publisher_metadata.cc
@@ -100,6 +100,9 @@ void PublisherMetadata::SetMetadata(grpc::ClientContext& context,
     context.AddMetadata("x-goog-user-project",
                         options.get<UserProjectOption>());
   }
+  if (options.has<AuthorityOption>()) {
+    context.set_authority(options.get<AuthorityOption>());
+  }
 }
 
 GOOGLE_CLOUD_CPP_INLINE_NAMESPACE_END
diff --git a/google/cloud/pubsub/internal/subscriber_metadata.cc b/google/cloud/pubsub/internal/subscriber_metadata.cc
@@ -147,6 +147,9 @@ void SubscriberMetadata::SetMetadata(grpc::ClientContext& context,
     context.AddMetadata("x-goog-user-project",
                         options.get<UserProjectOption>());
   }
+  if (options.has<AuthorityOption>()) {
+    context.set_authority(options.get<AuthorityOption>());
+  }
 }
 
 GOOGLE_CLOUD_CPP_INLINE_NAMESPACE_END

Original file line number	Diff line number	Diff line change
`@@ -100,6 +100,9 @@ void PublisherMetadata::SetMetadata(grpc::ClientContext& context,`
`100`	`100`	`context.AddMetadata("x-goog-user-project",`
`101`	`101`	`options.get<UserProjectOption>());`
`102`	`102`	`}`
	`103`	`+ if (options.has<AuthorityOption>()) {`
	`104`	`+ context.set_authority(options.get<AuthorityOption>());`
	`105`	`+ }`
`103`	`106`	`}`
`104`	`107`
`105`	`108`	`GOOGLE_CLOUD_CPP_INLINE_NAMESPACE_END`
Original file line number	Diff line number	Diff line change
`@@ -147,6 +147,9 @@ void SubscriberMetadata::SetMetadata(grpc::ClientContext& context,`
`147`	`147`	`context.AddMetadata("x-goog-user-project",`
`148`	`148`	`options.get<UserProjectOption>());`
`149`	`149`	`}`
	`150`	`+ if (options.has<AuthorityOption>()) {`
	`151`	`+ context.set_authority(options.get<AuthorityOption>());`
	`152`	`+ }`
`150`	`153`	`}`
`151`	`154`
`152`	`155`	`GOOGLE_CLOUD_CPP_INLINE_NAMESPACE_END`