eQj,ddlZddlZddlZddlZddlmZddlmZdZdZ dZ ejjZ dZdZGd d Zy) N)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/watch/watch.py_find_return_typer$s##D);;K7,,222 s " OOK (;$ FMM; /d#)r557: ??- ../01779 9: c#Kt}|jddD]}t|tr|j |nIt|t r!|j |j dntdt|d|jd}|dk7s|d|jdd }||d zd}|r|nd |jd}|dk7r@yw) NF)amtdecode_contentzutf-8zReceived invalid segment type, z-, from stream. Accepts only 'str' or 'bytes'. replace)errorsr) bytearraystreamrbytesextendrencode TypeErrortypefinddecode)respbuffersegment next_newliners riter_resp_linesr47s [F;;4;>. gu % MM' "  % MM'..1 21$w-@mnp p{{5) b -<(// 0+DLNO,F !;;u-Lb %.sB"C(%?C(%C(c2eZdZddZdZdZdZdZdZy) WatchNc`||_d|_tj|_d|_y)NF)_raw_return_type_stopr ApiClient _api_clientresource_version)selfrs r__init__zWatch.__init__Ys* + !++- $rcd|_t|drY|jrLddl} t |jdd}|r t |ddnd}|r|j |j yyyy#t$rYywxYw)NT_respr connectionsock)r9rr@socketgetattrshutdown SHUT_RDWR Exception)r=rCconnrBs rstopz Watch.stop_s} 4 !djj   tzz<>6:wtVT2MM&"2"23'1 !  sAA.. A:9A:c0|jr |jSt|}t|tr|n |j}|j t r?|dtt  }t|tr|Sttj|S|SN) r8rrr__name__endswithTYPE_LIST_SUFFIXrrDrr)r=rrreturn_type_nameitem_type_names rget_return_typezWatch.get_return_typeqs  (( ('- %k37K[=Q=Q   $ $%5 6-.E4D0E/EFN+s+%%6==.9 9rcdtj|jvstt j |xsdvryy)Nfollowrwatch)rr parametersPYDOC_FOLLOW_PARAMrr)r=rs rget_watch_argument_namezWatch.get_watch_argument_names7 ))$/:: :!ell4&8&>B?rcx|r|jry tj|}|d|d<|s|S|ddk(rBt|dtr-d|dvr&|dd}t|trd|vr |d|_|S|ddk7r|j jtj|d|d|d<t|ddr |djj |_|St|dtr!d|dvrd|ddvr|ddd|_|S#tj$rYywxYw) Nobject raw_objectr-BOOKMARKmetadataresourceVersionERRORzapplication/json) isspacejsonloadsrdictr<r; deserializedumpsrr\JSONDecodeError)r=datarjsr\s runmarshal_eventzWatch.unmarshal_eventset||~ D!B!(|B|  &zZ'blD1jBxL6P!(|J7H!(D16G86S089J0K-IFw&#//;;JJr,/0& 8 2h<4,.xL,A,A,R,RD)I !Ht4r(|9S+r(|J/GG,.xL,D)-+D)I##  s$ D#A D#A,D#-5D##D98D9c/BKd|_|j|}|j|}d||<d|d<d|vr |d|_d|v}d}|j dd} ||i|} | |_ t | dd} t| tr)d | cxkrd ksn|jj| it| D]} |d k(r|r|j| |} ntj| } t| trR| d d k(rJ| d} |s|s| dt k(rd}nS| dd| d}t"j$j'| d|d}| n | r| nd|jsn| j)| j+d|_|j|j|d<nd|_ |js|rys#| j)| j+d|_|j|j|d<wd|_wxYww)ajWatch an API resource and stream the result back via a generator. Note that watching an API resource can expire. The method tries to resume automatically once from the last result, but if that last result is too old as well, an `ApiException` exception will be thrown with ``code`` 410. In that case you have to recover yourself, probably by listing the API resource to obtain the latest state and then watching from that state on by setting ``resource_version`` to one returned from listing. :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.client.CoreV1Api() watch = kubernetes.watch.Watch() for e in watch.stream(v1.list_namespace, resource_version=1127): 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_preload_contentr<timeout_secondsrcstatusNi+rTr-r^rZcodereasonz: message)rlror)r9rQrWr<popr@rDrintr;response_deserializer4rhr`rarbHTTP_STATUS_GONErrest ApiExceptionclose release_conn)r=rargskwargsr watch_argdisable_retriesretry_after_410rcr0rlreventobjros rr(z Watch.streamsND **40 006  y%*!"  '$*+=$>D !-6jj5 ((DDJ, & x6fc*3&3GC3G$$99$C+D1 D!G+&$($8$8{$KE%)JJt$4E%eT2$)&MW$<"' "5C$3?$'K3C$C26 %%(M3y>*C&,kk&>&>+.v;v'?'G!G/4O"'K"&J"$HzzA D !!#! ((4151F1FF-.!%DJzz_eR !!#! ((4151F1FF-.!%DJs'A*H-DG1G4AHA HHrK) rL __module__ __qualname__r>rIrQrWrhr(rrr6r6Ws"% $ !Farr6)httprr`rtypingr kubernetesrrrVrN HTTPStatusGONErtrr4r6rrrrsT  %??''&.@uur