o 9iD`ddlZddlZddlZddlZddlZddlZddlmZddlm Z ddl m Z m Z ddl mZddlmZmZddlmZdd lmZmZmZmZmZdd lmZmZd ZGd d eZGddeZ GddeZ!GddeZ"GddejFZ$GddejJZ&y)N)partial) defaultdict)abstractmethodabstractproperty)JSONDecodeError) ProtocolError MaxRetryError) __version__) NotFoundErrorResourceNotFoundErrorResourceNotUniqueError ApiExceptionServiceUnavailableError)Resource ResourceListapisceZdZdZdZddZdZdZedZ e ddZ e d Z e d Zdd Zdd Zd ZdZdZy) 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|j d} dj tj|dj}|xs2tjjtj||_|j#y#t$r5dj tj|j}YwxYw)Nzutf-8zosrcp-{0}.jsonF)usedforsecurity)client configurationhostsixPY3encodeformathashlibmd5 hexdigest TypeErrorospathjointempfile gettempdir_Discoverer__cache_file_Discoverer__init_cache)selfr cache_filedefault_cache_iddefault_cachefile_names e/var/www/html/leadgen/airagagent/rag_env/lib/python3.12/site-packages/kubernetes/dynamic/discovery.py__init__zDiscoverer.__init__,s ;;4499 77/66w?  h%5%<%.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&Y/ . a/ 188]8[{{0055@@L$%n%)[[%>%>%C%C&DEE s-A""C=1BC88C=c tt}i}djtd|||g} |jj d|j xsg}ttd|} ttd|} | D]8} | djdd\} } |j| si|| <| || | <:| D]} dD]}| j|dtd ||||j||j| dd | }|| d j|t|j||| d  }||jj||S#ttf$rg}YwxYw) 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!K!K!Qr  V$PRdef 'OQc de+ 7K(066sA>NHd##H-)+ X&+6L "4 (  7 & @HP ( S$' (##{{#)--hv.>? K hv& ' . .{ ;(EwbjkqbrsM m(( ) 0 0 ?# @$=(9 $!#  $s*E%%E:9E:c |jdi|}t|dkDr3|jdr"|Dcgc]}|j|dk(s|}}t|dkDrGt |Dcgc]}t |t c}s |Dcgc]}t |t r|}}t|dk(r|dS|stdj|tdj||cc}wcc}wcc}w)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 rVrzNo matches found for {}z!Multiple matches found for {}: {}rP) rYlenr; group_versionallrrr rr)r*rXresultsresultxs r.r;zDiscoverer.gets $++'' wQ&$%Y\e%eff#---6q\9Q<7EF4151S1S"E41G1G2I . HTDKK ,V4U;GD*.D'}}U12Y 0F0F RRL$/}}U12Y i4&>PRR8s?z%(D'A%13 +08>>+;3KD%&y$75@(1{ 233 I''G ~~' Wt}}cUU12Y-> 9UV WN1)4334s &#F FNc t|s|rd|vr|jd\}}|||||g}ttd|S)Nrc|xsdSNrrPrs r.rz/LazyDiscoverer.__build_search..0 !(srMrrmapr*rTrUrVrWrXrs r.__build_searchzLazyDiscoverer.__build_search+F );!,!2!23!7 E; T6:C*E233rMc #K|jjD]\}}|jD]\}}|jD]~\}}|jsB|j||||j|_||j d|||<d|_tj|jD] \}}| |jyw)NrcT) rrrcrfrwr6rr iteritemsr) r*rTrirUrnr]rgr{rs r.__iter__zLazyDiscoverer.__iter__2s"..446 'NFF#)<<> 'x#+>>#3'KGR<<'+'I'I"E7BLL(B KM K08?H.2+'*}}R\\'B' 8&'' ' '   "sCCr) rrrrr/rArrrQrYrrrrPrMr.rrsB $J( ZZ (T4 #rMrcLeZdZdZdZdZdZedZdZ 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||_yrO)_EagerDiscoverer__resources)r*rcs r.rrzEagerDiscoverer.updateHs $rMc2tj|||yrO)rr/rs r.r/zEagerDiscoverer.__init__KsD&*5rMc2|jd|_y)NTrm)rxrrLs r.rAzEagerDiscoverer.discoverNs0040HrMcJ|jdddjS)z list available api groups TrrrrLs r.rQzEagerDiscoverer.api_groupsQs($$tD$I&QVVXXrMc |j|jdi||j}|s<|j|j|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.searchWsf-- 3 3 3 =f =t?O?OP  ! ! #mm$7D$7$7$A&$A4CSCSTGrMNc t|s|rd|vr|jd\}}|||||g}ttd|S)Nrc|xsdSrrPrs r.rz0EagerDiscoverer.__build_search..mrrMrrs r.rzEagerDiscoverer.__build_searchhrrMc "|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 ) r;rrerrcrrrrr) r*rrcrrrrrrrs r.rzEagerDiscoverer.__searchos%Qx }}T* 3;<, 6}}U12Y 0F0FGGL$/}}U12Y ==8s?z%(D'A%13 +08>>+;3KD%&y$75@(1{ 233I'' S[G ~~' Lt}}cUU12Y-> JK LN rMc#K|jjD]Q\}}|jD]9\}}|jD]!\}}|jD] \}}| #;SywrO)rr)r*r{rirnrcrs r.rzEagerDiscoverer.__iter__sz))//1 'IAv%||~ ' 8$,NN$4'LAy'0'8' 8&'' ' 'sA0A2r) rrrrrrr/rArrQrYrrrrPrMr.rrAsA %6IYY "42'rMrceZdZdZddZdZy)rez%Helper class for Discoverer containerNc(||_|xsi|_yrOrwrc)r*rwrcs r.r/zResourceGroup.__init__s""brMc6d|j|jdS)Nre)_typerwrcrrLs r.to_dictzResourceGroup.to_dicts$  rMrO)rrrrr/rrPrMr.reres/) rMreceZdZdZy)rJc"|jSrO)r)r*os r.defaultzCacheEncoder.defaultsyy{rMN)rrrrrPrMr.rJrJsrMrJceZdZdZdZy)r:cp||_tjj|g|d|ji|y)N object_hook)rr8 JSONDecoderr/r)r*rargsrXs r.r/zCacheDecoder.__init__s2  !!$VtVD4D4DVvVrMcd|vr|S|jd}|dk(rtd d|ji|S|dk(rt|jfi|S|dk(r"t |d|j |dS|S) NrrrrrerwrcrbrP)rrrrrer)r*objrs r.rzCacheDecoder.object_hooks # J  J 64;;6#6 6 n $ 3s3 3 o % [!1T=M=McR]N^=_` ` rMN)rrrr/rrPrMr.r:r:s W rMr:)'r#rr8r>rr& functoolsr collectionsrabcrr json.decoderrurllib3.exceptionsrr r~r exceptionsr r rrrrrrrgobjectrrrre JSONEncoderrJrr:rPrMr.rs #0(;"{{,wfwft`#Z`#FL'jL'^  F  4## 4##rM