Skip to content

Commit

Permalink
[CHANGE ME] Re-generated pubsub to pick up changes in the API or clie…
Browse files Browse the repository at this point in the history 
…nt library generator.
  • Loading branch information
@yoshi-automation
yoshi-automation committed Mar 30, 2019
1 parent 28ad1a8 commit 1026e45
Show file tree
Hide file tree
Showing 3 changed files with 358 additions and 5 deletions.
131 changes: 131 additions & 0 deletions pubsub/google/cloud/pubsub_v1/gapic/publisher_client.py
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down Expand Up @@ -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
)
Expand Down Expand Up @@ -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
)
Expand Down Expand Up @@ -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
)
Expand Down Expand Up @@ -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
)
Expand Down Expand Up @@ -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(
Expand Down Expand Up @@ -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(
Expand Down Expand Up @@ -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
)
Expand Down Expand Up @@ -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
)
Expand Down Expand Up @@ -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
)
Expand Down Expand Up @@ -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
)
Loading

0 comments on commit 1026e45

Please sign in to comment.