tjiDfddlZddlZddlZddlZddlZddlmZddlmZddl m Z m Z ddl m Z ddlmZmZddlmZdd lmZmZmZmZmZdd lmZmZd ZGd d ZGddeZGddeZGddZ Gddej!Z"Gddej#Z$dS)N)partial) defaultdict)abstractmethodabstractproperty)JSONDecodeError) ProtocolError MaxRetryError) __version__) NotFoundErrorResourceNotFoundErrorResourceNotUniqueError ApiExceptionServiceUnavailableError)Resource ResourceListapisceZdZdZdZddZdZdZedZ e dd Z e d Z e d Zdd Zdd ZdZdZdZdS) 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. c||_|jjjd} dt j|d}nI#t$r<dt j|}YnwxYw|p0tj tj ||_|dS)Nzutf-8zosrcp-{0}.jsonF)usedforsecurity)client configurationhostencodeformathashlibmd5 hexdigest TypeErrorospathjointempfile gettempdir_Discoverer__cache_file_Discoverer__init_cache)selfr cache_filedefault_cache_iddefault_cachefile_names Z/var/www/html/CA-Chatbot/venv/lib/python3.11/site-packages/kubernetes/dynamic/discovery.py__init__zDiscoverer.__init__+s ;49@@II h%5%<%zDiscoverer.discover\rOrJc|jSrL)_Discoverer__versionrIs r,versionzDiscoverer.version`s ~rJc i}dd|r'td|ddddntdii|d<ddtddt|jgiii|t<|S)Nv1Tapi resourcesList) ResourceGroupget_resources_for_api_versionrrDISCOVERY_PREFIX)r(request_resourcesgroupss r,default_groupszDiscoverer.default_groupsds $>=$$2T2TUZ\^`dfj2k2kmmmm*7*=*=  u %' -6L.just_jsons rJrZ kubernetesr8z/version) serializerzhttps://zGHost value %s should start with https:// when talking to HTTPS endpoint) r3r8rrn ValueErrorr isinstancereasonrrr startswithrY)r(rzrBs r,r=zDiscoverer._load_server_infos    {y))   $+"5"5eZT]"5"^"^* I&& .   a// 18]8[8[{05@@LL$%n%)[%>%C&DEEE Y/s'ACA6CCc btt}i}dtd|||g} |jd|jpg}n#ttf$rg}YnwxYwttd|} ttd|} | D]F} | d dd\} } | | si|| <| || | <G| D]} dD]}| |dtd ||||j|| | dd | }|| d  |t|j||| d  }||j ||S) zT returns a dictionary of resources associated with provided (prefix, group, version)/Nricd|dvSNrrlrMresources r,z:Discoverer.get_resources_for_api_version..sS@P5PrJcd|dvSrrMrs r,rz:Discoverer.get_resources_for_api_version..sx?O8OrJrlr )rQrRrSrrt)rQrRrSrrt subresourcesrT)rRrS base_kindrM)rlistr#filterrrnr`rrsplitr8poprappendrrT)r(rQrRrZrtr`rr"resources_response resources_rawsubresources_raw subresourcerrlkey resourceobj resource_lists r,rcz(Discoverer.get_resources_for_api_versions  %%  xxtfeW%=>>?? $!%!4!4UD!A!A!K!Qr  '9 $ $ $!#    $V$P$PRdeeff 'O'OQc d dee+ 7 7K(066sA>>NHd##H-- ,)+ X&+6L "4 ( (% @ @HP ( ( S$''''"#{#)--hv.>?? K hv& ' . .{ ; ; ;(EwbjkqbrsssM m( ) 0 0 ? ? ? ?s"A!!A76A7c |jd i}t|dkr#drfd|D}t|dkr%td|Ds d|D}t|dkr|dS|s"t dt d|) 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. r rSc6g|]}|jdk|S)rS) group_version).0resultrUs r, z"Discoverer.get..s2!0D}H]0]0]0]0]0]rJc8g|]}t|tSrMr~r)rxs r,rz"Discoverer.get..s"(V(V(VA|)D)D(V(V(VrJc<g|]}t|t|SrMr)rrs r,rz"Discoverer.get..s'\\\&:fl;[;[\v\\\rJrzNo matches found for {}z!Multiple matches found for {}: {}NrM)rVlenr8allr rrr(rUresultss ` r,r8zDiscoverer.gets  $+'''' w<propertyrZrgrur=rcr8rMrJr,rr#s,       &(((      ^   ^ X    ((((0000('''RfffffrJrcTeZdZdZdZdZdZedZdZ dZ d d Z d Z dS) LazyDiscovererz A convenient container for storing discovered API resources. Allows easy searching and retrieval of specific resources. Resources for the cluster are loaded lazily. cLt|||d|_dSNF)rr-_LazyDiscoverer__update_cacher(rr)s r,r-zLazyDiscoverer.__init__s(D&*555#rJc<|d|_dS)NFrj)ru_LazyDiscoverer__resourcesrIs r,r>zLazyDiscoverer.discovers!0050IIrJcN|jr|d|_dSdSr)rr?rIs r,__maybe_write_cachez"LazyDiscoverer.__maybe_write_caches7   (      "'D    ( (rJc`|dddS)NFTrerorrukeysrIs r,rNzLazyDiscoverer.api_groupss,$$uT$JJ6RWWYYYrJc  ||jdi||jg}n#t$rg}YnwxYw|s;|||jdi||jg}||S)NrM)_LazyDiscoverer__search_LazyDiscoverer__build_searchrr r9"_LazyDiscoverer__maybe_write_cachers r,rVzLazyDiscoverer.searchs mm$7D$7$A$A&$A$A4CSUWXXGG$   GGG  Y  ! ! # # #mm$7D$7$A$A&$A$A4CSUWXXG   """s '* 99c |d}|dkr||}|sgSt|trt|dkrt d|z|jsn|d|d|}}} |||||j|_n#t$rtwxYw||j d|||<d|_ | |dd|j|St|tr#| |dd|||gzS|ddkr]t|dtrB|D]=} |dD] \} } t| | | kr| gccS!>gS|Sg} |D]8} | | | g|ddz||9| S)Nr*z2prefix and group params should be present, have %sr r`T)r8r~rbrr}r`rcrtr r r3rrdictitemsgetattrrextend)r(partsr` reqParamspart resourcePartrQrRrZ _resourcetermvaluematchesrs r,__searchzLazyDiscoverer.__searchsCQx 3;;$==..L ( L-88 (y>>Q&&$%Y\e%efff#- /-6q\9Q<7EF4151S1S"E41G2I2I ..(444334HTDK ,V4U;GD*.D'}}U122Y 0F RRRL$// (}}U122Y i4&>PRRR8s??z%(D'A'A?%133 +08>>+;+;33KD%&y$775@@(1{ 2 2 2 2 2 A3I''G ~~'' W Wt}}cUU122Y-> 9UUVVVVNs ="B B2Nc |s|rd|vr|d\}}|||||g}ttd|S)Nrc |pdSNrrMrs r,rz/LazyDiscoverer.__build_search..- !(srJrrmapr(rQrRrSrTrUrs r,__build_searchzLazyDiscoverer.__build_search(_ 8 8 ););!,!2!23!7!7 E; T6:C**E22333rJc #K|jD]\}}|D]\}}|D]t\}}|jsE|||||j|_||jd|||<d|_|jD] \}}|V u|dS)Nr`T)rrr`rcrtr3rr) r(rQrfrRrkrZrgrxrs r,__iter__zLazyDiscoverer.__iter__/s".4466 ' 'NFF#)<<>> ' 'x#+>>#3#3''KGR<3'+'I'I"E7BL(B(B KM K08?H.2+')|'9'9';';'' 8&'' '   """""rJr) rrrrr-r>rrrNrVrrrrMrJr,rrs $$$JJJ((( ZZXZ   (((T4444 # # # # #rJrcTeZdZdZdZdZdZedZdZ d dZ d Z d Z dS) 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||_dSrL)_EagerDiscoverer__resources)r(r`s r,rozEagerDiscoverer.updateEs$rJc>t|||dSrL)rr-rs r,r-zEagerDiscoverer.__init__Hs D&*55555rJc<|d|_dS)NTrj)rurrIs r,r>zEagerDiscoverer.discoverKs!0040HHrJc`|dddS)z list available api groups TrrrrIs r,rNzEagerDiscoverer.api_groupsNs.$$tD$II&QVVXXXrJc ||jdi||j}|s:|||jdi||j}|S)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 rM)_EagerDiscoverer__search_EagerDiscoverer__build_searchrr9rs r,rVzEagerDiscoverer.searchTsx-- 3 3 = =f = =t?OPP U  ! ! # # #mm$7D$7$A$A&$A$A4CSTTGrJNc |s|rd|vr|d\}}|||||g}ttd|S)Nrc |pdSrrMrs r,rz0EagerDiscoverer.__build_search..jrrJrrs r,rzEagerDiscoverer.__build_searcherrJc |d}||}|dkr|rt|tr#||dd|jSt|t r||dd|S|ddkr]t|dt rB|D]=}|dD] \}}t|||kr|gccS!>gS|S|dkrPg}|D]7} | || g|ddz|8|SgS)Nrrr ) r8r~rbrr`rrrrr) r(rr`rrrrrrrs r,rzEagerDiscoverer.__searchls}Qx }}T** 3;;<;, 66 (}}U122Y 0FGGGL$// (}}U122Y ===8s??z%(D'A'A?%133 +08>>+;+;33KD%&y$775@@(1{ 2 2 2 2 2 A3I'' S[[G ~~'' L Lt}}cUU122Y-> JJKKKKN rJc#K|jD]W\}}|D]=\}}|D]#\}}|D] \}}|V $>XdSrL)rr)r(rxrfrkr`rs r,rzEagerDiscoverer.__iter__s)//11 ' 'IAv%||~~ ' ' 8$,NN$4$4''LAy'0'8'8'' 8&'' ' ' 'rJr) rrrrror-r>rrNrVrrrrMrJr,rr>s %%%666IIIYYXY "44442'''''rJrc eZdZdZddZdZdS)rbz%Helper class for Discoverer containerNc&||_|pi|_dSrLrtr`)r(rtr`s r,r-zResourceGroup.__init__s""brJc"d|j|jdS)Nrb)_typertr`rrIs r,to_dictzResourceGroup.to_dicts$   rJrL)rrrrr-rrMrJr,rbrbs=//))))     rJrbceZdZdZdS)rGc*|SrL)r)r(os r,defaultzCacheEncoder.defaultsyy{{rJN)rrrrrMrJr,rGrGs#rJrGceZdZdZdZdS)r7cV||_tjj|g|Rd|ji|dS)N object_hook)rr5 JSONDecoderr-r)r(rargsrUs r,r-zCacheDecoder.__init__s;  !$VtVVVD4DVvVVVVVrJc d|vr|S|d}|dkrtd d|ji|S|dkrt|jfi|S|dkr0t |d||dS|S) Nrrrrrbrtr`r_rM)rrrrrbr)r(objrs r,rzCacheDecoder.object_hooks #  J   J  664;6#66 6 n $ $ 33s33 3 o % % [!1T=M=McR]N^=_=_``` ` rJN)rrrr-rrMrJr,r7r7s5WWW     rJr7)%r!r5r;rr$ functoolsr collectionsrabcrr json.decoderrurllib3.exceptionsrr r{r exceptionsr r rrrrrrrdrrrrb JSONEncoderrGrr7rMrJr,rs! ######00000000((((((;;;;;;;;""""""{{{{{{{{{{{{{{,,,,,,,,ufufufufufufufufp`#`#`#`#`#Z`#`#`#FL'L'L'L'L'jL'L'L'^         4# 4#rJ