dQj`)ddlZddlZddlZddlZddlmZddlmZddlm Z dZ dZ dZ dZ Gd d eZGd d eZy) N)partial)Any)clientz:rtype:z:param follow:Listctj|j}|tjjur|t urtj |r|St|trttj|r|Stj|xsdjD]9}|jt s|t#t dj%cSy)N)inspect signaturereturn_annotation Signatureemptyrisclass isinstancestrhasattrrmodelspydocgetdoc splitlines startswithPYDOC_RETURN_LABELlenstrip)func return_typelines _/home/oem/CyberBrain26-unified/.venv/lib/python3.12/site-packages/kubernetes/aio/watch/watch.py_find_return_typer#s##D);;K7,,222 s " OOK (;$ FMM; /d#)r557: ??- ../01779 9: ceZdZdZy)StreamcyN)selfrargskwargss r__init__zStream.__init__8s rN)__name__ __module__ __qualname__r(r$rrr!r!6s rr!cbeZdZddZdZdZdZdefdZdZ d Z d Z d Z d Z d ZdZdZy)WatchNcn||_d|_tj|_d|_d|_y)NF)_raw_return_type_stopr ApiClient _api_clientresource_versionresp)r%rs rr(zWatch.__init__>s1 + !++- $ rcd|_y)NT)r0r%s rstopz Watch.stopEs  rc0|jr |jSt|}t|tr|n |j}|j t r?|dtt  }t|tr|Sttj|S|Sr#) r/rrrr)endswithTYPE_LIST_SUFFIXrgetattrrr)r%rrreturn_type_nameitem_type_names rget_return_typezWatch.get_return_typeHs  (( ('- %k37K[=Q=Q   $ $%5 6-.E4D0E/EFN+s+%%6==.9 9rc<ttj|vryy)Nfollowwatch)PYDOC_FOLLOW_PARAMrr)r%rs rget_watch_argument_namezWatch.get_watch_argument_nameVs d!3 3rdatac: tj|}d|vsd|vrrd|vrTdj|j d|j d}t j j|d|tdj||d|d <|djd k(rA|d }dj|d|d}t j j|d||djd k7r|r7|jjtj|d |d |d<t|ddr |djj|_|St!|dt"r!d|dvrd|ddvr|ddd|_|S|djd k(rPt!|d t"r#d|d vrd|d dvr|d dd|_|Stdj||S#t$r|cYSwxYw)z8Return the K8s response `data` in JSON format. objecttypecodez{}: {}reasonmessage)statusrIzNMalformed JSON response, the 'object' and/or 'type' field is missing. JSON: {} raw_objecterrorbookmarkzapplication/json) response_text response_type content_typemetadataresourceVersionzfMalformed JSON response for bookmark event, 'metadata' or 'resourceVersion' field is missing. JSON: {})jsonloads ValueErrorformatgetr exceptions ApiException Exceptionlowerr2 deserializedumpsrrRr3rdict)r%rDrPjsrIobjs runmarshal_eventzWatch.unmarshal_event\s_ D!B 2 r!1|!)9266);LM''44BvJv4VVABH&*N N h<< f:    (\"C__S]C NCF##00F F0S S f:    +#//;;"&**R -=">"/!3 < 8 r(|Z0(*8 (=(=(N(N%& R\40"bl2)R\*-EE(*8 Z(@AR(S% Z   : -2l+T2"b&66)R -=j-II(*<(8(DEV(W%   ",-3VBZ99 q K sH HHc|Sr#r$r6s r __aiter__zWatch.__aiter__s rc~K |jd{S7#|jd{7xYwwr#)nextcloser6s r __anext__zWatch.__anext__s5 $ $$ **,   s(==:6:=c|jjd|_|jr$|j|jjd<yy)Nr3)r4rgr3rkeywordsr6s r _reconnectzWatch._reconnects@   595J5JDII  1 2 !rcKd|jjv}|} |j|jd{|_|jrt |jj j d{}|jd}|jdk(r |dk(rt|S|dk(r|r|jt |j||j}|}|S77r#tj$r|r|jYwxYw#tjj$r/}|j dk(r|rd}|jYd}~Ld}~wwxYww)Ntimeout_secondsutf8rriF)rrjr4r0StopAsyncIterationcontentreadlineasyncio TimeoutErrorrkdecoderrbrrYrZrK)r% watch_forever retry_410reventexs rrfz Watch.nexts\)1C1CC ! yy "&))+- zz(( !YY..7799;;v&D5(2:,, rz OO%(( ,,T43C3CD&IL].:'' !OO% :$$11 99# %IOO%  sv;E2C2E2'C6C4C6A E2D#.E24C66%D E2D  E2#E/#E*#E2)E**E//E2c>d|_|j||_d||j|<t j |r/t |j|jdd}||}n d|d<nd|d<d|vr |d|_ t|g|i||_ |S)aWatch an API resource and stream the result back via a generator. :param func: The API function pointer. Any parameter to the function can be passed after this parameter. :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 model representation of raw_object. The name of model will be determined based on the func's doc string. If it cannot be determined, 'object' value will be the same as 'raw_object'. Example: v1 = kubernetes.aio.client.CoreV1Api() watch = kubernetes.aio.watch.Watch() async for e in watch.stream(v1.list_namespace, timeout_seconds=10): type = e['type'] object = e['object'] # object is one of type return_type raw_object = e['raw_object'] # raw_object is a dict ... if should_stop: watch.stop() FT_without_preload_contentN_preload_contentr3) r0r>rrCr ismethodr;__self__r)r3rr)r%rr&r'raw_funcs rstreamz Watch.streams2 //559t++D12   D ! ==/!9:H #-2)*).F% &  '$*+=$>D !D24262  rcK|Swr#r$r6s r __aenter__zWatch.__aenter__s  sc@K|jd{y7wr#)rg)r%exc_type exc_value tracebacks r __aexit__zWatch.__aexit__sjjls cK|jjd{|j"|jjd|_yy73wr#)r2rgr4releaser6s rrgz Watch.closesI$$&&& 99 II   DI ! 'sAA4Ar#)r)r*r+r(r7r>rCrrbrdrhrkrfrrrrgr$rrr-r-<sN  >C>@K 8t-^rr-)rrr rTr functoolsrtypingrkubernetes.aiorrrBr:rrFr!r-r$rrrsO !%& V cFcr