UPSrSSKJr SSKJr SSKJr SSKrSSKrSSKJr SSK J r Sr "S S \ 5r "S S \ 5r"S S\5r"SS\5r"SS\5r"SS\5r"SS\5r"SS\ 5r"SS\5r"SS\ 5r"SS\ 5rSrg) z?Classes for cloud/file references yielded by storage iterators.)absolute_import)division)unicode_literalsN)errors) resource_util_NOT_SUPPORTED_DO_NOT_DISPLAYcJ\rSrSrSrSrSrSrSrSr Sr \ S 5r S r g ) ResourceaBase class for a reference to one fully expanded iterator result. This allows polymorphic iteration over wildcard-iterated URLs. The reference contains a fully expanded URL string containing no wildcards and referring to exactly one entity (if a wildcard is contained, it is assumed this is part of the raw string and should never be treated as a wildcard). Each reference represents a Bucket, Object, or Prefix. For filesystem URLs, Objects represent files and Prefixes represent directories. The metadata_object member contains the underlying object as it was retrieved. It is populated by the calling iterator, which may only request certain fields to reduce the number of server requests. For filesystem and prefix URLs, metadata_object is not populated. Attributes: TYPE_STRING (str): String representing the resource's content type. storage_url (StorageUrl): A StorageUrl object representing the resource. resourcecXlg)zInitialize the Resource object. Args: storage_url_object (StorageUrl): A StorageUrl object representing the resource. N storage_url)selfstorage_url_objects Flib/googlecloudsdk/command_lib/storage/resources/resource_reference.py__init__Resource.__init__6s *c[R"[R"SURR 4SUR 4/55$)z&Formats resource for printing as JSON.urltype)rconfigured_json_dumps collections OrderedDictr url_string TYPE_STRINGrs r get_json_dumpResource.get_json_dump?sJ  . . D$$// 0 T%% &!    rc.URR$N)rrrs r__repr__Resource.__repr__Gs    & &&rcl[XR5=(a URUR:H$r") isinstance __class__r)rothers r__eq__Resource.__eq__Ms,5..) . E---rc[S5e)Nz is_container must be overridden.NotImplementedErrorrs r is_containerResource.is_containerSs @ AArcg)z+Returns whether this resource is a symlink.Frs r is_symlinkResource.is_symlinkVs rrN)__name__ __module__ __qualname____firstlineno____doc__rrrr#r)r.propertyr2__static_attributes__r1rrr r s<(+* '  B  rr c2\rSrSrSrSr\S5rSrSr g) CloudResource\a)For Resource classes with CloudUrl's. Attributes: TYPE_STRING (str): String representing the resource's content type. scheme (storage_url.ProviderPrefix): Prefix indicating what cloud provider hosts the bucket. storage_url (StorageUrl): A StorageUrl object representing the resource. cloud_resourcec.URR$r")rschemers rr@CloudResource.schemegs    " ""rc0$)a=Returns provider specific formatting for the acl fields. Provider specific resource classses can override this method to return provider specific formatting for acl fields. If not overriden, acl values are displayed as-is if present. Returns: Dictionary with acl fields as key and corresponding formatted values. r1rs rget_formatted_aclCloudResource.get_formatted_aclks  Irr1N) r4r5r6r7r8rr9r@rCr:r1rrr<r<\s%!+ # # rr<c^\rSrSrSrSrS U4Sjjr\S5r\S5r \S5r U4Sjr S r S r U=r$) BucketResourcexa Class representing a bucket. Warning: After being run through through output formatter utils (e.g. in `shim_format_util.py`), these fields may all be strings. Attributes: TYPE_STRING (str): String representing the resource's content type. storage_url (StorageUrl): A StorageUrl object representing the bucket. name (str): Name of bucket. scheme (storage_url.ProviderPrefix): Prefix indicating what cloud provider hosts the bucket. acl (dict|CloudApiError|None): ACLs dict or predefined-ACL string for the bucket. If the API call to fetch the data failed, this can be an error string. cors_config (dict|CloudApiError|None): CORS configuration for the bucket. If the API call to fetch the data failed, this can be an error string. creation_time (datetime|None): Bucket's creation time in UTC. default_event_based_hold (bool|None): Prevents objects in bucket from being deleted. Currently GCS-only but needed for generic copy logic. default_storage_class (str|None): Default storage class for objects in bucket. etag (str|None): HTTP version identifier. labels (dict|None): Labels for the bucket. lifecycle_config (dict|CloudApiError|None): Lifecycle configuration for bucket. If the API call to fetch the data failed, this can be an error string. location (str|None): Represents region bucket was created in. If the API call to fetch the data failed, this can be an error string. logging_config (dict|CloudApiError|None): Logging configuration for bucket. If the API call to fetch the data failed, this can be an error string. metadata (object|dict|None): Cloud-provider specific data type for holding bucket metadata. metageneration (int|None): The generation of the bucket's metadata. requester_pays (bool|CloudApiError|None): "Requester pays" status of bucket. If the API call to fetch the data failed, this can be an error string. retention_period (int|None): Default time to hold items in bucket before before deleting in seconds. Generated from retention_policy. retention_policy (dict|None): Info about object retention within bucket. retention_policy_is_locked (bool|None): True if a retention policy is locked. update_time (str|None): Bucket's update time. versioning_enabled (bool|CloudApiError|None): Whether past object versions are saved. If the API call to fetch the data failed, this can be an error string. website_config (dict|CloudApiError|None): Website configuration for bucket. If the API call to fetch the data failed, this can be an error string. cloud_bucketc>[[U] U5 X lX0lX@lXPlX`lXplXl Xl Xl Xl Xl XlXlXlUUlUUlUUlg6Initializes resource. Args are a subset of attributes.N)superrFracl cors_config creation_timedefault_event_based_holddefault_storage_classetaglabelslifecycle_configlocationlogging_configmetadatametagenerationrequester_paysretention_policy update_timeversioning_enabledwebsite_config)rrrMrNrOrPrQrRrSrTrUrVrXrWrYrZr[r\r]r's rrBucketResource.__init__s|( .$();<H"&$<!!6IK,M(M((,"D0D(Drc.URR$r"r bucket_namers rnameBucketResource.name    ' ''rcgr"r1rs rretention_periodBucketResource.retention_period rcgr"r1rs rretention_policy_is_locked)BucketResource.retention_policy_is_lockedrhrc>[[U] U5=(GaB URUR:H=(Ga! URUR:H=(Ga UR UR :H=(Ga UR UR :H=(Ga URUR:H=(Ga URUR:H=(Ga| URUR:H=(Ga[ URUR:H=(Ga: URUR:H=(Ga URUR:H=(a URUR:H=(a URUR:H=(a URUR:H=(a URUR:H=(ay UR UR :H=(aY UR"UR":H=(a9 UR$UR$:H=(a UR&UR&:H$r")rLrFr)rMrNrOrPrQrRrUrSrTrVrWrXrYrZr[r\r]rr(r's rr)BucketResource.__eq__s .$ .u 5 8 8 HH ! 8 8&*&6&6%:K:K&K 8 8   %"5"5 5 8 8  ) )U-K-K K 8 8  & &%*E*E E  8 8 II #  8 8 )- (G  8 8 KK5<< '  8 8  ! !U%;%; ; 8 8 MMU^^ + 8   5#7#7 7 8 MMU^^ + 8   5#7#7 7 8   5#7#7 7 8  ! !U%;%; ; 8    1 1 1 8  # #u'?'? ? 8   5#7#7 7!9rcgNTr1rs rr.BucketResource.is_container r)rMrNrOrPrQrRrSrTrUrVrWrXrYrZr[r\r])NNNNNNNNNNNNNNNNN)r4r5r6r7r8rrr9rbrfrjr)r.r: __classcell__r's@rrFrFxs.^+!(,%) $""" $"&"%%)N ( (    9&rrFc^\rSrSrSrSrS U4Sjjr\S5r\S5r \S5r \S5r U4S jr S r S rS rU=r$)ObjectResourceaO Class representing a cloud object confirmed to exist. Warning: After being run through through output formatter utils (e.g. in `shim_format_util.py`), these fields may all be strings. Attributes: TYPE_STRING (str): String representing the resource's type. storage_url (StorageUrl): A StorageUrl object representing the object. scheme (storage_url.ProviderPrefix): Prefix indicating what cloud provider hosts the object. bucket (str): Bucket that contains the object. name (str): Name of object. generation (str|None): Generation (or "version") of the underlying object. acl (dict|str|None): ACLs dict or predefined-ACL string for the objects. If the API call to fetch the data failed, this can be an error string. cache_control (str|None): Describes the object's cache settings. component_count (int|None): Number of components, if any. content_disposition (str|None): Whether the object should be displayed or downloaded. content_encoding (str|None): Encodings that have been applied to the object. content_language (str|None): Language used in the object's content. content_type (str|None): A MIME type describing the object's content. custom_time (str|None): A timestamp in RFC 3339 format specified by the user for an object. Currently, GCS-only, but not in provider-specific class because generic daisy chain logic uses the field. crc32c_hash (str|None): Base64-encoded digest of crc32c hash. creation_time (datetime|None): Time the object was created. custom_fields (dict|None): Custom key-value pairs set by users. decryption_key_hash_sha256 (str|None): Digest of a customer-supplied encryption key. encryption_algorithm (str|None): Encryption algorithm used for encrypting the object if CSEK is used. etag (str|None): HTTP version identifier. event_based_hold (bool|None): Event based hold information for the object. Currently, GCS-only, but left generic because can affect copy logic. kms_key (str|None): Resource identifier of a Google-managed encryption key. md5_hash (str|None): Base64-encoded digest of md5 hash. metadata (object|dict|None): Cloud-specific metadata type. metageneration (int|None): Generation object's metadata. noncurrent_time (datetime|None): Noncurrent time value for the object. retention_expiration (datetime|None): Retention expiration information. size (int|None): Size of object in bytes (equivalent to content_length). storage_class (str|None): Storage class of the bucket. temporary_hold (bool|None): Temporary hold information for the object. update_time (datetime|None): Time the object was updated. cloud_objectcn>[[U] U5 X lX0lX@lXPlX`lXplXl Xl Xl Xl Xl XlXlXlUUlUUlUUlUUlUUlUUlUUlUUlUUlUUlUUlgrJ)rLrvrrM cache_controlcomponent_countcontent_dispositioncontent_encodingcontent_language content_type crc32c_hashrO custom_fields custom_timedecryption_key_hash_sha256encryption_algorithmrRevent_based_holdkms_keymd5_hashrXrWnoncurrent_timeretention_expirationsize storage_classtemporary_holdr[)rrrMrzr{r|r}r~rrrOrrrrrRrrrrWrXrrrrrr[r's rrObjectResource.__init__'s8 .$();<H&*2,,$"&&"&@# 4I,DDLDM(DDM*D 4DDI&D(D"Drc.URR$r"r`rs rbucketObjectResource.bucket^rdrc.URR$r"r resource_namers rrbObjectResource.nameb    ) ))rc.URR$r")r generationrs rrObjectResource.generationfs    & &&rcUR(a[RUR;agUR[RR5S:H$)z)Returns whether this object is a symlink.Ftrue)rrSYMLINK_METADATA_KEYlowerrs rr2ObjectResource.is_symlinkjsK     - -T5G5G G  ===>DDF&Prc>[[U] U5=(Ga) URUR:H=(Ga URUR:H=(Ga UR UR :H=(Ga UR UR :H=(Ga URUR:H=(Ga URUR:H=(Gac URUR:H=(GaB URUR:H=(Ga! URUR:H=(Ga URUR:H=(Ga URUR:H=(Ga URUR:H=(Ga URUR:H=(Ga| UR UR :H=(Ga[ UR"UR":H=(Ga: UR$UR$:H=(Ga UR&UR&:H=(a UR(UR(:H=(a UR*UR*:H=(a UR,UR,:H=(a UR.UR.:H=(ay UR0UR0:H=(aY UR2UR2:H=(a9 UR4UR4:H=(a UR6UR6:H$r")rLrvr)rMrzr{r|r}r~rrrOrrrrrRrrrrWrXrrrrrr[rms rr)ObjectResource.__eq__vs nd*51 . .dhh%))6K . . e111 . .  5 55 . .   E$=$== . . !7!77  . . !7!77  . . U///  . . E--- . . e111 . . e111 . . E--- . . ''5+K+KK . . !!U%?%?? . . UZZ . . !7!77 . .  % . .+/--5>>*I . '! ." u333# .$  5 55% .& !!U%?%??' .( UZZ) .* e111+ ., u333- .. E---1/rcgNFr1rs rr.ObjectResource.is_container rc[er"r,rs r is_encryptedObjectResource.is_encrypteds r)rMrzr{r|r}r~rrrOrrrrrRrrrrWrXrrrrrr[)NNNNNNNNNNNNNNNNNNNNNNNNN)r4r5r6r7r8rrr9rrbrr2r)r.rr:rsrts@rrvrvs-\+!##' $ $ !!*.$( $"#$(!"55#n ( ( * * ' '    /6rrvc6^\rSrSrSrSrU4SjrSrSrU=r $)PrefixResourceizClass representing a cloud object. Attributes: TYPE_STRING (str): String representing the resource's content type. storage_url (StorageUrl): A StorageUrl object representing the prefix. prefix (str): A string representing the prefix. prefixc8>[[U] U5 X lg)zInitialize the PrefixResource object. Args: storage_url_object (StorageUrl): A StorageUrl object representing the prefix. prefix (str): A string representing the prefix. N)rLrrr)rrrr's rrPrefixResource.__init__s .$();<Krcgrpr1rs rr.PrefixResource.is_containerrrr)r) r4r5r6r7r8rrr.r:rsrts@rrrs+ rrcx^\rSrSrSrSrS U4Sjjr\S5r\S5r \S5r U4Sjr S r U=r $) ManagedFolderResourceiz$Class representing a managed folder.managed_foldercp>[[U] XR5 X lX0lX@lXPlgr")rLrrr create_timerWrXr[rrrrWrXr[r's rrManagedFolderResource.__init__s7 /<<#M("rc.URR$r"r`rs rrManagedFolderResource.bucketrdrcgrr1rs rr2 ManagedFolderResource.is_symlink rc.URR$r"rrs rrbManagedFolderResource.namerrcj>[[U] U5=(a URUR:H=(ay URUR:H=(aY UR UR :H=(a9 UR UR :H=(a URUR:H$r")rLrr)rrrWrXr[rms rr)ManagedFolderResource.__eq__s #T1%8 2    1 1 1 2    1 1 1 2 MMU^^ + 2   5#7#7 7  2    1 1 1 rrrWrXr[NNNNr4r5r6r7r8rrr9rr2rbr)r:rsrts@rrrsd, +  #  ( (   * *rrcx^\rSrSrSrSrS U4Sjjr\S5r\S5r \S5r U4Sjr S r U=r $) FolderResourceizClass representing a folder.foldercp>[[U] XR5 X lX0lX@lXPlgr")rLrrrrrWrXr[rs rrFolderResource.__init__s6 .$(<<#M("rc.URR$r"r`rs rrFolderResource.bucketrdrcgrr1rs rr2FolderResource.is_symlinkrrc.URR$r"rrs rrbFolderResource.namerrcj>[[U] U5=(a URUR:H=(ay URUR:H=(aY UR UR :H=(a9 UR UR :H=(a URUR:H$r")rLrr)rrrWrXr[rms rr)FolderResource.__eq__s nd*51 2    1 1 1 2    1 1 1 2 MMU^^ + 2   5#7#7 7  2    1 1 1 rrrrrts@rrrsd$+  #  ( (   * *rrcZ^\rSrSrSrSrS U4SjjrSr\S5r \S5r Sr U=r $) FileObjectResourcei aWrapper for a filesystem file. Attributes: TYPE_STRING (str): String representing the resource's content type. size (int|None): Size of local file in bytes or None if pipe or stream. storage_url (StorageUrl): A StorageUrl object representing the resource. md5_hash (bytes): Base64-encoded digest of MD5 hash. is_symlink (bool|None): Whether this file is known to be a symlink. file_objectcD>[[U] U5 X lX0lgrJ)rLrrr _is_symlink)rrrr2r's rrFileObjectResource.__init__s d,-?@M!rcgrr1rs rr.FileObjectResource.is_containerrrcURR(ag[RR URR 5$)z,Returns file size or None if pipe or stream.N)r is_streamospathgetsizerrs rrFileObjectResource.sizes5 !!  77??4++99 ::rcURc8[RRURR 5UlUR$)z'Returns whether this file is a symlink.)rrrislinkrrrs rr2FileObjectResource.is_symlink%s= (8(8(F(FGd   r)rr)NN) r4r5r6r7r8rrr.r9rr2r:rsrts@rrr sA+"  ; ;   rrcP^\rSrSrSrSU4Sjjr\S5r\S5rSr U=r $)FileSymlinkPlaceholderResourcei-zdA file to a symlink that should be preserved as a placeholder. Attributes: Refer to super class. c.>[[U] XS5 g)rKTN)rLrr)rrrr's rr'FileSymlinkPlaceholderResource.__init__4s ($8drc[[R"URR5R S55$)zEReturns the length of the symlink target to be used as a placeholder.zutf-8)lenrreadlinkrrencoders rr#FileSymlinkPlaceholderResource.size:s/ r{{4++99:AA'J KKrcgrpr1rs rr2)FileSymlinkPlaceholderResource.is_symlink?s rr1r") r4r5r6r7r8rr9rr2r:rsrts@rrr-s7   L L  rrc"\rSrSrSrSrSrSrg)FileDirectoryResourceiDz$Wrapper for a File system directory.file_directorycgrpr1rs rr."FileDirectoryResource.is_containerHrrrr1Nr4r5r6r7r8rr.r:r1rrrrDs, +rrc"\rSrSrSrSrSrSrg)UnknownResourceiLz0Represents a resource that may or may not exist.unknownc.[R"S5e)Nz6Unknown whether or not UnknownResource is a container.)rValueCannotBeDeterminedErrorrs rr.UnknownResource.is_containerPs  - -@ BBrr1Nrr1rrrrLs8+Brrc[U[5(aURR5$UR 5$)z@Returns if resource is a known or unverified container resource.)r&rr is_bucketr.)r s r!is_container_or_has_container_urlrUs3/**    ) ) ++     r)r8 __future__rrrrr"googlecloudsdk.command_lib.storager,googlecloudsdk.command_lib.storage.resourcesrNOT_SUPPORTED_DO_NOT_DISPLAYobjectr r<rFrvrrrrrrrrr1rrrsF&' 5F ?:v:zH8{]{|_]_D]2)N)X)^)X!!H%7.HBhB!r