feat: Add location methods

google/cloud/artifactregistry_v1/services/artifact_registry/async_client.py

@@ -44,6 +44,7 @@
 
 from google.api_core import operation # type: ignore
 from google.api_core import operation_async # type: ignore
+from google.cloud.location import locations_pb2 # type: ignore
 from google.iam.v1 import iam_policy_pb2 # type: ignore
 from google.iam.v1 import policy_pb2 # type: ignore
 from google.protobuf import empty_pb2 # type: ignore
@@ -3271,6 +3272,114 @@ async def sample_update_project_settings():
  # Done; return the response.
  return response
 
+ async def get_location(
+ self,
+ request: Optional[locations_pb2.GetLocationRequest] = None,
+ *,
+ retry: OptionalRetry = gapic_v1.method.DEFAULT,
+ timeout: Union[float, object] = gapic_v1.method.DEFAULT,
+ metadata: Sequence[Tuple[str, str]] = (),
+ ) -> locations_pb2.Location:
+ r"""Gets information about a location.
+
+ Args:
+ request (:class:`~.location_pb2.GetLocationRequest`):
+ The request object. Request message for
+ `GetLocation` method.
+ retry (google.api_core.retry.Retry): Designation of what errors,
+ if any, should be retried.
+ timeout (float): The timeout for this request.
+ metadata (Sequence[Tuple[str, str]]): Strings which should be
+ sent along with the request as metadata.
+ Returns:
+ ~.location_pb2.Location:
+ Location object.
+ """
+ # Create or coerce a protobuf request object.
+ # The request isn't a proto-plus wrapped type,
+ # so it must be constructed via keyword expansion.
+ if isinstance(request, dict):
+ request = locations_pb2.GetLocationRequest(**request)
+
+ # Wrap the RPC method; this adds retry and timeout information,
+ # and friendly error handling.
+ rpc = gapic_v1.method.wrap_method(
+ self._client._transport.get_location,
+ default_timeout=None,
+ client_info=DEFAULT_CLIENT_INFO,
+ )
+
+ # Certain fields should be provided within the metadata header;
+ # add these here.
+ metadata = tuple(metadata) + (
+ gapic_v1.routing_header.to_grpc_metadata((("name", request.name),)),
+ )
+
+ # Send the request.
+ response = await rpc(
+ request,
+ retry=retry,
+ timeout=timeout,
+ metadata=metadata,
+ )
+
+ # Done; return the response.
+ return response
+
+ async def list_locations(
+ self,
+ request: Optional[locations_pb2.ListLocationsRequest] = None,
+ *,
+ retry: OptionalRetry = gapic_v1.method.DEFAULT,
+ timeout: Union[float, object] = gapic_v1.method.DEFAULT,
+ metadata: Sequence[Tuple[str, str]] = (),
+ ) -> locations_pb2.ListLocationsResponse:
+ r"""Lists information about the supported locations for this service.
+
+ Args:
+ request (:class:`~.location_pb2.ListLocationsRequest`):
+ The request object. Request message for
+ `ListLocations` method.
+ retry (google.api_core.retry.Retry): Designation of what errors,
+ if any, should be retried.
+ timeout (float): The timeout for this request.
+ metadata (Sequence[Tuple[str, str]]): Strings which should be
+ sent along with the request as metadata.
+ Returns:
+ ~.location_pb2.ListLocationsResponse:
+ Response message for ``ListLocations`` method.
+ """
+ # Create or coerce a protobuf request object.
+ # The request isn't a proto-plus wrapped type,
+ # so it must be constructed via keyword expansion.
+ if isinstance(request, dict):
+ request = locations_pb2.ListLocationsRequest(**request)
+
+ # Wrap the RPC method; this adds retry and timeout information,
+ # and friendly error handling.
+ rpc = gapic_v1.method.wrap_method(
+ self._client._transport.list_locations,
+ default_timeout=None,
+ client_info=DEFAULT_CLIENT_INFO,
+ )
+
+ # Certain fields should be provided within the metadata header;
+ # add these here.
+ metadata = tuple(metadata) + (
+ gapic_v1.routing_header.to_grpc_metadata((("name", request.name),)),
+ )
+
+ # Send the request.
+ response = await rpc(
+ request,
+ retry=retry,
+ timeout=timeout,
+ metadata=metadata,
+ )
+
+ # Done; return the response.
+ return response
+
  async def __aenter__(self):
  return self
 

google/cloud/artifactregistry_v1/services/artifact_registry/client.py

@@ -48,6 +48,7 @@
 
 from google.api_core import operation # type: ignore
 from google.api_core import operation_async # type: ignore
+from google.cloud.location import locations_pb2 # type: ignore
 from google.iam.v1 import iam_policy_pb2 # type: ignore
 from google.iam.v1 import policy_pb2 # type: ignore
 from google.protobuf import empty_pb2 # type: ignore
@@ -3653,6 +3654,114 @@ def __exit__(self, type, value, traceback):
  """
  self.transport.close()
 
+ def get_location(
+ self,
+ request: Optional[locations_pb2.GetLocationRequest] = None,
+ *,
+ retry: OptionalRetry = gapic_v1.method.DEFAULT,
+ timeout: Union[float, object] = gapic_v1.method.DEFAULT,
+ metadata: Sequence[Tuple[str, str]] = (),
+ ) -> locations_pb2.Location:
+ r"""Gets information about a location.
+
+ Args:
+ request (:class:`~.location_pb2.GetLocationRequest`):
+ The request object. Request message for
+ `GetLocation` method.
+ retry (google.api_core.retry.Retry): Designation of what errors,
+ if any, should be retried.
+ timeout (float): The timeout for this request.
+ metadata (Sequence[Tuple[str, str]]): Strings which should be
+ sent along with the request as metadata.
+ Returns:
+ ~.location_pb2.Location:
+ Location object.
+ """
+ # Create or coerce a protobuf request object.
+ # The request isn't a proto-plus wrapped type,
+ # so it must be constructed via keyword expansion.
+ if isinstance(request, dict):
+ request = locations_pb2.GetLocationRequest(**request)
+
+ # Wrap the RPC method; this adds retry and timeout information,
+ # and friendly error handling.
+ rpc = gapic_v1.method.wrap_method(
+ self._transport.get_location,
+ default_timeout=None,
+ client_info=DEFAULT_CLIENT_INFO,
+ )
+
+ # Certain fields should be provided within the metadata header;
+ # add these here.
+ metadata = tuple(metadata) + (
+ gapic_v1.routing_header.to_grpc_metadata((("name", request.name),)),
+ )
+
+ # Send the request.
+ response = rpc(
+ request,
+ retry=retry,
+ timeout=timeout,
+ metadata=metadata,
+ )
+
+ # Done; return the response.
+ return response
+
+ def list_locations(
+ self,
+ request: Optional[locations_pb2.ListLocationsRequest] = None,
+ *,
+ retry: OptionalRetry = gapic_v1.method.DEFAULT,
+ timeout: Union[float, object] = gapic_v1.method.DEFAULT,
+ metadata: Sequence[Tuple[str, str]] = (),
+ ) -> locations_pb2.ListLocationsResponse:
+ r"""Lists information about the supported locations for this service.
+
+ Args:
+ request (:class:`~.location_pb2.ListLocationsRequest`):
+ The request object. Request message for
+ `ListLocations` method.
+ retry (google.api_core.retry.Retry): Designation of what errors,
+ if any, should be retried.
+ timeout (float): The timeout for this request.
+ metadata (Sequence[Tuple[str, str]]): Strings which should be
+ sent along with the request as metadata.
+ Returns:
+ ~.location_pb2.ListLocationsResponse:
+ Response message for ``ListLocations`` method.
+ """
+ # Create or coerce a protobuf request object.
+ # The request isn't a proto-plus wrapped type,
+ # so it must be constructed via keyword expansion.
+ if isinstance(request, dict):
+ request = locations_pb2.ListLocationsRequest(**request)
+
+ # Wrap the RPC method; this adds retry and timeout information,
+ # and friendly error handling.
+ rpc = gapic_v1.method.wrap_method(
+ self._transport.list_locations,
+ default_timeout=None,
+ client_info=DEFAULT_CLIENT_INFO,
+ )
+
+ # Certain fields should be provided within the metadata header;
+ # add these here.
+ metadata = tuple(metadata) + (
+ gapic_v1.routing_header.to_grpc_metadata((("name", request.name),)),
+ )
+
+ # Send the request.
+ response = rpc(
+ request,
+ retry=retry,
+ timeout=timeout,
+ metadata=metadata,
+ )
+
+ # Done; return the response.
+ return response
+
 
 DEFAULT_CLIENT_INFO = gapic_v1.client_info.ClientInfo(
  gapic_version=package_version.__version__

google/cloud/artifactregistry_v1/services/artifact_registry/transports/base.py

@@ -22,6 +22,7 @@
 from google.api_core import retry as retries
 import google.auth # type: ignore
 from google.auth import credentials as ga_credentials # type: ignore
+from google.cloud.location import locations_pb2 # type: ignore
 from google.iam.v1 import iam_policy_pb2 # type: ignore
 from google.iam.v1 import policy_pb2 # type: ignore
 from google.longrunning import operations_pb2 # type: ignore
@@ -527,6 +528,27 @@ def update_project_settings(
  ]:
  raise NotImplementedError()
 
+ @property
+ def get_location(
+ self,
+ ) -> Callable[
+ [locations_pb2.GetLocationRequest],
+ Union[locations_pb2.Location, Awaitable[locations_pb2.Location]],
+ ]:
+ raise NotImplementedError()
+
+ @property
+ def list_locations(
+ self,
+ ) -> Callable[
+ [locations_pb2.ListLocationsRequest],
+ Union[
+ locations_pb2.ListLocationsResponse,
+ Awaitable[locations_pb2.ListLocationsResponse],
+ ],
+ ]:
+ raise NotImplementedError()
+
  @property
  def kind(self) -> str:
  raise NotImplementedError()

google/cloud/artifactregistry_v1/services/artifact_registry/transports/grpc.py

@@ -20,6 +20,7 @@
 import google.auth # type: ignore
 from google.auth import credentials as ga_credentials # type: ignore
 from google.auth.transport.grpc import SslCredentials # type: ignore
+from google.cloud.location import locations_pb2 # type: ignore
 from google.iam.v1 import iam_policy_pb2 # type: ignore
 from google.iam.v1 import policy_pb2 # type: ignore
 from google.longrunning import operations_pb2 # type: ignore
@@ -977,6 +978,42 @@ def update_project_settings(
  def close(self):
  self.grpc_channel.close()
 
+ @property
+ def list_locations(
+ self,
+ ) -> Callable[
+ [locations_pb2.ListLocationsRequest], locations_pb2.ListLocationsResponse
+ ]:
+ r"""Return a callable for the list locations method over gRPC."""
+ # Generate a "stub function" on-the-fly which will actually make
+ # the request.
+ # gRPC handles serialization and deserialization, so we just need
+ # to pass in the functions for each.
+ if "list_locations" not in self._stubs:
+ self._stubs["list_locations"] = self.grpc_channel.unary_unary(
+ "/google.cloud.location.Locations/ListLocations",
+ request_serializer=locations_pb2.ListLocationsRequest.SerializeToString,
+ response_deserializer=locations_pb2.ListLocationsResponse.FromString,
+ )
+ return self._stubs["list_locations"]
+
+ @property
+ def get_location(
+ self,
+ ) -> Callable[[locations_pb2.GetLocationRequest], locations_pb2.Location]:
+ r"""Return a callable for the list locations method over gRPC."""
+ # Generate a "stub function" on-the-fly which will actually make
+ # the request.
+ # gRPC handles serialization and deserialization, so we just need
+ # to pass in the functions for each.
+ if "get_location" not in self._stubs:
+ self._stubs["get_location"] = self.grpc_channel.unary_unary(
+ "/google.cloud.location.Locations/GetLocation",
+ request_serializer=locations_pb2.GetLocationRequest.SerializeToString,
+ response_deserializer=locations_pb2.Location.FromString,
+ )
+ return self._stubs["get_location"]
+
  @property
  def kind(self) -> str:
  return "grpc"

google/cloud/artifactregistry_v1/services/artifact_registry/transports/grpc_asyncio.py

@@ -19,6 +19,7 @@
 from google.api_core import gapic_v1, grpc_helpers_async, operations_v1
 from google.auth import credentials as ga_credentials # type: ignore
 from google.auth.transport.grpc import SslCredentials # type: ignore
+from google.cloud.location import locations_pb2 # type: ignore
 from google.iam.v1 import iam_policy_pb2 # type: ignore
 from google.iam.v1 import policy_pb2 # type: ignore
 from google.longrunning import operations_pb2 # type: ignore
@@ -1015,5 +1016,41 @@ def update_project_settings(
  def close(self):
  return self.grpc_channel.close()
 
+ @property
+ def list_locations(
+ self,
+ ) -> Callable[
+ [locations_pb2.ListLocationsRequest], locations_pb2.ListLocationsResponse
+ ]:
+ r"""Return a callable for the list locations method over gRPC."""
+ # Generate a "stub function" on-the-fly which will actually make
+ # the request.
+ # gRPC handles serialization and deserialization, so we just need
+ # to pass in the functions for each.
+ if "list_locations" not in self._stubs:
+ self._stubs["list_locations"] = self.grpc_channel.unary_unary(
+ "/google.cloud.location.Locations/ListLocations",
+ request_serializer=locations_pb2.ListLocationsRequest.SerializeToString,
+ response_deserializer=locations_pb2.ListLocationsResponse.FromString,
+ )
+ return self._stubs["list_locations"]
+
+ @property
+ def get_location(
+ self,
+ ) -> Callable[[locations_pb2.GetLocationRequest], locations_pb2.Location]:
+ r"""Return a callable for the list locations method over gRPC."""
+ # Generate a "stub function" on-the-fly which will actually make
+ # the request.
+ # gRPC handles serialization and deserialization, so we just need
+ # to pass in the functions for each.
+ if "get_location" not in self._stubs:
+ self._stubs["get_location"] = self.grpc_channel.unary_unary(
+ "/google.cloud.location.Locations/GetLocation",
+ request_serializer=locations_pb2.GetLocationRequest.SerializeToString,
+ response_deserializer=locations_pb2.Location.FromString,
+ )
+ return self._stubs["get_location"]
+
 
 __all__ = ("ArtifactRegistryGrpcAsyncIOTransport",)