?gLDTddlZddlZddlZddlZddlZddlZddlmZddlm Z ddl m Z m Z ddl mZmZddlmZddlmZmZmZmZmZdd lmZmZd ZGd d eZGd deZGddeZGddeZ GddejBZ"GddejFZ$y)N)partial) defaultdict)abstractmethodabstractproperty) 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 Q/var/www/openai/venv/lib/python3.12/site-packages/kubernetes/dynamic/discovery.py__init__zDiscoverer.__init__+s ;;4499 77/66w?  h%5%<%.just_jsons rLr\ kubernetesr:z/version) serializerzhttps://zGHost value %s should start with https:// when talking to HTTPS endpoint) r5r:rrp ValueErrorr isinstancereasonrrr startswithr[)r)r|rDs 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#t$rg}YwxYw) zT returns a dictionary of resources associated with provided (prefix, group, version)/Nrkcd|dvSNrrnrOresources r-z:Discoverer.get_resources_for_api_version..sS@P5PrLcd|dvSrrOrs r-rz:Discoverer.get_resources_for_api_version..sx?O8OrLrnr )rSrTrUrrv)rSrTrUrrv subresourcesrV)rTrU base_kindrO)rlistr$filterrrprbrsplitr:poprappendrrV)r)rSrTr\rvrbrr#resources_response resources_rawsubresources_raw subresourcerrnkey resourceobj resource_lists r-rez(Discoverer.get_resources_for_api_versions %  xxtfeW%=>? $!%!4!4UD!A!K!K!Qr V$PRdef 'OQc de+K(066sA>NHd##H-)+ X&+6L "4 ( , &HP S$'Q##{{#)--hv.>? K hv& ' . .{ ;(EwbjkqbrsM m(( ) 0 0 ?#&$;' $!#  $s*E%% E43E4c |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 rUrzNo matches found for {}z!Multiple matches found for {}: {}rO) rXlenr: group_versionallrrr rr )r)rWresultsresultxs 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%1 +08>>+;KD%&y$75@(1{ 2,<&2 I''G ~~'t}}cUU12Y-> 9UV(N1)4334s &#F FNc t|s|rd|vr|jd\}}|||||g}ttd|S)Nrc|xsdSNrrOrs r-rz/LazyDiscoverer.__build_search... !(s(rLrrmapr)rSrTrUrVrWrs r-__build_searchzLazyDiscoverer.__build_search)F );!,!2!23!7 E; T6:C*E233rLc #K|jjD]\}}|jD]\}}|jD]~\}}|jsB|j||||j|_||j d|||<d|_tj|jD] \}}| |jyw)NrbT) rrrbrervr5rr iteritemsr) r)rSrhrTrmr\rgrzrs r-__iter__zLazyDiscoverer.__iter__0s"..446NFF#)<<>x#+>>#3KGR<<'+'I'I"E7BLL(B KM K08?H.2+'*}}R\\'B 8&(C$4$27   "sCCr) rrrrr.r@rrrPrXrrrrOrLr-rrsB $J( ZZ (T4 #rLrcLeZdZdZdZdZdZedZdZ 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||_yrN)_EagerDiscoverer__resources)r)rbs r-rqzEagerDiscoverer.updateFs $rLc2tj|||yrN)rr.rs r-r.zEagerDiscoverer.__init__IsD&*5rLc2|jd|_y)NTrl)rwrrKs r-r@zEagerDiscoverer.discoverLs0040HrLcJ|jdddjS)z list available api groups TrrrrKs r-rPzEagerDiscoverer.api_groupsOs($$tD$I&QVVXXrLc |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 rO)_EagerDiscoverer__search_EagerDiscoverer__build_searchrr;rs r-rXzEagerDiscoverer.searchUsf-- 3 3 3 =f =t?O?OP  ! ! #mm$7D$7$7$A&$A4CSCSTGrLNc t|s|rd|vr|jd\}}|||||g}ttd|S)Nrc|xsdSrrOrs r-rz0EagerDiscoverer.__build_search..krrLrrs r-rzEagerDiscoverer.__build_searchfrrLc "|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:rrdrrbrrrrr) r)rrbrrrrrrrs r-rzEagerDiscoverer.__searchmsQx }}T* 3;<, 6}}U12Y 0F0FGGL$/}}U12Y ==8s?z%(D'A%1 +08>>+;KD%&y$75@(1{ 2,<&2I'' S[G ~~'t}}cUU12Y-> JK(N rLc#K|jjD]Q\}}|jD]9\}}|jD]!\}}|jD] \}}| #;SywrN)rr)r)rzrhrmrbrs r-rzEagerDiscoverer.__iter__sf))//1IAv%||~ 8$,NN$4LAy'0'8 8&(9%5 .2sA0A2r) rrrrrqr.r@rrPrXrrrrOrLr-rr?sA %6IYY "42'rLrceZdZdZddZdZy)rdz%Helper class for Discoverer containerNc(||_|xsi|_yrNrvrb)r)rvrbs r-r.zResourceGroup.__init__s""brLc6d|j|jdS)Nrd)_typervrbrrKs r-to_dictzResourceGroup.to_dicts$  rLrN)rrrrr.rrOrLr-rdrds/) rLrdceZdZdZy)rIc"|jSrN)r)r)os r-defaultzCacheEncoder.defaultsyy{rLN)rrrrrOrLr-rIrIsrLrIceZdZdZdZy)r9cp||_tjj|g|d|ji|y)N object_hook)rr7 JSONDecoderr.r)r)rargsrWs r-r.zCacheDecoder.__init__s2  !!$VtVD4D4DVvVrLcd|vr|S|jd}|dk(rtd d|ji|S|dk(rt|jfi|S|dk(r"t |d|j |dS|S) NrrrrrdrvrbrarO)rrrrrdr)r)objrs r-rzCacheDecoder.object_hooks # J  J 64;;6#6 6 n $ 3s3 3 o % [!1T=M=McR]N^=_` ` rLN)rrrr.rrOrLr-r9r9s W rLr9)%r"rr7r=rr% functoolsr collectionsrabcrrurllib3.exceptionsrrr}r exceptionsr r r rrrrrrfobjectrrrrd JSONEncoderrIrr9rOrLr-rs #0;"{{,vfvfr`#Z`#FL'jL'^  F  4## 4##rL