[j~)ddlZddlZddlZddlmZdZdZdZejddkZ e r ddl Z e j Z nddl Z e jj Z GddZd Zd ZGd d eZdS) N)clientz:rtype:z:param bool follow:ListceZdZdZdS)SimpleNamespacec :|j|dSN)__dict__update)selfkwargss S/var/www/FlaskApp/flask-venv/lib/python3.11/site-packages/kubernetes/watch/watch.py__init__zSimpleNamespace.__init__+s V$$$$$N)__name__ __module__ __qualname__rrrrr)s#%%%%%rrctj|D]L}|tr0|t tdcSMdS)N)pydocgetdoc splitlines startswithPYDOC_RETURN_LABELlenstrip)funclines r_find_return_typer /sr T""--//:: ??- . . :.//0017799 9 9 9 : 2rc#FKt}|ddD]}t|tr||n^t|t r)||dn tdt|d| d}|dkrR|d| dd }||d zd}|r|Vnd V| d}|dkRdS) NF)amtdecode_contentzutf-8zReceived invalid segment type, z-, from stream. Accepts only 'str' or 'bytes'. replace)errorsr) bytearraystream isinstancebytesextendstrencode TypeErrortypefinddecode)respbuffersegment next_newliners riter_resp_linesr86sR [[F;;4;>>.. gu % % p MM' " " " "  % % p MM'..11 2 2 2 2n$w--nnnpp p{{5)) b  -<-(// 0++DLNOO,F  !;;u--Lb  %..rc4eZdZddZdZdZdZdZdZdS) WatchNc`||_d|_tj|_d|_dS)NF)_raw_return_type_stopr ApiClient _api_clientresource_version)r return_types rrzWatch.__init__Xs0 + !+-- $rcd|_t|drh|jrcddl} t |jdd}|rt |ddnd}|r||jdSdS#t$rYdSwxYwdSdS)NT_respr connectionsock)r=hasattrrCsocketgetattrshutdown SHUT_RDWR Exception)r rGconnrEs rstopz Watch.stop^s 4 ! ! dj  MMM  tz<>>6:DwtVT2224MM&"23333344        sAA// A=<A=c|jr|jSt|}|tr|dt t S|Sr )r<r endswithTYPE_LIST_SUFFIXr)r rrAs rget_return_typezWatch.get_return_typeps]   )( ('--    0 1 1 86%5!6!6 667 7rc@ttj|vrdSdS)Nfollowwatch)PYDOC_FOLLOW_PARAMrr)r rs rget_watch_argument_namezWatch.get_watch_argument_namexs! d!3!3 3 387rc|r|rdS tj|}|d|d<|s|S|ddkrZt|dtr>d|dvr4|dd}t|trd|vr |d|_n|ddkrt tj|d}|j |||d<t|ddr|dj j|_nNt|dtr3d|dvr)d|ddvr|ddd|_|S#tj $rYdSwxYw) Nobject raw_objectr1BOOKMARKmetadataresourceVersionERROR)data) isspacejsonloadsr+dictr@rdumpsr? deserializerFr[JSONDecodeError)r r^rAjsr[objs runmarshal_eventzWatch.unmarshal_event~s t||~~ 4 D!!B!(|B|   &zZ''blD11LjBxL6P6P!(|J7H!(D11L6G86S6S089J0K-Fw&&%4:b6F+G+GHHH#/;;CMM8 2h<44+,.xL,A,RD))!Ht44+r(|9S9S+r(|J/GGG,.xL,D)-+D)I#   44 s"E3D5E33FFc/Kd|_||}||}d||<d|d<d|vr |d|_d|v}d}|dd} ||i|} | |_ t | D]} |dkr|r|| |} ntj | } t| trg| dd kr[| d } |s|s| d tkrd}nV| d d | d} tj| d | d}| Vn | r| VndV|jrn| | d|_|j |j|d<nUd|_nM#| | d|_|j |j|d<nd|_wxYw|js|rdS)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_secondsrdrTr1r]rYcodereasonz: message)statusrmrN)r=rQrVr@poprCr8rhr`rar+rbHTTP_STATUS_GONErrest ApiExceptionclose release_conn)r rargsr rA watch_argdisable_retriesretry_after_410rdr4reventrgrms rr*z Watch.streamsD **400 0066  y%*!"  ' '$*+=$>D !-6jj55 / 4(((DDJ) &+D11  D!G++&5$($8$8{$K$KEE%)Jt$4$4E%eT22($)&MW$<$<"' "5C$3G?G$'K3C$C$C26 %%(MMM3y>>*C&,k&>&>+.v;v'?'G'G!G/4O"'KKKK%"&JJJJ"$HHHz !!###! (4151FF-..!%DJJ  !!###! (4151FF-..!%DJ%%%%z _ _/ srs * qQ,NNN|KKK+%%%%%%%% ...@fffffFfffffr