dQjHddlZddlZddlZddlZddlZddlmZddlmZddl m Z ddl m Z ddl mZddlmZmZddlmZd d lmZmZmZmZd d lmZmZd Zej:eZGd de Z!Gdde!Z"Gdde!Z#Gdde Z$GddejJZ&GddejNZ(y)N)abstractmethod) defaultdict)partial)Dict)ContentTypeError) MaxRetryError ProtocolError) __version__) NotFoundErrorResourceNotFoundErrorResourceNotUniqueErrorServiceUnavailableError)Resource ResourceListapisceZdZdZddZdZdZddZdZdZ e e d Z e dd Z e d Ze d Zdd ZddefdZdZdZdZy) Discovererz A convenient container for storing discovered API resources. Allows easy searching and retrieval of specific resources. Subclasses implement the abstract methods with different loading strategies. Nc||_|jjj}|jd} dj t j |dj}|xs2tjjtj||_y#t$r5dj t j |j}YywxYw)Nzutf-8zosrcp-{0}.jsonF)usedforsecurity)client configurationhostencodeformathashlibmd5 hexdigest TypeErrorospathjointempfile gettempdir_Discoverer__cache_file)selfr cache_filedefault_cache_iddefault_cachefile_names e/home/oem/CyberBrain26-unified/.venv/lib/python3.12/site-packages/kubernetes/aio/dynamic/discovery.py__init__zDiscoverer.__init__0s ;;4499+227; h%5%<%< ,eDNNP&R " 'e"'',,x7J7J7LNd*e h%5%<%.closure=s###% % %K &s   ) __await__)r&r2s` r*r3zDiscoverer.__await__<s y""$$cBK|jd{|S7wr.r/r1s r* __aenter__zDiscoverer.__aenter__Cs"!!!  "s cK|s)tjj|jsdti|_d}n t |jd5}tj|tt|j|_ddd|j jdtk7r|jd{|j#d{|j%d{|r|j'yy#1swYxYw7T#t$r9}tj!d||jd{7Yd}~d}~wwxYw77mw)Nlibrary_versionTrclszload cache error: %s)r r!existsr%r _cacheopenjsonloadr CacheDecoderrgetinvalidate_cache Exceptionloggererror_load_server_infodiscover _write_cache)r&refreshfes r* __init_cachezDiscoverer.__init_cacheGs "''..):):;,k:DKG .$++S1WQ"&))A7<3U"VDKW;;??#45D//111$$&&&mmo      WW2 . 3Q7++--- . 's|r%r?dumpr= CacheEncoderrD)r&rKs r*rIzDiscoverer._write_cacheZsS d''- < $++ql; < < <   s-A'AAA AA A A cDK|jdd{y7w)NT)rJr/r1s r*rCzDiscoverer.invalidate_cachebs---s   cyr.r1s r* api_groupszDiscoverer.api_groupses r4c Kywr.rT)r&prefixgroup api_versionkindkwargss r*searchzDiscoverer.searchjs  scyr.rTr1s r*rHzDiscoverer.discoverns r4c|jSr.)_Discoverer__versionr1s r*versionzDiscoverer.versionrs ~~r4c Kddd|r'td|jddddd{n tdiitddtddt|jgiiii}|S7Dw)Napiv1T resourcesList) ResourceGroupget_resources_for_api_versionDISCOVERY_PREFIXrr)r&request_resourcesgroupss r*default_groupszDiscoverer.default_groupsvs B+%T4;];]^cegimos;t5tu1>t1D rmDVl4;;>W=X4YZ$  6us#A,A*AA,returnchK|jjdr|rz|jjdi|jd<|jjddj t d{}|j }|j|d{}|D]}i}|dD]}|d} |jjdijt ij|dij| } ||d k(} | r | jni} |r#|jt |d| | d{} t| | || <||t |d<|jdj||j|jdS7.7 7jw) z1 Discovers all API groups present in the cluster rfGETz/{}Nrkversionsr`namepreferredVersionre) r=rBrrequestrrjrlrmrfrirhupdaterI) r&rkrvresponsegroups_responserlrX new_group version_rawr`resource_group preferredrfs r*parse_api_groupszDiscoverer.parse_api_groupss{{{+v'+{{{B'GDKK $![[00 EU8VWWH&ooO..AR.SSF( D #(#4 WK))4G%)[[__["%E%I%IJZJL&NNQcRWX^R_acNdehehipeq# +u5G/H HI.just_jsons r4r` kubernetesrBz/version) serializerzhttps://zGHost value %s should start with https:// when talking to HTTPS endpoint) r=rBrru ValueErrorr isinstancereasonr rr startswithr_)r&rrLs r*rGzDiscoverer._load_server_infos {{y)   (;(;E:Zc(;(d"d* I&Y/#e . a/ 188]8[{{0055@@L$%n%)[[%>%>%C%C&DEE s;D "A.A,A.D ,A..D =BDD  D c Ktt}i}djtd|||g} |jj d|d{}|j xsg} ttd| } ttd| } | D]8} | djdd\} }|j| si|| <| || |<:| D]} dD]}| j|dtd ||||j||j| dd | }|| d j|t|j||| d  }||jj||S7#ttf$rg} Y!wxYww) zT returns a dictionary of resources associated with provided (prefix, group, version)/Nrpcd|dvSNrrsrTr9s r*z:Discoverer.get_resources_for_api_version..sc6.Br4cd|dvSrrTrs r*rz:Discoverer.get_resources_for_api_version..s& 1Ar4rsr )rWrXrYrr|)rWrXrYrr| subresourcesrZ)rXrY base_kindrT)rlistr"filterrrurfrrsplitrBpoprappendrrZ)r&rWrXr`r|rfrr!rwresources_response resources_rawsubresources_raw subresourceresourcerskey resourceobj resource_lists r*riz(Discoverer.get_resources_for_api_versions %  xxtfeW%=>? $![[00==H!)!3!3!9r  V$BDVWX 'ACU VW+ 7K(066sA>NHd##H-)+ X&+6L "4 (  7& @HP ( S$' (##{{#)--hv.>? K hv& ' . .{ ;(EwbjkqbrsM m(( ) 0 0 ?# @$E>')9: $"$  $s;0F E4E1E4'D F 1E44F F F  F c K|jdi|d{}t|dkDr3|jdr"|Dcgc]}|j|dk(s|}}t|dkDrGt |Dcgc]}t |t c}s |Dcgc]}t |t r|}}t|dk(r|dS|stdj|tdj||7cc}wcc}wcc}ww)z Same as search, but will throw an error if there are multiple or no results. If there are multiple results and only one is an exact match on api_version, that resource will be returned. Nr rYrzNo matches found for {}z!Multiple matches found for {}: {}rT) r\lenrB group_versionallrrr rr)r&r[resultsresultxs r*rBzDiscoverer.gets $ -f-- w>+;3KD%&y$75@(1{ 233I((G ~~' ^T]]C5593DiQ[%\\] ^N33J(4334 [Z ]siA%G (!F0 F- F0AG G1G GA G A G  G ! G -F00GG G G Nc t|s|rd|vr|jd\}}|||||g}ttd|S)Nrc|xsdSNrrTrs r*rz/LazyDiscoverer.__build_search..F !(sr4rrmaprWrXrYrZr[rs r*__build_searchzLazyDiscoverer.__build_search@F );!,!2!23!7 E; T6:C*E233r4c K|jjD]\}}|jD]\}}|jD]q\}}|jsJ|j||||jd{|_||j d|||<d|_|jD]}| s|jy7Uw)NrfT)rrrfrir|r=rr)r&rWrlrXrrr`rgrs r* __aiter__zLazyDiscoverer.__aiter__Hs"..446 'NFF#)<<> 'x#+>>#3'KGR<<-1-O-O"E7BLL.B(B KM K08?H.2+$&LL'&'' ' '   " (BsA:C<C =ACr)rrrrr+rHrrrUr\r staticmethodrrrTr4r*rrsO $ P( %% &P44 #r4rcVeZdZdZdZdZdZedZdZ e d dZ d Z d Z y) EagerDiscovererz A convenient container for storing discovered API resources. Allows easy searching and retrieval of specific resources. All resources are discovered for the cluster upon object instantiation. c||_yr.)_EagerDiscoverer__resources)r&rfs r*rvzEagerDiscoverer.update^s $r4c@d|_tj|||yr.)rrr+rs r*r+zEagerDiscoverer.__init__asD&*5r4cNK|jdd{|_y7 w)NTrq)r}rr1s r*rHzEagerDiscoverer.discoveres"!%!6!6!6!NNNrcjK|jddd{}|djS7w)z list available api groups TrNrrrs r*rUzEagerDiscoverer.api_groupshs9,,tD,QQf~""$$RrcK|j|jdi||j}|sD|jd{|j|jdi||j}|S72w)aW Takes keyword arguments and returns matching resources. The search will happen in the following order: prefix: The api prefix for a resource, ie, /api, /oapi, /apis. Can usually be ignored group: The api group of a resource. Will also be extracted from api_version if it is present there api_version: The api version of a resource kind: The kind of the resource arbitrary arguments (see below), in random order The arbitrary arguments can be any valid attribute for an Resource object NrT)_EagerDiscoverer__search_EagerDiscoverer__build_searchrrCrs r*r\zEagerDiscoverer.searchnsu-- 3 3 3 =f =t?O?OP'') ) )mm$7D$7$7$A&$A4CSCSTG *sAA9A73A9Nc t|s|rd|vr|jd\}}|||||g}ttd|S)Nrc|xsdSrrTrs r*rz0EagerDiscoverer.__build_search..rr4rrs r*rzEagerDiscoverer.__build_searchrr4c "|d}|j|}|dk7r|rt|tr|j|dd|jSt|t r|j|dd|S|ddk7rMt|dt r:|D]3}|dj D]\}}t|||k(s|gccS5gS|S|dk(rAg}|jD]*} |j|j| g|ddz|,|SgS)Nrrr ) rBrrhrrfrrrrr) r&rrfrrrrrrrs r*rzEagerDiscoverer.__searchs%Qx! d+ 3;=-7}}U12Y 0G0GHHM40}}U12Y >>8s?z%(D'A%23 +08>>+;3KD%&y$75@(1{ 233I(( S[G ~~' Lt}}cUU12Y-> JK LN r4c#K|jjD]Q\}}|jD]9\}}|jD]!\}}|jD] \}}| #;Sywr.)rr)r&rrlrrrfrs r*__iter__zEagerDiscoverer.__iter__sz))//1 'IAv%||~ ' 8$,NN$4'LAy'0'8' 8&'' ' 'sA0A2r)rrrrrvr+rHrrUr\rrrrrTr4r*rrWsN %6O%% "442'r4rceZdZdZddZdZy)rhz%Helper class for Discoverer containerNc(||_|xsi|_yr.r|rf)r&r|rfs r*r+zResourceGroup.__init__s""br4c6d|j|jdS)Nrh)_typer|rfrr1s r*to_dictzResourceGroup.to_dicts$  r4r.)rrrrr+rrTr4r*rhrhs/) r4rhceZdZdZy)rQc"|jSr.)r)r&os r*defaultzCacheEncoder.defaultsyy{r4N)rrrrrTr4r*rQrQsr4rQceZdZdZdZy)rAcp||_tjj|g|d|ji|y)N object_hook)rr? JSONDecoderr+r)r&rargsr[s r*r+zCacheDecoder.__init__s2  !!$VtVD4D4DVvVr4cd|vr|S|jd}|dk(rtd d|ji|S|dk(rt|jfi|S|dk(r"t |d|j |dS|S) Nrrrrrhr|rfrerT)rrrrrhr)r&objrs r*rzCacheDecoder.object_hooks # J  J 64;;6#6 6 n $ 3s3 3 o % [!1T=M=McR]N^=_` ` r4N)rrrr+rrTr4r*rArAs W r4rA))rr?loggingr r#abcr collectionsr functoolsrtypingraiohttp.client_exceptionsrurllib3.exceptionsrr kubernetes.aior exceptionsr r rrrrrrj getLoggerrrEobjectrrrrh JSONEncoderrQrrArTr4r*r s  #6;&-   8 $HfHfVa#Za#HN'jN'b  F  4## 4##r4