@&SrSSKJr SSKJr SSKJr SSKrSSKJr SSKJr SSK r "SS \ 5r \ R"\R5"S S \R55rg) zA persistent cache metadata table implementation layer. Used by persistent cache implementations that maintain a metadata table to keep track of cache tables. )absolute_import)division)unicode_literalsN) exceptions)persistent_cache_basec:\rSrSrSrSrSr\SSj5rSr g) Metadata"a"Metadata table row container. This object encapsulates the persistent metadata table row layout. Attributes: name: The table name. columns: The number of columns in the table. Must be >= 1. keys: The number of columns, starting from 0, that form the primary row key. Must be 1 <= keys <= columns. The primary key is used to differentiate rows in the AddRows and DeleteRows methods. timeout: A float number of seconds. Tables older than (modified+timeout) are invalid. 0 means no timeout. modified: Table modify Now() (time.time()) value. 0 for expired tables. restricted: True if Table is restricted. version: A caller defined version string that must match the version string stored when the persistent object was created. '' for all but the metadata table itself. crUuUlUlUlUlUlo l[ U5Ulg)z+Constructs a metadata container from a row.N)namecolumnskeystimeoutmodifiedversionbool restricted)selfrowrs /lib/googlecloudsdk/core/cache/metadata_table.py__init__Metadata.__init__8s1"%TY dit}:&DONc*Ub [U5nXX4XVU4$)z:Constructs and returns a metadata table row from the args.)int)clsr rrrrrrs rRow Metadata.Row>s"z?j 4( HHr)rrrr rrr)NNNNNNN) __name__ __module__ __qualname____firstlineno____doc__COLUMNSr classmethodr__static_attributes__rrr r "s/& '' ;?26IIrr c^\rSrSrSrS U4Sjjr\RS5r\RS5r \RSSj5r Sr Sr SS jr S rSS jrS rU=r$)CacheUsingMetadataTableGzA persistent cache metadata table implementation layer. Attributes: _metadata: A table containing a row for each table. _table_class: The cache Table class. _restricted: The set of restricted table names. _tables: The map of open table objects. c`>[[U] X#XES9 SUlXlSUlSUlg)N)createrr)superr*r _metadata _table_class _restricted_tables)rtabler r-rr __class__s rr CacheUsingMetadataTable.__init__Rs9 !41 W2?DNDDLrcgNr(rs rDeleteCacheUsingMetadataTable.DeleteZrcgr7r(r8s rCommitCacheUsingMetadataTable.Commit^r;rcgr7r()rcommits rCloseCacheUsingMetadataTable.Closebr;rcg)a:Implementation layer _CreateTable. The cache implementation object can override this method to do implementation specific table initialization. Args: name: The table name. columns: The number of columns in each row. keys: The number of columns, left to right, that are primary keys. 0 for all columns. Nr()rr rrs r_ImplementationCreateTable2CacheUsingMetadataTable._ImplementationCreateTablefs rc UcSnUS:a0[R"SRURX55eUcUnUS:dXC:a1[R"SRURXU55eUc UR nUR XU5 URUUUUUSUS9nUR(aSnGO&X`lUR5 UR[RUS95nU(aUSOSn U (a[U 5n URcU R=(d SUl OuURU R:wa[[R"S RURU RUR5U RUR5eUR cU R UlSUlURnURR![RURUR"UR$UR URUR&US 9/5 U$) a9Creates and returns a table object for name. NOTE: This code is conditioned on self._metadata. If self._metadata is None then we are initializing/updating the metadata table. The table name is relaxed, in particular '_' is allowed in the table name. This avoids user table name conflicts. Finally, self._metadata is set and the metadata table row is updated to reflect any changes in the default timeout. Args: name: The table name. restricted: Return a restricted table object. columns: The number of columns in each row. keys: The number of columns, left to right, that are primary keys. 0 for all columns. timeout: The number of seconds after last modification when the table becomes invalid. 0 for no timeout. Raises: CacheTableNameInvalid: If name is invalid. Returns: A table object for name. Nz/[{}] table [{}] column count [{}] must be >= 1.z>[{}] table [{}] primary key count [{}] must be >= 1 and <= {}.rr rrrrrr z,[{}] cache version [{}] does not match [{}].)r rrrrrr)rCacheTableColumnsInvalidformatr CacheTableKeysInvalidrrDr0r/ValidateSelectr rrCacheVersionMismatchrAddRowsrrr) rr rrrrr3rrowsrmetadatas r _CreateTable$CacheUsingMetadataTable._CreateTablets0g{  / / ; B Bii ( )) | d ax4>  , , J 6$))T 1 33 g##D48   d#'&-#'&-'()3  5E ~~gn nn \\(,,D,1 2dDGc C= << !))/R$, \\X-- -//<CC))X--t||= . . << !))$,en gNNHLL ZZ ZZ ##) Lrc ~XR;a0[R"SRURU55eUR R US5nU(aUR(dUbJXGR:wa;[R"SRURXUR55eUbJXWR:wa;[R"SRURXUR55eU$U(d0[R"SRURU55eUR(aURR[R!US95nU(aUSOSn U (a\[U 5n UR#UU RU RU RU R$U R&U R(S9$U(d0[R"SRURU55eUR+XXEU5$) aReturns the Table object for existing table name. Args: name: The table name. create: If True creates the table if it does not exist. restricted: Return a restricted table object. columns: The number of columns in each row. keys: The number of columns, left to right, that are primary keys. 0 for all columns. timeout: The number of seconds after last modification when the table becomes invalid. 0 for no timeout. If None then the default cache timeout is assumed. Raises: CacheTableNameInvalid: name is not a valid table name. CacheTableNotFound: If the table does not exist. Returns: A Table object for name. z$[{}] cache table [{}] is restricted.Nz>[{}] cache table [{}] columns [{}] does not match existing {}.z;[{}] cache table [{}] keys [{}] does not match existing {}.z [{}] cache table [{}] not found.rIrrH)r1rCacheTableRestrictedrLr r2getdeletedrrKrrMCacheTableNotFoundr/rOr rr0rrrrT) rr r-rrrrr3rRrrSs rTableCacheUsingMetadataTable.Tables,   + + 0 7 7 4 H JJ LL  T4 (E ]]  7mm#;33Nvdii >@ @   200KvdiiUZZ8: : ++ . 5 5dii FH H ~~ ^^ " "8<> 4E!J KD*. /$3HSM  $ // /sA)r/r1r0r2rr)TrN)T)TFNNNr7)r r!r"r#r$rabcabstractmethodr9r=rArDrTr[r_rOr' __classcell__)r4s@rr*r*Gs        KZKO7Gr" 0 0rr*)r$ __future__rrrrcgooglecloudsdk.core.cacherrsixobjectr add_metaclassABCMetaCacher*r(rrrmsd  '' 0; "Iv"IJ3;;B0399B0 B0r