Skip to content

Commit

Permalink
Add routing header to method metadata (via synth). (#7604)
Browse files Browse the repository at this point in the history
  • Loading branch information
@yoshi-automation @busunkim96
yoshi-automation authored and busunkim96 committed Apr 1, 2019
1 parent 489e9e5 commit 9329ea8
Show file tree
Hide file tree
Showing 4 changed files with 710 additions and 5 deletions.
235 changes: 235 additions & 0 deletions packages/google-cloud-vision/google/cloud/vision_v1/gapic/product_search_client.py
View file
Original file line number Diff line number Diff line change
Expand Up @@ -23,6 +23,7 @@
import google.api_core.gapic_v1.client_info
import google.api_core.gapic_v1.config
import google.api_core.gapic_v1.method
import google.api_core.gapic_v1.routing_header
import google.api_core.grpc_helpers
import google.api_core.operation
from google.api_core import operations_v1
Expand Down Expand Up @@ -303,6 +304,19 @@ def create_product(
request = product_search_service_pb2.CreateProductRequest(
parent=parent, product=product, product_id=product_id
)
if metadata is None:
metadata = []
metadata = list(metadata)
try:
routing_header = [("parent", parent)]
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_product"](
request, retry=retry, timeout=timeout, metadata=metadata
)
Expand Down Expand Up @@ -389,6 +403,19 @@ def list_products(
request = product_search_service_pb2.ListProductsRequest(
parent=parent, page_size=page_size
)
if metadata is None:
metadata = []
metadata = list(metadata)
try:
routing_header = [("parent", parent)]
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 @@ -462,6 +489,19 @@ def get_product(
)

request = product_search_service_pb2.GetProductRequest(name=name)
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["get_product"](
request, retry=retry, timeout=timeout, metadata=metadata
)
Expand Down Expand Up @@ -546,6 +586,19 @@ def update_product(
request = product_search_service_pb2.UpdateProductRequest(
product=product, update_mask=update_mask
)
if metadata is None:
metadata = []
metadata = list(metadata)
try:
routing_header = [("product.name", product.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_product"](
request, retry=retry, timeout=timeout, metadata=metadata
)
Expand Down Expand Up @@ -609,6 +662,19 @@ def delete_product(
)

request = product_search_service_pb2.DeleteProductRequest(name=name)
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)

self._inner_api_calls["delete_product"](
request, retry=retry, timeout=timeout, metadata=metadata
)
Expand Down Expand Up @@ -696,6 +762,19 @@ def list_reference_images(
request = product_search_service_pb2.ListReferenceImagesRequest(
parent=parent, page_size=page_size
)
if metadata is None:
metadata = []
metadata = list(metadata)
try:
routing_header = [("parent", parent)]
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 @@ -771,6 +850,19 @@ def get_reference_image(
)

request = product_search_service_pb2.GetReferenceImageRequest(name=name)
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["get_reference_image"](
request, retry=retry, timeout=timeout, metadata=metadata
)
Expand Down Expand Up @@ -838,6 +930,19 @@ def delete_reference_image(
)

request = product_search_service_pb2.DeleteReferenceImageRequest(name=name)
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)

self._inner_api_calls["delete_reference_image"](
request, retry=retry, timeout=timeout, metadata=metadata
)
Expand Down Expand Up @@ -934,6 +1039,19 @@ def create_reference_image(
reference_image=reference_image,
reference_image_id=reference_image_id,
)
if metadata is None:
metadata = []
metadata = list(metadata)
try:
routing_header = [("parent", parent)]
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_reference_image"](
request, retry=retry, timeout=timeout, metadata=metadata
)
Expand Down Expand Up @@ -1012,6 +1130,19 @@ def create_product_set(
request = product_search_service_pb2.CreateProductSetRequest(
parent=parent, product_set=product_set, product_set_id=product_set_id
)
if metadata is None:
metadata = []
metadata = list(metadata)
try:
routing_header = [("parent", parent)]
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_product_set"](
request, retry=retry, timeout=timeout, metadata=metadata
)
Expand Down Expand Up @@ -1098,6 +1229,19 @@ def list_product_sets(
request = product_search_service_pb2.ListProductSetsRequest(
parent=parent, page_size=page_size
)
if metadata is None:
metadata = []
metadata = list(metadata)
try:
routing_header = [("parent", parent)]
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 @@ -1172,6 +1316,19 @@ def get_product_set(
)

request = product_search_service_pb2.GetProductSetRequest(name=name)
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["get_product_set"](
request, retry=retry, timeout=timeout, metadata=metadata
)
Expand Down Expand Up @@ -1248,6 +1405,19 @@ def update_product_set(
request = product_search_service_pb2.UpdateProductSetRequest(
product_set=product_set, update_mask=update_mask
)
if metadata is None:
metadata = []
metadata = list(metadata)
try:
routing_header = [("product_set.name", product_set.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_product_set"](
request, retry=retry, timeout=timeout, metadata=metadata
)
Expand Down Expand Up @@ -1311,6 +1481,19 @@ def delete_product_set(
)

request = product_search_service_pb2.DeleteProductSetRequest(name=name)
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)

self._inner_api_calls["delete_product_set"](
request, retry=retry, timeout=timeout, metadata=metadata
)
Expand Down Expand Up @@ -1383,6 +1566,19 @@ def add_product_to_product_set(
request = product_search_service_pb2.AddProductToProductSetRequest(
name=name, product=product
)
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)

self._inner_api_calls["add_product_to_product_set"](
request, retry=retry, timeout=timeout, metadata=metadata
)
Expand Down Expand Up @@ -1454,6 +1650,19 @@ def remove_product_from_product_set(
request = product_search_service_pb2.RemoveProductFromProductSetRequest(
name=name, product=product
)
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)

self._inner_api_calls["remove_product_from_product_set"](
request, retry=retry, timeout=timeout, metadata=metadata
)
Expand Down Expand Up @@ -1545,6 +1754,19 @@ def list_products_in_product_set(
request = product_search_service_pb2.ListProductsInProductSetRequest(
name=name, page_size=page_size
)
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)

iterator = google.api_core.page_iterator.GRPCIterator(
client=None,
method=functools.partial(
Expand Down Expand Up @@ -1643,6 +1865,19 @@ def import_product_sets(
request = product_search_service_pb2.ImportProductSetsRequest(
parent=parent, input_config=input_config
)
if metadata is None:
metadata = []
metadata = list(metadata)
try:
routing_header = [("parent", parent)]
except AttributeError:
pass
else:
routing_metadata = google.api_core.gapic_v1.routing_header.to_grpc_metadata(
routing_header
)
metadata.append(routing_metadata)

operation = self._inner_api_calls["import_product_sets"](
request, retry=retry, timeout=timeout, metadata=metadata
)
Expand Down
Loading

0 comments on commit 9329ea8

Please sign in to comment.