ZiDrddlZddlZddlZddlZddlZddlZddlmZddlm Z ddl m Z m Z ddl mZddlmZmZddlmZdd lmZmZmZmZmZdd lmZmZd ZGd d eZGddeZ GddeZ!GddeZ"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||_|jjj}tjr|d} dtj|d }nI#t$r<dtj| }YnwxYw|p0tj tj||_|dS)Nzutf-8zosrcp-{0}.jsonF)usedforsecurity)client configurationhostsixPY3encodeformathashlibmd5 hexdigest TypeErrorospathjointempfile gettempdir_Discoverer__cache_file_Discoverer__init_cache)selfr cache_filedefault_cache_iddefault_cachefile_names W/root/projects/butler/venv/lib/python3.11/site-packages/kubernetes/dynamic/discovery.py__init__zDiscoverer.__init__,s ;49 7 @/66w??  h%5%<%=$$2T2TUZ\^`dfj2k2kmmmm*7*=*=  u %' -6L.just_jsons rMr] kubernetesr;z/version) serializerzhttps://zGHost value %s should start with https:// when talking to HTTPS endpoint) r6r;rrq ValueErrorr isinstancereasonrrr startswithr\)r*r}rEs 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)/Nrlcd|dvSNrrorPresources r.z:Discoverer.get_resources_for_api_version..sS@P5PrMcd|dvSrrPrs r.rz:Discoverer.get_resources_for_api_version..sx?O8OrMror )rTrUrVrrw)rTrUrVrrw subresourcesrW)rUrV base_kindrP)rlistr%filterrrqrcrrsplitr;poprappendrrW)r*rTrUr]rwrcrr$resources_response resources_rawsubresources_raw subresourcerrokey resourceobj resource_lists r.rfz(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 rVc6g|]}|jdk|S)rV) group_version).0resultrXs r. z"Discoverer.get..s2!0D}H]0]0]0]0]0]rMc8g|]}t|tSrPrr)rxs r.rz"Discoverer.get..s"(V(V(VA|)D)D(V(V(VrMc<g|]}t|t|SrPr)rrs r.rz"Discoverer.get..s'\\\&:fl;[;[\v\\\rMrzNo matches found for {}z!Multiple matches found for {}: {}NrP)rYlenr;allr rrr*rXresultss ` r.r;zDiscoverer.gets  $+'''' w<gS|Sg} |D]8} | | | g|ddz||9| S)Nr*z2prefix and group params should be present, have %sr rcT)r;rrerrrcrfrwr r r6rrdictitemsgetattrrextend)r*partsrc reqParamspart resourcePartrTrUr] _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 |pdSNrrPrs r.rz/LazyDiscoverer.__build_search..0 !(srMrrmapr*rTrUrVrWrXrs r.__build_searchzLazyDiscoverer.__build_search+_ 8 8 ););!,!2!23!7!7 E; T6:C**E22333rMc #K|jD]\}}|D]\}}|D]t\}}|jsE|||||j|_||jd|||<d|_tj|jD] \}}|V u| dS)NrcT) rrrcrfrwr6rr iteritemsr) r*rTrirUrnr]rgr{rs r.__iter__zLazyDiscoverer.__iter__2s".4466 ' 'NFF#)<<>> ' 'x#+>>#3#3''KGR<3'+'I'I"E7BL(B(B KM K08?H.2+'*}R\'B'B'' 8&'' '   """""rMr) rrrrr/rArrrQrYrrrrPrMr.rrs $$$JJJ((( ZZXZ   (((T4444 # # # # #rMrcTeZdZdZdZdZdZedZdZ 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||_dSrO)_EagerDiscoverer__resources)r*rcs r.rrzEagerDiscoverer.updateHs$rMc>t|||dSrO)rr/rs r.r/zEagerDiscoverer.__init__Ks D&*55555rMc<|d|_dS)NTrm)rxrrLs r.rAzEagerDiscoverer.discoverNs!0040HHrMc`|dddS)z list available api groups TrrrrLs r.rQzEagerDiscoverer.api_groupsQs.$$tD$II&QVVXXXrMc ||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 rP)_EagerDiscoverer__search_EagerDiscoverer__build_searchrr<rs r.rYzEagerDiscoverer.searchWsx-- 3 3 = =f = =t?OPP U  ! ! # # #mm$7D$7$A$A&$A$A4CSTTGrMNc |s|rd|vr|d\}}|||||g}ttd|S)Nrc |pdSrrPrs r.rz0EagerDiscoverer.__build_search..mrrMrrs r.rzEagerDiscoverer.__build_searchhrrMc |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 ) r;rrerrcrrrrr) r*rrcrrrrrrrs r.rzEagerDiscoverer.__searchos}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 rMc#K|jD]W\}}|D]=\}}|D]#\}}|D] \}}|V $>XdSrO)rr)r*r{rirnrcrs r.rzEagerDiscoverer.__iter__s)//11 ' 'IAv%||~~ ' ' 8$,NN$4$4''LAy'0'8'8'' 8&'' ' ' 'rMr) rrrrrrr/rArrQrYrrrrPrMr.rrAs %%%666IIIYYXY "44442'''''rMrc eZdZdZddZdZdS)rez%Helper class for Discoverer containerNc&||_|pi|_dSrOrwrc)r*rwrcs r.r/zResourceGroup.__init__s""brMc"d|j|jdS)Nre)_typerwrcrrLs r.to_dictzResourceGroup.to_dicts$   rMrO)rrrrr/rrPrMr.reres=//))))     rMreceZdZdZdS)rJc*|SrO)r)r*os r.defaultzCacheEncoder.defaultsyy{{rMN)rrrrrPrMr.rJrJs#rMrJceZdZdZdZdS)r:cV||_tjj|g|Rd|ji|dS)N object_hook)rr8 JSONDecoderr/r)r*rargsrXs r.r/zCacheDecoder.__init__s;  !$VtVVVD4DVvVVVVVrMc d|vr|S|d}|dkrtd d|ji|S|dkrt|jfi|S|dkr0t |d||dS|S) NrrrrrerwrcrbrP)rrrrrer)r*objrs r.rzCacheDecoder.object_hooks #  J   J  664;6#66 6 n $ $ 33s33 3 o % % [!1T=M=McR]N^=_=_``` ` rMN)rrrr/rrPrMr.r:r:s5WWW     rMr:)'r#rr8r>rr& functoolsr collectionsrabcrr json.decoderrurllib3.exceptionsrr r~r exceptionsr r rrrrrrrgobjectrrrre JSONEncoderrJrr:rPrMr.rs. ######00000000((((((;;;;;;;;""""""{{{{{{{{{{{{{{,,,,,,,,wfwfwfwfwfwfwfwft`#`#`#`#`#Z`#`#`#FL'L'L'L'L'jL'L'L'^      F    4# 4#rM