+ 2jp@Rt^RIHt^RIt^RIt^RIt^RIt^RIt^RIt^RI t ^RI H t ^RI H t Ht^RIHt^RIHtHt^RIHt^RIHt^R IHt]'d^R IHt]P:!]4t.R5Ot Rt!Rt"Rt#Rt$Rt%R6t&Rt'Rt(]'](3t)]*!RR.4t+!RR],4t-] !RRR7!RR 44t.RRlt/RRlt0RRlt1R R!lt2R"R#lt3R$R%lt4R&R'lt5!R(R4t6R)R*lt7R+R,lt8R-R.lt9R/R0lt:R1R2lt;!R3R ]4t<!R4R 4t=R#)7aOOn-disk cache for nab-index. Stores PEP 691 Simple API responses (JSON body plus a sidecar cache policy file) and PEP 658 wheel metadata (raw text, treated as immutable). The cache is consulted by :class:`CachedAsyncSimpleClient` before any HTTP transport call. Layout under ``root``: simple-v1/[-]/.json <- PEP 691 JSON body simple-v1/[-]/.policy <- {fetched_at, max_age, etag, page_url, body_digest} simple-parsed-v0/[-]/.parsed <- parsed blob simple-neg-v0/[-]/.neg <- {fetched_at, max_age, etag} metadata-v1///.metadata sdist-v1///.json <- {pkg_info, pyproject} An index pinned to one serialization gets its own listings directory, since a stored body records nothing about which serialization it came from. A versioned bucket name (``simple-v1``) gives zero-cost schema migration: when the on-disk format changes, bump the suffix and the old directory is harmless. When the index serves PEP 503 HTML the stored body is nab's own rendering of the page. A 304 revalidation keeps the old body, so changing that rendering also needs the suffix bumped to reach warm caches. A resolve writes two more buckets under the same root, holding upstream source trees: vcs/vcs/// <- shallow clone archive// <- extracted archive ) annotationsN)suppress) dataclassreplace)Path) TYPE_CHECKINGProtocol) atomic_write)corruption_reason)SimpleSerialization)Iterator CacheBackend CachePolicy NullCache OfflineError OnDiskCachev1v0vcsarchivezhttps://pypi.org/simplezhttp://pypi.org/simplec]tRt^_tRtRtR#)rzARaised when offline mode is set and a needed entry is not cached.N)__name__ __module__ __qualname____firstlineno____doc____static_attributes__rZ/home/user/billing-ledger-validation/.venv/lib/python3.14/site-packages/nab_index/cache.pyrr_sKrT)frozenslotscf]tRt^ct$RtR]R&R]R&R]R&RtR]R&RtR]R &R R R lltR t R#)raCRFC 9111-style freshness policy for one Simple API entry. ``fetched_at`` is the start of the freshness window: when nab received the response, less any Age a relaying shared cache reported. ``page_url`` is the URL the stored body was retrieved from, the base its relative entries resolve against. It is ``None`` for the negative sentinel, which has no body, and for an entry cached without it. ``body_digest`` is the sha256 hex of the raw body this policy governs, and binds a parsed-listing blob to that body. It is ``None`` for an older policy or a bodyless negative entry. int fetched_atmax_age str | NoneetagNpage_url body_digestc V^8dQhRRRR/#)now int | Nonereturnboolr)formats"r __annotate__CachePolicy.__annotate__ys88J8$8rc Vf\\P!44MTpW P, VP8#)z>Return True if the entry is still within its freshness window.)r#timer$r%)selfr,currents&& ris_freshCachePolicy.is_freshys.&)k#diik"s(4<<77rrN) rrrrr__annotations__r(r)r7rrrrrrcs7 O L Hj"K"88rc V^8dQhRRRR/#r+namestrr.r/r)r0s"rr1r1sLL3L4Lrca\;QJd#V3Rl\4F 'gK R# R#!V3Rl\44#)z>Whether ``name`` is a bucket of records nab writes and parses.c3F<"TFpSPV4xK R#5ir9) startswith).0prefixr=s& r #_is_entry_bucket..sK5J6tv&&5Js!TF)anyENTRY_BUCKET_PREFIXESr=sfr_is_entry_bucketrIs. 3K5JK33K3K3K5JK KKrc V^8dQhRRRR/#r<r)r0s"rr1r1s<r.r)r0s"rr1r1sFFcFcFrcVPR4\9dR#\P!VP R44P 4R,#)zAReturn a stable, filesystem-safe directory name for an index URL./pypiutf-8:NN)rstripDEFAULT_PYPI_URLShashlibsha256encode hexdigest)rOs&r_index_dirnamer[sA 11 >>)**73 4 > > @ EErc$V^8dQhRRRRRR/#)r+pathrdatabytesr.Noner)r0s"rr1r1s!EdrcVVPPRRR7\W4R#)zBCreate the cache bucket for ``path``, then write ``data`` into it.T)parentsexist_okN)parentmkdirr )r]r^s&&r _atomic_writerfs!KKdT2rc V^8dQhRRRR/#)r+ componentr>r.r)r0s"rr1r1s  s s rcjVR9gV\V4P8wdRV: 2p\V4hV#)a|Return ``component`` if it names exactly one path segment. Each cache key component becomes one file or directory name under the cache root, so it must be a single path segment. A value with an embedded separator expands to a nested path, and ``.`` or ``..`` names a parent, so either would read or write a different file than the key describes and return the wrong cache entry. z2cache key component is not a single path segment: ).z..)rr= ValueError)rhmsgs& r_require_single_segmentrns9O#yDO4H4H'HB9-Po rc$V^8dQhRRRRRR/#)r+r]rbitsr#r.r`r)r0s"rr1r1s!++$+c+d+rcVP4'dR#VPVP4PV,4R#)z=Add ``bits`` to ``path``'s mode, leaving a symlink untouched.N) is_symlinkchmodstatst_mode)r]rps&&r_add_owner_modervs/ JJtyy{""T)*rc V^8dQhRRRR/#)r+rootrr.r`r)r0s"rr1r1s??$?4?rc*\V\P4\P!V4F^wrpVF&p\\ W4\P4K( VF&p\\ W4\P 4K( K` R#)aGive the owner write on ``root`` and everything under it. A clone carries read-only packfiles and an extracted archive keeps the mode bits the archive declared, so either can leave a tree ``rmtree`` cannot take apart. Symlinks are skipped so no chmod lands outside the root. N)rvrtS_IRWXUoswalkrS_IWUSR)rxdirpathdirnames filenamesr=s& r_make_removablerscD$,,'(* $9D D/ >D D/ >)6rc]tRt^tRtR]P /RRlltRRltRRlt R R lt R R lt R Rlt RRlt RRltRRltRRltRRltRRltRRltRRltRR ltR!R"ltR#R$ltR%R&ltR'R(ltR)R*ltR+R,ltR-R.ltR/R0ltR1R2ltR3R4ltR5R6lt R7R8lt!R9R:lt"R;R<lt#R=t$R>#)?rzFile-per-key cache for Simple API and wheel metadata. Stores are best-effort: a write the filesystem refuses is dropped, just as an entry that cannot be read is a miss. serializationc(V^8dQhRRRRRRRR/#) r+rxrrOr>rr r.r`r)r0s"rr1OnDiskCache.__annotate__s2#### + #  #rc Wn\V4VnV\PJd VPMVP RVP 2pVR\ 2, V, VnVR\ 2, V, Vn VR\ 2, V, Vn VR\ 2, VP, Vn VR\ 2, VP, VnRVnR#) z4Create a cache rooted at ``root`` for ``index_url``.-simple-zsimple-parsed-z simple-neg- metadata-sdist-FN)_rootr[_indexr NEGOTIATEvalueCACHE_VERSION_SIMPLE _simple_dirCACHE_VERSION_SIMPLE_PARSED _parsed_dirCACHE_VERSION_SIMPLE_NEG_neg_dirCACHE_VERSION_METADATA _metadata_dirCACHE_VERSION_SDIST _sdist_dir _store_failed)r5rxrOr simple_indexs&&&$ r__init__OnDiskCache.__init__s $Y/  3 = == KKKK=-"5"5!67   G,@+A"BB\Q ^$?#@A AL P -E,FGG,V !i0F/G$HH4;;V6*=)>!??$++M"rc$V^8dQhRRRRRR/#)r+r]rr^r_r.r/r)r0s"rr1rs!4urc \W4R# \dFpTP'g)RTn\P RTP T4Rp?R#Rp?ii;i)zWrite ``data`` to ``path``, returning False if the write failed. Only the first failure warns: a root that refuses one write refuses the rest. Tz'cannot store cache entries under %s: %sNF)rfOSErrorrloggerwarningr)r5r]r^excs&&& r_storeOnDiskCache._storesV   $ % %%%%)"=tzz3  s  A:AAc V^8dQhRRRR/#)r+packager>r.ztuple[Path, Path]r)r0s"rr1rsS->rc v\V4pVPV R2, pVPV R2, pW43#).json.policy)rnr)r5rsegmentbodypolicys&& r _simple_pathsOnDiskCache._simple_pathssB)'2WIU"33!!wiw$77~rc V^8dQhRRRR/#r+rr>r.rr)r0s"rr1rs66C6D6rc D\V4pVPV R2, #).parsed)rnrr5rrs&& r _parsed_pathOnDiskCache._parsed_paths$)'2WIW"555rc V^8dQhRRRR/#rr)r0s"rr1rs0000rc D\V4pVPV R2, #).neg)rnrrs&& r _neg_pathOnDiskCache._neg_paths")'2}}'$///rc$V^8dQhRRRRRR/#)r+rr>versionr.rr)r0s"rr1rs&MM3MMMrc h\V4p\V4pVPV, V R2, #)r)rnr)r5rrpackage_segmentversion_segments&&& r _sdist_pathOnDiskCache._sdist_paths21':1':0o5Fe3LLLrc$V^8dQhRRRRRR/#)r+rr> metadata_urlr.rr)r0s"rr1rs& K Kc K K Krc \V4p\P!VPR44P 4pVP V, V R2, #)zReturn the file holding the sidecar published at ``metadata_url``. :pep:`658` attaches a sidecar to one file, so the wheels of a version each have their own. The URL is digested to keep the key a single path segment whatever path shape the index serves. rS .metadata)rnrWrXrYrZr)r5rrrdigests&&& r_metadata_pathOnDiskCache._metadata_pathsM2': 3 3G <=GGI!!O3 6JJJrc V^8dQhRRRR/#r+rr>r.z tuple[bytes, CachePolicy] | Noner)r0s"rr1r s#*Jrc VPV4wr#VP4pVP4p\T4pTf\P RT4R#YV3# \dR#i;i)9Return ``(body_bytes, policy)`` if cached, else ``None``.N:Corrupt cache policy %s: not decodable; treating as a missr read_bytesr_decode_policyrr)r5r body_path policy_path policy_bytesrrs&& r get_simpleOnDiskCache.get_simple sz!%!3!3G!<  &113L'')D - > NNL ~  s A A.-A.c(V^8dQhRRRRRRRR/# r+rr>rr_rrr.r&r)r0s"rr1rs(#UKJrc  VPV4wrEVPWB4'gR#\P!V4P 4pVPV\ \ W6R744'gR#V#)aWrite the body and the policy sidecar; return the body's digest. The sidecar goes out only once the body has landed, so a dropped body write cannot stamp an older body with the new one's ETag and freshness window. The sha256 of ``body`` is stamped into the stored policy, overriding any value the caller passed, and returned as the binding key for the parsed blob the caller writes next. A write that did not land returns ``None``, so no parsed blob is ever bound to a body the store does not hold. N)r))rrrWrXrZ_encode_policyr)r5rrrrrrs&&&& r put_simpleOnDiskCache.put_simplesj"&!3!3G!< {{9++%//1{{ (KL   rc$V^8dQhRRRRRR/#r+rr>rrr.r`r)r0s"rr1r1s!99S9+9$9rc bVPV4wr4VPV\V44R#)zReplace the policy sidecar without touching the body. Called after a 304 Not Modified, where the cached body is still valid but the freshness window has slid forward. N)rrr)r5rr_rs&&& rrefresh_simple_policy!OnDiskCache.refresh_simple_policy1s) ++G4 K!78rc V^8dQhRRRR/#r+rr>r.CachePolicy | Noner)r0s"rr1r:s1Crc VPV4wr#VP4p\T4pTf\P RT4T# \dR#i;i)zReturn the freshness policy for a cached Simple entry, without its body. The parsed-cache read path needs only the policy on a hit, so this reads the small sidecar without the body. A corrupt policy logs and misses, matching :meth:`get_simple`. Nrr)r5rrrrrs&& rget_simple_policyOnDiskCache.get_simple_policy:sg++G4 &113L - > NNL    sA AAc V^8dQhRRRR/#r+rr>r.z bytes | Noner)r0s"rr1rNs    rc fVPV4P4# \dR#i;i)zReturn the opaque parsed-listing blob for ``package``, or ``None``. The blob is bytes to this layer; the record codec lives in ``parsed_listing``. An absent blob is a silent miss. N)rrrr5rs&&rget_simple_parsedOnDiskCache.get_simple_parsedNs3  $$W-88: :  s ! 00c V^8dQhRRRR/#r+rr>r.r-r)r0s"rr1rYs  c j rc zVPV4P4P# \dR#i;i)zReturn the on-disk size of the parsed-listing blob in bytes, or ``None``. A single ``stat`` on the same path :meth:`get_simple_parsed` reads, so a caller can size the blob before deciding whether to read and decode it. An absent blob is a silent miss. N)rrtst_sizerrs&&rget_simple_parsed_size"OnDiskCache.get_simple_parsed_sizeYs9 $$W-224<< <  s (+ ::c$V^8dQhRRRRRR/#r+rr>blobr_r.r`r)r0s"rr1res!888E8d8rc <\VPV4V4R#)z@Write the opaque parsed-listing blob for ``package`` atomically.N)rfrr5rrs&&&rput_simple_parsedOnDiskCache.put_simple_parsedesd''0$7rc$V^8dQhRRRRRR/#r+rr>rr.r&r)r0s"rr1ris!Cszrc VPW4pVP4pTPR4# \dR#i;i \d\ P RT4R#i;i)zReturn the cached sidecar text for ``metadata_url``, or ``None``. A present file that is not valid UTF-8 is a corrupt entry: logged and treated as a miss. An absent file is a silent miss. NrSz?Corrupt cached metadata %s: not valid UTF-8; treating as a miss)rrrdecodeUnicodeDecodeErrorrr)r5rrr]raws&&& r get_metadataOnDiskCache.get_metadataist ""79 //#C ::g& &  "  NNQ   s 5A AA!A,+A,c(V^8dQhRRRRRRRR/#r+rr>rtextr.r`r)r0s"rr1r}s.VVCVsV#V$Vrc fVPVPW4VPR44R#)z=Write the sidecar text served at ``metadata_url``. Immutable.rSN)rrrYr5rrrs&&&&r put_metadataOnDiskCache.put_metadata}s$ D''> G@TUrc$V^8dQhRRRRRR/#r+rr>rr.z$tuple[str | None, str | None] | Noner)r0s"rr1rs$%( -rc "VPW4pVP4p\P!T4pTR,TR,3# \dR#i;i \ \ \3d\PRT4R#i;i)zReturn the cached ``(pkg_info, pyproject_toml)`` pair, or ``None`` on miss. Written as one record, so a hit is always the complete pair. A hit whose ``pyproject_toml`` is ``None`` means the sdist ships no pyproject.toml, which is not the same as a miss. Npkg_info pyprojectz@Corrupt sdist cache record %s: not parseable; treating as a miss) rrrjsonloadsrlKeyError TypeErrorrr)r5rrr]rdocs&&& rget_sdist_filesOnDiskCache.get_sdist_filess1 //#C **S/C OS%56 6    Hi0  NNR   s"A 'A AA,B Bc ,V^8dQhRRRRRRRRRR/# r+rr>rr r&pyproject_tomlr.r`r)r0s"rr1rs<         #    rc  VPVPW4\P!RVRV/4P R44R#)zJ K R R  rc V^8dQhRRRR/#rr)r0s"rr1rs  C ,> rc VPV4pVP4p\T4pTf\P RT4T# \dR#i;i)DReturn the freshness policy of a cached name-level 404, or ``None``.NzBCorrupt negative cache entry %s: not decodable; treating as a miss)rrrrrr)r5rneg_path neg_bytesrs&& r get_negativeOnDiskCache.get_negativesa>>'*  ++-I * > NNT    sA AAc$V^8dQhRRRRRR/#rr)r0s"rr1rs&EECEEErc ZVPVPV4\V44R#zBRecord that ``package`` returned a name-level 404 from this index.N)rrrr5rrs&&&r put_negativeOnDiskCache.put_negatives DNN7+^F-CDrc V^8dQhRRRR/#r+rr>r.r`r)r0s"rr1rs<>cV^8dQhRR/#r3r)r0s"rr1rs  J rc VP4Uu.uF"p\VP4'gK VNK$ up#uupi)zReturn the bucket entries holding records nab wrote. The source buckets are excluded: they hold upstream files, not nab records. )r8rIr=r<s& r_entry_bucket_dirsOnDiskCache._entry_bucket_dirss= $224 4e8H8TEE4   r@cV^8dQhRR/#r+r.zIterator[Path]r)r0s"rr1rs$$N$rc# L"VP4FpVP4'gVP4'gK1\P!VRR7F>wr#p\ V4pVF'pWV, pVP4'dK#VxK) K@ K R#5i)zYield each entry file inside the record buckets. A symlinked bucket or a symlinked file is skipped, never followed out of the tree. F) followlinksN)rCrris_dirr{r|r)r5bucketr~ _dirnamesrbaser=entrys& riter_cache_entriesOnDiskCache.iter_cache_entriess --/F  ""&--//13U1S-IG}%D KE ++--# &2T0s?B$A B$B$c V^8dQhRRRR/#r+r]rr.r&r)r0s"rr1rsTjrc JVP4pTPpTR9d\ T4eR#R#TR8Xd \ T4#TR8Xd \ T4#TR8XdTPY4#R# \d$pRTP;'gT 2uRp?#Rp?ii;i)abReturn a corruption reason for a cache entry, or ``None`` if it parses. Parses by suffix, matching each kind's read path: ``.policy`` and ``.neg`` decode as a policy, ``.metadata`` as UTF-8, ``.json`` as JSON (an sdist record also carries its two fields), ``.parsed`` as a parsed-listing blob. Any other suffix is not a nab entry and is reported clean. z unreadable: Nzpolicy not decodablerrr)rr)rrstrerrorsuffixr_read_parsed_reason_read_metadata_reason_read_json_reason)r5r]rrrTs&& rread_cache_entryOnDiskCache.read_cache_entrys 8//#C ( ()#.:4 V@V V Y &s+ + [ (- - W ))$4 4 8!#,,"5"5#!67 7 8sA44 B"?BB"B"c$V^8dQhRRRRRR/#)r+r]rrr_r.r&r)r0s"rr1rs!  d  : rc \P!V4pTPT4pTP R4'd'\ T\ 4'dRT9dRT9gR#R# \dR#i;i)znot valid JSONrr rzsdist record missing fieldsN)rrrl _bucket_ofrA isinstancedict)r5r]rrrJs&&& rrWOnDiskCache._read_json_reasonsj $**S/C&   X & & sD ! !jC&7K3r)r0s"rr1rs11t11rc VPVP4pTP'dTP^,#R# \dR#i;i)rj) relative_torrlparts)r5r]rels&& rr\OnDiskCache._bucket_ofsL ""4::.C #yyysyy|0b0  sA AAcV^8dQhRR/#r+r.z list[str]r)r0s"rr1rsYrc .pVP4FupVP4'dVP4M0VP4'd\P !V4MKZVPVP4Kw V# \ d%\T4\P !T4LOi;i)zRemove the recognized bucket directories in full, returning their names. A symlinked bucket has its link removed, never followed, so a target outside the root survives. A recognized-named plain file is left in place and not counted. ) r>rrr/rIshutilrmtreePermissionErrorrappendr=)r5removedrJs& r clear_cacheOnDiskCache.clear_caches '')F  "" *MM&)  NN6;; '* '*#F+MM&)*sB,B=<B=)rrrrrrrrN)%rrrrrr rrrrrrrrrrrrrrrrrrrr#r)r0r8r>rCrNrXrWr\rnrrrrrrs # .A-J-J #0" 60M K"*9(  8(V0   E<   $ 0 1rc V^8dQhRRRR/#r+rr_r.r&r)r0s"rr1r11surcNVPR4R# \dR#i;i)rSznot valid UTF-8N)rrrs&rrVrV1s,! 7  ! !s  $$c V^8dQhRRRR/#rqr)r0s"rr1r19s##U#z#rc\V4#r9)_parsed_corruptionrss&rrUrU9s c ""rc V^8dQhRRRR/#)r+rrr.r_r)r0s"rr1r1@s + +; +5 +rcRVPRVPRVPRVP/pVPeVPVR&\ P !V4PR4#)r$r%r'r(r)rS)r$r%r'r(r)rrrY)rrs& rrr@sff''6>> FOO C%#//M ::c? ! !' **rc V^8dQhRRRR/#)r+robjectr.r&r)r0s"rr1r1Ns??F?z?rcF\V\4'd V'dV#R#)zFPage URL from a decoded policy, or None when it is unusable as a base.N)r]r>)rs&r_policy_page_urlr|Nsuc**u5>$>rc V^8dQhRRRR/#)r+rr_r.rr)r0s"rr1r1Ss   += rc 6\P!V4p\\VR,4\VR,4VP R4\ VP R44VP R4R7# \ \\3dR#i;i)r$r%r'r(r))r$r%r'r(r)N) rrrr#getr|rlrr)rrs& rrrSs~ jj&3|,-I'%cggj&9: .    ) ,sA;A>>BBc]tRtRtRtRRltRRltRRltR R ltR R lt R Rlt RRlt RRlt RRlt RRltRRltRRltRRltRRltRR ltR!R"ltR#R$ltR%tR&#)'r iaz?Protocol shared by :class:`OnDiskCache` and :class:`NullCache`.c V^8dQhRRRR/#rr)r0s"rr1CacheBackend.__annotate__ds  # *J rc R#)rNrrs&&rrCacheBackend.get_simpled rc(V^8dQhRRRRRRRR/#rr)r0s"rr1rhs(   #  U  K  J  rc R#)aStore a Simple API body and its freshness policy; return the digest. The returned value is the sha256 hex of the body the backend stored, the binding key for the parsed-listing blob the caller writes next, or ``None`` when the backend stored nothing. A caller writes a parsed blob only for a digest it was given, so no derived entry ever claims to describe a body the store does not hold. Nrr5rrrs&&&&rrCacheBackend.put_simplehs rc$V^8dQhRRRRRR/#rr)r0s"rr1rss!  S + $ rc R#)zCUpdate the policy for an existing entry without rewriting the body.Nrr(s&&&rr"CacheBackend.refresh_simple_policysrrc V^8dQhRRRR/#rr)r0s"rr1rws   1C rc R#)zGReturn a Simple entry's freshness policy without its body, or ``None``.Nrrs&&rrCacheBackend.get_simple_policywrrc V^8dQhRRRR/#rr)r0s"rr1r{s    rc R#)zCReturn the opaque parsed-listing blob for ``package``, or ``None``.Nrrs&&rrCacheBackend.get_simple_parsed{rrc V^8dQhRRRR/#rr)r0s"rr1rs  c j rc R#)zDReturn the parsed-listing blob's on-disk size in bytes, or ``None``.Nrrs&&rr#CacheBackend.get_simple_parsed_sizerrc$V^8dQhRRRRRR/#rr)r0s"rr1rs!   E d rc R#)z5Store the opaque parsed-listing blob for ``package``.Nrrs&&&rrCacheBackend.put_simple_parsedrrc$V^8dQhRRRRRR/#rr)r0s"rr1rs!  C s z rc R#)zAReturn the cached sidecar text for ``metadata_url``, or ``None``.Nrr5rrs&&&rrCacheBackend.get_metadatarrc(V^8dQhRRRRRRRR/#rr)r0s"rr1rs(  C s # $ rc R#)z=Store the sidecar text served at ``metadata_url``. Immutable.Nrrs&&&&rrCacheBackend.put_metadatarrc$V^8dQhRRRRRR/#r r)r0s"rr1rs$   %( - rc R#)zCReturn the cached ``(pkg_info, pyproject_toml)`` pair, or ``None``.Nrr5rrs&&&rrCacheBackend.get_sdist_filess rc ,V^8dQhRRRRRRRRRR/#rr)r0s"rr1rs<      #    rc R#)z rc R#)r Nrrs&&rr#CacheBackend.get_negativerrc$V^8dQhRRRRRR/#rr)r0s"rr1rs!  C   rc R#r'rr(s&&&rr)CacheBackend.put_negativerrc V^8dQhRRRR/#r,r)r0s"rr1rs  S T rc R#)z*Remove any negative entry for ``package``.Nrrs&&rr0CacheBackend.drop_negativerrcV^8dQhRR/#rFr)r0s"rr1rs  N rc R#)z0Yield each entry file inside the record buckets.Nrr7s&rrNCacheBackend.iter_cache_entriesrrc V^8dQhRRRR/#rQr)r0s"rr1rs  T j rc R#)zGReturn a corruption reason for a cache entry, or ``None`` if it parses.Nrr5r]s&&rrXCacheBackend.read_cache_entryrrcV^8dQhRR/#rgr)r0s"rr1rs  Y rc R#)zFRemove the recognized bucket directories, returning the names removed.Nrr7s&rrnCacheBackend.clear_cacherrrNrrrrrrrrrrrrrrrrr#r)r0rNrXrnrrrrr r as_I                   rc]tRtRtRtRRltRRltRRltR R ltR R lt R Rlt RRlt RRlt RRlt RRltRRltRRltRRltRRltRR ltR!R"ltR#R$ltR%tR&#)'riawNo-op cache backend used when persistence is disabled. Lets :class:`CachedAsyncSimpleClient` be used unconditionally so the call site does not branch on whether a cache is configured. Each method is a docstring-only stub: gets implicitly return ``None`` (a permanent miss) and puts implicitly do nothing. Argument names match :class:`CacheBackend` for Protocol conformance. c V^8dQhRRRR/#rr)r0s"rr1NullCache.__annotate__s//#/*J/rc R#z Return ``None`` (always a miss).Nrrs&&rrNullCache.get_simplerc(V^8dQhRRRRRRRR/#) r+rr>rr_rrr.r`r)r0s"rr1rs(  # U K D rc R#)zDiscard the entry; return ``None`` since no body was stored. A disabled cache holds nothing for a parsed blob to describe, so the caller skips building one rather than encoding records into a store that would drop them. Nrrs&&&&rrNullCache.put_simplerrc$V^8dQhRRRRRR/#rr)r0s"rr1rs!**S*+*$*rc R#)zDiscard the policy refresh.Nrr(s&&&rrNullCache.refresh_simple_policyrrc V^8dQhRRRR/#rr)r0s"rr1rs///1C/rc R#rrrs&&rrNullCache.get_simple_policyrrc V^8dQhRRRR/#rr)r0s"rr1rs////rc R#rrrs&&rrNullCache.get_simple_parsedrrc V^8dQhRRRR/#rr)r0s"rr1rs//c/j/rc R#rrrs&&rr NullCache.get_simple_parsed_sizerrc$V^8dQhRRRRRR/#rr)r0s"rr1rs!!!!E!d!rc R#zDiscard the entry.Nrrs&&&rrNullCache.put_simple_parsedrrc$V^8dQhRRRRRR/#rr)r0s"rr1rs!//C/s/z/rc R#rrrs&&&rrNullCache.get_metadatarrc(V^8dQhRRRRRRRR/#rr)r0s"rr1rs(!!C!s!#!$!rc R#rrrs&&&&rrNullCache.put_metadatarrc$V^8dQhRRRRRR/#r r)r0s"rr1rs$///%(/ -/rc R#rrrs&&&rrNullCache.get_sdist_filesrrc ,V^8dQhRRRRRRRRRR/#rr)r0s"rr1rs<!!!! ! # !  !rc R#rrrs&&&&&rrNullCache.put_sdist_filesrrc V^8dQhRRRR/#rr)r0s"rr1rs//C/,>/rc R#rrrs&&rr#NullCache.get_negativerrc$V^8dQhRRRRRR/#rr)r0s"rr1rs!!!C!!!rc R#rrr(s&&&rr)NullCache.put_negativerrc V^8dQhRRRR/#r,r)r0s"rr1rsSTrc R#)z Do nothing.Nrrs&&rr0NullCache.drop_negativerrcV^8dQhRR/#rFr)r0s"rr1rsNrc \R4#)z&Yield nothing (no persistent entries).r)iterr7s&rrNNullCache.iter_cache_entriess Bxrc V^8dQhRRRR/#rQr)r0s"rr1rsNNTNjNrc R#)z?Return ``None`` (a disabled cache never holds a corrupt entry).Nrrs&&rrXNullCache.read_cache_entryrrcV^8dQhRR/#rgr)r0s"rr1rsYrc .#)z)Return an empty list (nothing to remove).rr7s&rrnNullCache.clear_caches rrNrrrrrrsb/ *///!/!/ !/!Nr)ARCHIVE_BUCKET VCS_BUCKETr rrrrrM)rrr)>r __future__rrWrloggingr{rirtr4 contextlibr dataclassesrrpathlibrtypingrratomicr parsed_listingr rvrr collections.abcr getLoggerrr__all__rrrrrrGrrrL frozensetrV ExceptionrrrIrMr[rfrnrvrrrVrUrr|rr rrrrrs?"H#  ** C.(   8 $ "; n-! L9L $d#88$86L < F +?"qqh # +? T 8T nJJr