eQj<ddlZddlmZddlmZddlmZmZddlm Z m Z ddl m Z m Z mZmZmZ ddlZdZ dd lmZgd ZdZGddZy#e$rd ZY"wxYw#e$rGd d eZY1wxYw)N)watch) ApiException)EagerDiscovererLazyDiscoverer) api_exceptionKubernetesValidateMissing)Resource ResourceList SubresourceResourceInstance ResourceFieldTF)VersionNotSupportedErrorc eZdZy)rN)__name__ __module__ __qualname__^/home/oem/CyberBrain26-unified/.venv/lib/python3.12/site-packages/kubernetes/dynamic/client.pyrr!s rr) DynamicClientr r r r rrrcfd}|S)zC Handles parsing response structure and translating API Exceptions cn|jdd}|jdt} |g|i|}|r6 ||t j |j jdS|S#t$r}t|d}~wwxYw#t$r|j jdcYSwxYw)N serializeT serializerutf8) popr rrjsonloadsdatadecode ValueError)selfargskwargsserialize_responserrespefuncs rinnerzmeta_request..inner2s#ZZ T:ZZ .>?  #.t.v.D  0!$ 4993C3CF3K(LMM  #" " #  0yy''// 0s( A14B 1 B : BB  $B43B4r)r)r*s` r meta_requestr+0s  LrceZdZdZddZedZedZdZdZ ddZ dd Z dd Z dd Z dd Zdd ZddZeddZddZy)rzb A kubernetes client that dynamically discovers and interacts with the kubernetes API Ncd|xst}||_|j|_||||_yN)rclient configuration_DynamicClient__discoverer)r#r/ cache_file discoverers r__init__zDynamicClient.__init__Hs2 1>  #11&tZ8rc|jSr.)r1r#s r resourceszDynamicClient.resourcesQs   rc.|jjSr.)r1versionr6s rr9zDynamicClient.versionUs  (((rc|xs!|jdijd}|s/tdj|j|j|S)Nmetadata namespacezNamespace is required for {}.{})getr"format group_versionkind)r#resourcer<bodys rensure_namespacezDynamicClient.ensure_namespaceYsQJ*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)callablegetattrrE)r#rBs rserialize_bodyzDynamicClient.serialize_body_s+ GD)T2 3<<> !zrrc P|j||}|jd|fi|S)Nnamer<r=)pathrequest)r#rArKr<r%rLs rr=zDynamicClient.getis,}}$)}<t||E42622rc |j|}|jr|j|||}|j|}|jd|fd|i|S)N)r<postrB)rH namespacedrCrLrM)r#rArBr<r%rLs rcreatezDynamicClient.createms\""4(   --h 4HI}}y}1t||FD>t>v>>rc |s|s |s td|jr|s|s |s td|j||}|jd|f|||d|S)Nz>At least one of name|label_selector|field_selector is requiredzCAt least one of namespace|label_selector|field_selector is requiredrJdelete)rBlabel_selectorfield_selector)r"rPrLrM) r#rArKr<rBrTrUr%rLs rrSzDynamicClient.deletetse.]^ ^   .Ibc c}}$)}<t||Hd~nes~w}~~rc `|j|}|xs!|jdijd}|s/tdj|j|j |j r|j|||}|j||}|jd|fd|i|S)Nr;rKz!name is required to replace {}.{}rJputrB) rHr=r"r>r?r@rPrCrLrM)r#rArBrKr<r%rLs rreplacezDynamicClient.replace|s""4(;txx B/33F;@GGH^H^`h`m`mno o   --h 4HI}}$)}<t||E4=d=f==rc |j|}|xs!|jdijd}|s/tdj|j|j |j r|j|||}|jdd}|j||}|jd|f||d|S) Nr;rKname is required to patch {}.{} content_typez&application/strategic-merge-patch+jsonrJpatch)rBr[) rHr=r"r>r?r@rPrCrrLrM)r#rArBrKr<r%r[rLs rr\zDynamicClient.patchs""4(;txx B/33F;>EEhF\F\^f^k^klm m   --h 4HIzz.2Z[ }}$)}<t||GTZ<ZSYZZrc |j|}|xs!|jdijd}|s/tdj|j|j |j r|j|||}|jddi|j||}|jd|f||d|S) Nr;rKrZr[zapplication/apply-patch+yamlrJr\)rBforce_conflicts) rHr=r"r>r?r@rPrCupdaterLrM)r#rArBrKr<r^r%rLs rserver_side_applyzDynamicClient.server_side_applys""4(;txx B/33F;>EEhF\F\^f^k^klm m   --h 4HI  ~'EFG}}$)}<t||GT`o`Y_``rc #K|stj}|rd|}|j|j||||d|| | |  D]} t || d| d<| yw)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 :param allow_watch_bookmarks: Ask the API server to send BOOKMARK events :param send_initial_events: Ask the API server to begin the stream with synthetic events for the current state, followed by a BOOKMARK event :param resource_version_match: How resource_version is matched, e.g. "NotOlderThan". Required by the API server when send_initial_events is set :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=F) r<rUrTresource_versionrtimeout_secondsallow_watch_bookmarkssend_initial_eventsresource_version_matchobjectN)rWatchstreamr=r ) r#rAr<rKrTrUrbtimeoutwatcherrdrerfevents rrzDynamicClient.watchsF%++- -dV4N^^ LL))-#"7 3#9$  E/xxIE(OK sAA!c |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|jd|jd |df|jd!|jd"|d!f|jd#|jd$|d#f|jd%i}g}i} |jD cic]\} } | j | } } } d&| vr |j j d'd(g|d)<|jd*r |d*|d+<nd'|d+<d,g} |jd-d|j j|j||||||| | . }|j j|d/|jd/i}d0|jcxkrd1ks.n|j|j j|i|jScc} } w)2N/ path_params query_paramspretty _continuecontinueinclude_uninitializedincludeUninitializedrU fieldSelectorrT labelSelectorlimitrbresourceVersionrfresourceVersionMatchrctimeoutSecondsrgrace_period_secondsgracePeriodSecondspropagation_policypropagationPolicyorphan_dependentsorphanDependentsdry_rundryRun field_manager fieldManagerr^forcerdallowWatchBookmarksresendInitialEvents header_paramsacceptzapplication/jsonzapplication/yamlAcceptr[z Content-Type BearerToken async_req)rorprrB post_paramsfiles auth_settings_request_timeouti+) startswithr=appenditemslowerr/select_header_acceptrparam_serializeuppercall_apistatusreadresponse_deserializeresponse)r#methodrLrBparamsrorpr form_paramslocal_var_fileskeyvaluenew_header_paramsrrM api_responses rrMzDynamicClient.requests}s#: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 ::. / ;   !7@X9Y Z [ ::' ( 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 ::- . :   !6?V8W X Y ::+ , 8   !4f=R6S T U ?B7  CPBUBUBWXJCSYY[%/XX,,&*kk&F&F""H'M( # ::n %,2>,BM. )-?M. )'  ;%++-- LLN #%'#!'.  ,t{{++  #ZZ(:; l))0S0     KK , ,\2 >$$$UYs"Qc 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_VALIDATEr listr9KeyErrorkubernetes_validatelatest_versionvalidateutilsValidationErrorrjoinrLstrmessagerSchemaNotFoundErrorr@ api_version)r# definitionr9stricterrorswarningsr(items rrzDynamicClient.validate6s{'+- -6 @C"ll<8FG ( (Wf E C1@@BGC#((88 D MMchhnontntWufjX[\`XaWuWuNvxyyByBC D D  ( e MMY\cc d#((<< @ OOVVQ]]AII? @ @ @sWA9AA9A63A95A66A99E<%C5;C C55 E<E<69E77E<)NN)NNNNN)NNN)NNNN) NNNNNNNNNNr.)NF)rrr__doc__r4propertyr7r9rCrHr=rQrSrXr\r`rr+rMrrrrrrCs9!!)) 3?> [ a6pZ%Z%x rr)rrrkubernetes.client.restr discoveryrr exceptionsrr rAr r r r rrr ImportErrorkubernetes_validate.utilsrNotImplementedError__all__r+rrrrrs /6@ZZ$" B &Q Q Q$#$   #6  s"AAAAA/.A/