dQj:ddlmZddlmZddlmZmZddlmZm Z ddl m Z m Z m Z mZmZ ddlZdZ dd lmZgd ZdZGddeZy#e$rd ZY#wxYw#e$rGd d eZY2wxYw))watch) ApiException)EagerDiscovererLazyDiscoverer)KubernetesValidateMissing api_exception)Resource ResourceFieldResourceInstance ResourceList SubresourceNTF)VersionNotSupportedErrorc eZdZy)rN)__name__ __module__ __qualname__b/home/oem/CyberBrain26-unified/.venv/lib/python3.12/site-packages/kubernetes/aio/dynamic/client.pyrr!s rr) DynamicClientr r r rrrr cfd}|S)zC Handles parsing response structure and translating API Exceptions cfK|jdd}|jdt} |g|i|d{}|r" |j d{}|||S|S7*#t$r}t|d}~wwxYw7-#t $r|j d{7}|cYSwxYww)N serializeT serializer)popr rr json ValueError) selfargskwargsserialize_responserrespedatafuncs rinnerzmeta_request..inner2s#ZZ T:ZZ .>?  #d4T4V44D  !YY[(!$-- 5 #" " #) !YY[((  sz)B1A)A'A)B1BB B$B1'A)) B2 A==BB1BB.#B&$B.+B1-B..B1r)r&r's` r meta_requestr(0s LrceZdZdZddZdZdZdZedZ edZ e d Z e d Z dd Zdd Z dd ZddZddZddZe ddZeddZddZy)rzb A kubernetes client that dynamically discovers and interacts with the kubernetes API Nc`||_||_|j|_|xst|_yN) cache_fileclient configurationr discoverer)rr-r,r/s r__init__zDynamicClient.__init__Js*$ #11$6rc8fd}|jS)NcfKjjd{_S7 wr+r/r,_DynamicClient__discovererrsrclosurez(DynamicClient.__await__..closureQs,&*oodDOO&L LD K!Ms 1/ 1) __await__)rr6s` rr7zDynamicClient.__await__Ps y""$$rcdK|j||jd{|_|S7 wr+r3r5s r __aenter__zDynamicClient.__aenter__Ws+"&//$"HH Is 0. 0c Kywr+r)rr r!s r __aexit__zDynamicClient.__aexit__[s sc|jSr+)r4r5s r resourceszDynamicClient.resources^s   rc.|jjSr+)r4versionr5s rr?zDynamicClient.versionbs  (((rc|xs!|jdijd}|s/tdj|j|j|S)Nmetadata namespacezNamespace is required for {}.{})getrformat group_versionkind)resourcerBbodys rensure_namespacezDynamicClient.ensure_namespacefsQJ*b!9!=!=k!J >EEhF\F\^f^k^klm mrcZtt|ddr|jS|xsiS)zSerialize body to raw dict so apiserver can handle it :param body: kubernetes resource body, current support: Union[Dict, ResourceInstance] to_dictN)callablegetattrrK)rHs rserialize_bodyzDynamicClient.serialize_bodyms+ GD)T2 3<<> !zrrclK|j||}|jd|fi|d{S7w)NnamerBrC)pathrequest)rrGrQrBr!rRs rrCzDynamicClient.getxs6}}$)}<!T\\%88888s +424cK|j|}|jr|j|||}|j|}|jd|fd|i|d{S7w)N)rBpostrH)rN namespacedrIrRrS)rrGrHrBr!rRs rcreatezDynamicClient.create|sf""4(   --h 4HI}}y}1!T\\&$DTDVDDDDsAA%A#A%cK|s|s |s td|jr|s|s |s td|j||}|jd|f|||d|d{S7w)Nz>At least one of name|label_selector|field_selector is requiredzCAt least one of namespace|label_selector|field_selector is requiredrPdelete)rHlabel_selectorfield_selector)rrVrRrS) rrGrQrBrHrZr[r!rRs rrYzDynamicClient.deletes.]^ ^   .Ibc c}}$)}<!T\\(DKtN1?KCIKK KKsAA&A$ A&c|K|j|}|xs!|jdijd}|s/tdj|j|j |j r|j|||}|j||}|jd|fd|i|d{S7w)NrArQz!name is required to replace {}.{}rPputrH) rNrCrrDrErFrVrIrRrS)rrGrHrQrBr!rRs rreplacezDynamicClient.replaces""4(;txx B/33F;@GGH^H^`h`m`mno o   --h 4HI}}$)}<!T\\%CDCFCCCCsB3B<5B:6B<cK|j|}|xs!|jdijd}|s/tdj|j|j |j r|j|||}|jdd}|j||}|jd|f||d|d{S7w) NrArQname is required to patch {}.{} content_typez&application/strategic-merge-patch+jsonrPpatch)rHra) rNrCrrDrErFrVrIrrRrS)rrGrHrQrBr!rarRs rrbzDynamicClient.patchs""4(;txx B/33F;>EEhF\F\^f^k^klm m   --h 4HIzz.2Z[ }}$)}<!T\\'4`d`Y_````sCCC  CcK|j|}|xs!|jdijd}|s/tdj|j|j |j r|j|||}|jddi|j||}|jd|f||d|d{S7w) NrArQr`razapplication/apply-patch+yamlrPrb)rHforce_conflicts) rNrCrrDrErFrVrIupdaterRrS)rrGrHrQrBrdr!rRs rserver_side_applyzDynamicClient.server_side_applys""4(;txx B/33F;>EEhF\F\^f^k^klm m   --h 4HI  ~'EFG}}$)}<!T\\'4fdOf_effffsCC C Cc K|stj}|rd|}i}|||d<|j|jf||||dd|23d{} | dk(ryt || d| d<| (7#6yw)a Stream events for a resource from the Kubernetes API :param resource: The API resource object that will be used to query the API :param namespace: The namespace to query :param name: The name of the resource instance to query :param label_selector: The label selector with which to filter results :param field_selector: The field selector with which to filter results :param resource_version: The version with which to filter results. Only events with a resource_version greater than this value will be returned :param timeout: The amount of time in seconds to wait before terminating the stream :param watcher: The Watcher object that will be used to stream the resource :return: Event object with these keys: 'type': The type of event such as "ADDED", "DELETED", etc. 'raw_object': a dict representing the watched object. 'object': A ResourceInstance wrapping raw_object. Example: client = DynamicClient(k8s_client) watcher = watch.Watch() v1_pods = client.resources.get(api_version='v1', kind='Pod') for e in v1_pods.watch(resource_version=0, namespace=default, timeout=5, watcher=watcher): print(e['type']) print(e['object'].metadata) # If you want to gracefully stop the stream watcher watcher.stop() zmetadata.name=Ntimeout_secondsF)rBr[rZresource_versionrobject)rWatchstreamrCr ) rGrBrQrZr[ritimeoutwatcherr!events rrzDynamicClient.watchs@kkmG -dV4N  (/F$ %)7>> LL ))-    %{.xxIE(OK  s*A A8 A6A4A6 A84A66A8c K|jdsd|z}|jdi}|jdg}|jd|jd|df|jd|jd|df|jd|jd|df|jd |jd |d f|jd |jd |d f|jd |jd |d f|jd|jd|df|jd|jd|df|jd|jd|df|jd|jd|df|jd|jd|df|jd|jd|df|jd|jd|df|jd|jd|df|jd|jd|df|jdi}g}i} td |j D} d!| vr |j j d"d#g|d$<|jd%r |d%|d&<nd"|d&<d'g} |j j|j||||||| | ( d{} |j j| d)|jd)id{} d*| jcxkrd+ks6n| jd{|j j| i| jS77]70w),N/ path_params query_paramspretty _continuecontinueinclude_uninitializedincludeUninitializedr[ fieldSelectorrZ labelSelectorlimitriresourceVersionrhtimeoutSecondsrgrace_period_secondsgracePeriodSecondspropagation_policypropagationPolicyorphan_dependentsorphanDependentsdry_rundryRun field_manager fieldManagerrdforce header_paramsc3FK|]\}}|j|fywr+)lower).0keyvalues r z(DynamicClient.request..s ^*#u#))+u!5 ^s!acceptzapplication/jsonzapplication/yamlAcceptraz Content-Type BearerToken)rsrtrrH post_paramsfiles auth_settings_request_timeouti+) startswithrCappenddictitemsr-select_header_acceptparam_serializeuppercall_apistatusreadresponse_deserializeresponse)rmethodrRrHparamsrsrtr form_paramslocal_var_filesnew_header_paramsrrS api_responses rrSzDynamicClient.requestss#:Djj3 zz."5 ::h  +   6(+; < = ::k " .   VK-@ A B ::- . :   !7@W9X Y Z ::& ' 3   &9I2J K L ::& ' 3   &9I2J K L ::g  *   &/ : ; ::( ) 5   !2F;M4N O P ::' ( 4   !16:K3L M N ::g  *   &/ : ; ::, - 9   !5v>T7U V W ::* + 7   !4f=Q6R S T ::) * 6   !3V ::o & 2   1H I J ::' ( 4   &1B*C D E ?B7  ! ^ H[H[H] ^^ , ,&*kk&F&F""H'M( # ::n %,2>,BM. )-?M. )'  33 LLN #%'#!'4   2T[[11  #ZZ(:;  l))0S0##% % % KK , ,\2 >$$$%   &s6L5O 7O82O *O+.O O -O O  O c ts tt}t} | |jdd}t j|||||fS#t$rt j }Y:wxYw#t jj$rd}|jddj|jDcgc] }t|ncc}wc}d|jYd}~||fSd}~wt$r|jd|zY||fSt jj $rF}|jd|j"d |j$d |jd Yd}~||fSd}~wwxYw) avalidate checks a kubernetes resource definition Args: definition (dict): resource definition version (str): version of kubernetes to validate against strict (bool): whether unexpected additional properties should be considered errors Returns: warnings (list), errors (list): warnings are missing validations, errors are validation failures N kubernetes gitVersionz(resource definition validation error at .z: z=Kubernetes version %s is not supported by kubernetes-validatez&Could not find schema for object kind z with API version z in Kubernetes version z (possibly Custom Resource?))HAS_KUBERNETES_VALIDATErlistr?KeyErrorkubernetes_validatelatest_versionvalidateutilsValidationErrorrjoinrRstrmessagerSchemaNotFoundErrorrF api_version)r definitionr?stricterrorswarningsr$items rrzDynamicClient.validate>ss'+- -6 @C"ll<8FG ( (Wf E C1@@BGC#((88 Z MMchhnontntWufjX[\`XaWuWuNvNOiiY Z Z ( e MMY\cc d  #((<< @ OOVVQ]]AII? @ @  @sWA9AA9A63A95A66A99E<%C5;C C55 E<E<69E77E<)NN)NNNNN)NNN)NNNN)NNNNNNNr+)NF)rrr__doc__r0r7r9r;propertyr=r? staticmethodrIrNrCrWrYr^rbrfrr(rSrrrrrrEs7 %!!)) 9E[_$(KD a g]aAE66pP%P%d  rr)kubernetes.aiorkubernetes.aio.client.restr discoveryrr exceptionsrr rGr r r r rrr ImportErrorkubernetes_validate.utilsrNotImplementedError__all__r(rkrrrrrs!36@$" B *Y FY U$#$   #6  s"A A AAA,+A,