Pub/sub: Add routing header to method metadata (via synth).

pubsub/google/cloud/pubsub_v1/gapic/publisher_client.py

@@ -24,6 +24,7 @@
 import google.api_core.gapic_v1.config
 import google.api_core.gapic_v1.method
 import google.api_core.path_template
+import google.api_core.gapic_v1.routing_header
 import google.api_core.grpc_helpers
 import google.api_core.page_iterator
 import google.api_core.path_template
@@ -267,6 +268,19 @@ def create_topic(
  request = pubsub_pb2.Topic(
  name=name, labels=labels, message_storage_policy=message_storage_policy
  )
+ if metadata is None:
+ metadata = []
+ metadata = list(metadata)
+ try:
+ routing_header = [("name", name)]
+ except AttributeError:
+ pass
+ else:
+ routing_metadata = google.api_core.gapic_v1.routing_header.to_grpc_metadata(
+ routing_header
+ )
+ metadata.append(routing_metadata)
+
  return self._inner_api_calls["create_topic"](
  request, retry=retry, timeout=timeout, metadata=metadata
  )
@@ -341,6 +355,19 @@ def update_topic(
  )
 
  request = pubsub_pb2.UpdateTopicRequest(topic=topic, update_mask=update_mask)
+ if metadata is None:
+ metadata = []
+ metadata = list(metadata)
+ try:
+ routing_header = [("topic.name", topic.name)]
+ except AttributeError:
+ pass
+ else:
+ routing_metadata = google.api_core.gapic_v1.routing_header.to_grpc_metadata(
+ routing_header
+ )
+ metadata.append(routing_metadata)
+
  return self._inner_api_calls["update_topic"](
  request, retry=retry, timeout=timeout, metadata=metadata
  )
@@ -407,6 +434,19 @@ def publish(
  )
 
  request = pubsub_pb2.PublishRequest(topic=topic, messages=messages)
+ if metadata is None:
+ metadata = []
+ metadata = list(metadata)
+ try:
+ routing_header = [("topic", topic)]
+ except AttributeError:
+ pass
+ else:
+ routing_metadata = google.api_core.gapic_v1.routing_header.to_grpc_metadata(
+ routing_header
+ )
+ metadata.append(routing_metadata)
+
  return self._inner_api_calls["publish"](
  request, retry=retry, timeout=timeout, metadata=metadata
  )
@@ -464,6 +504,19 @@ def get_topic(
  )
 
  request = pubsub_pb2.GetTopicRequest(topic=topic)
+ if metadata is None:
+ metadata = []
+ metadata = list(metadata)
+ try:
+ routing_header = [("topic", topic)]
+ except AttributeError:
+ pass
+ else:
+ routing_metadata = google.api_core.gapic_v1.routing_header.to_grpc_metadata(
+ routing_header
+ )
+ metadata.append(routing_metadata)
+
  return self._inner_api_calls["get_topic"](
  request, retry=retry, timeout=timeout, metadata=metadata
  )
@@ -542,6 +595,19 @@ def list_topics(
  )
 
  request = pubsub_pb2.ListTopicsRequest(project=project, page_size=page_size)
+ if metadata is None:
+ metadata = []
+ metadata = list(metadata)
+ try:
+ routing_header = [("project", project)]
+ except AttributeError:
+ pass
+ else:
+ routing_metadata = google.api_core.gapic_v1.routing_header.to_grpc_metadata(
+ routing_header
+ )
+ metadata.append(routing_metadata)
+
  iterator = google.api_core.page_iterator.GRPCIterator(
  client=None,
  method=functools.partial(
@@ -633,6 +699,19 @@ def list_topic_subscriptions(
  request = pubsub_pb2.ListTopicSubscriptionsRequest(
  topic=topic, page_size=page_size
  )
+ if metadata is None:
+ metadata = []
+ metadata = list(metadata)
+ try:
+ routing_header = [("topic", topic)]
+ except AttributeError:
+ pass
+ else:
+ routing_metadata = google.api_core.gapic_v1.routing_header.to_grpc_metadata(
+ routing_header
+ )
+ metadata.append(routing_metadata)
+
  iterator = google.api_core.page_iterator.GRPCIterator(
  client=None,
  method=functools.partial(
@@ -703,6 +782,19 @@ def delete_topic(
  )
 
  request = pubsub_pb2.DeleteTopicRequest(topic=topic)
+ if metadata is None:
+ metadata = []
+ metadata = list(metadata)
+ try:
+ routing_header = [("topic", topic)]
+ except AttributeError:
+ pass
+ else:
+ routing_metadata = google.api_core.gapic_v1.routing_header.to_grpc_metadata(
+ routing_header
+ )
+ metadata.append(routing_metadata)
+
  self._inner_api_calls["delete_topic"](
  request, retry=retry, timeout=timeout, metadata=metadata
  )
@@ -773,6 +865,19 @@ def set_iam_policy(
  )
 
  request = iam_policy_pb2.SetIamPolicyRequest(resource=resource, policy=policy)
+ if metadata is None:
+ metadata = []
+ metadata = list(metadata)
+ try:
+ routing_header = [("resource", resource)]
+ except AttributeError:
+ pass
+ else:
+ routing_metadata = google.api_core.gapic_v1.routing_header.to_grpc_metadata(
+ routing_header
+ )
+ metadata.append(routing_metadata)
+
  return self._inner_api_calls["set_iam_policy"](
  request, retry=retry, timeout=timeout, metadata=metadata
  )
@@ -833,6 +938,19 @@ def get_iam_policy(
  )
 
  request = iam_policy_pb2.GetIamPolicyRequest(resource=resource)
+ if metadata is None:
+ metadata = []
+ metadata = list(metadata)
+ try:
+ routing_header = [("resource", resource)]
+ except AttributeError:
+ pass
+ else:
+ routing_metadata = google.api_core.gapic_v1.routing_header.to_grpc_metadata(
+ routing_header
+ )
+ metadata.append(routing_metadata)
+
  return self._inner_api_calls["get_iam_policy"](
  request, retry=retry, timeout=timeout, metadata=metadata
  )
@@ -903,6 +1021,19 @@ def test_iam_permissions(
  request = iam_policy_pb2.TestIamPermissionsRequest(
  resource=resource, permissions=permissions
  )
+ if metadata is None:
+ metadata = []
+ metadata = list(metadata)
+ try:
+ routing_header = [("resource", resource)]
+ except AttributeError:
+ pass
+ else:
+ routing_metadata = google.api_core.gapic_v1.routing_header.to_grpc_metadata(
+ routing_header
+ )
+ metadata.append(routing_metadata)
+
  return self._inner_api_calls["test_iam_permissions"](
  request, retry=retry, timeout=timeout, metadata=metadata
  )