tSrSSKJr SSKJr SSKJr SSKrSSKJr SSK J r SSK J r SSKJ r SSKJ r SSKJr SSKJr SS KJr SS KJr S R/S R1\"\R4Vs/sHoR6PM sn555rSqS \S\4Sjr Sr!Sr"SSjr#SSjr$gs snf)z5Returns correct API client instance for user command.)absolute_import)division)unicode_literalsN)errorsclient) storage_url)log) propertiesz-Invalid provider. Valid provider prefixes: {}z, bucket_namereturncRU(aU[RR:wag[R"5nUR U5nUR S:H$![Ra5n[USS5nUS;a[R"SX5 SnAgeSnAff=f)z7Returns true if the given bucket is a GCS zonal bucket.Fzone status_codeN)iiiz.Failed to get storage layout for bucket %s: %s) r ProviderPrefixGCSgcs_json_client JsonClientget_storage_layout locationTypecloud_api_errors CloudApiErrorgetattrr debug)providerr api_clientstorage_layouters 1lib/googlecloudsdk/api_lib/storage/api_factory.py_is_gcs_zonal_bucketr 0s K$>$>$B$BB ))+*  22;?N  & && 00  ' '  !]D1Ko% ii :K    sAB&1*B! B!!B&cU[RR:XGarU(a([R"S5 SSKJn UR$[RRRR5(dX[RRRR5[RR R":Xa&[R"S5 [$R&$[RRR(R5(aG[RRR*R5(a[,R.$[0R2$U[RR4:Xa[6R8$[:R<"[>5e)aMReturns a CloudApi subclass corresponding to the requested provider. Args: provider (storage_url.ProviderPrefix): Cloud provider prefix. is_zonal_bucket (bool): Whether the bucket is a zonal bucket. Returns: An appropriate CloudApi subclass. Raises: Error: If provider is not a cloud scheme in storage_url.ProviderPrefix. z2Using gRPC Bidi Streaming client for zonal bucket.rrz%Using gRPC client with JSON Fallback.) r rrr r6googlecloudsdk.api_lib.storage.gcs_grpc_bidi_streamingrGcsGrpcBidiStreamingClientr VALUESstorageuse_grpc_if_availableGetBool preferred_apiGetStoragePreferredApiGRPC_WITH_JSON_FALLBACKvaluegcs_grpc_clientGrpcClientWithJsonFallbackgs_xml_access_key_idgs_xml_secret_access_keygcs_xml_client XmlClientrrS3 s3_xml_client S3XmlClientrError _INVALID_PROVIDER_PREFIX_MESSAGE)ris_zonal_bucketgrpc_bidi_streaming_clients r_get_api_classr:Es8++/// iiDEm ' B BB   66>>@@!!//335  ) ) A A G G H ii78  7 77!!66::<<    % % > > B B D D  % %%  % %%;--000  $ $$ ,,7 88cHU(aURS3$UR$)zGReturns the thread local storage key for the given provider and bucket._zonal)r,)rr8s r_get_thread_local_storage_keyr>rs$nn V $$ NN r;c[X5n[RRRR 5(aC[ (d[R"5q[[ [X5S5nU(aU$[X5nU"5n[RRRR 5(a[[ [X5U5 U$)a-Returns thread local API instance based on provider and bucket(if available). Uses thread local storage to make sure only one instance of an API exists per thread per provider + bucket type. Args: provider (storage_url.ProviderPrefix): Cloud provider prefix. bucket_name (str): Name of the bucket. If available, the API client will be chosen based on the bucket type as well. Currently only supported for GCS. Returns: CloudApi client object for the arguments. Raises: Error: If provider is not a cloud scheme in storage_url.ProviderPrefix. N) r r r$r%use_threading_localr'_cloud_api_thread_local_storage threadinglocalrr>r:setattr)rr r8r api_classs rget_apirFys.)?/22::<< * *(1(9%'%h@ J  X7){*22::<< '%h@ r;cD[U[X55nUR$)aGets the capabilities of a cloud provider. Args: provider (storage_url.ProviderPrefix): Cloud provider prefix. bucket_name (str): Name of the bucket. If available, the API client will be chosen based on the bucket type as well. Currently only supported for GCS. Returns: The CloudApi.capabilities attribute for the requested provider. Raises: Error: If provider is not a cloud scheme in storage_url.ProviderPrefix. )r:r capabilities)rr rEs rget_capabilitiesrIs'$X;)   r;)N)%__doc__ __future__rrrrBgooglecloudsdk.api_lib.storagerr'googlecloudsdk.api_lib.storage.gcs_grpcrr-'googlecloudsdk.api_lib.storage.gcs_jsonr&googlecloudsdk.api_lib.storage.gcs_xmlr1%googlecloudsdk.api_lib.storage.s3_xmlr4"googlecloudsdk.command_lib.storager googlecloudsdk.corer r formatjoinsortedVALID_CLOUD_SCHEMESr,r7rAstrboolr r:r>rFrI)schemes0rrZs<''EMMKI5:#*4:: {/N/NO/NVLL/NO P !#'   **9Z/d KPs5B5