tj(ddlZddlZddlZddlmZdZdZdZejj Z GddZ dZ d Z Gd d ZdS) N)clientz:rtype:z:param follow:ListceZdZdZdS)SimpleNamespacec :|j|dSN)__dict__update)selfkwargss T/var/www/html/CA-Chatbot/venv/lib/python3.11/site-packages/kubernetes/watch/watch.py__init__zSimpleNamespace.__init__$s V$$$$$N)__name__ __module__ __qualname__rrr rr"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 r iter_resp_linesr7/sR [[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 r rzWatch.__init__Qs0 + !+-- $rcd|_t|drh|jrcddl} t |jdd}|rt |ddnd}|r||jdSdS#t$rYdSwxYwdSdS)NT_respr connectionsock)r<hasattrrBsocketgetattrshutdown SHUT_RDWR Exception)r rFconnrDs r stopz Watch.stopWs 4 ! ! dj  MMM  tz<>>6:DwtVT2224MM&"23333344        sAA// A=<A=c|jr|jSt|}|tr|dt t S|Sr)r;rendswithTYPE_LIST_SUFFIXr)r rr@s r get_return_typezWatch.get_return_typeis]   )( ('--    0 1 1 86%5!6!6 667 7rc@ttj|vrdSdS)Nfollowwatch)PYDOC_FOLLOW_PARAMrr)r rs r get_watch_argument_namezWatch.get_watch_argument_nameqs! 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_objectr0BOOKMARKmetadataresourceVersionERROR)data) isspacejsonloadsr*dictr?rdumpsr> deserializerErZJSONDecodeError)r r]r@jsrZobjs r unmarshal_eventzWatch.unmarshal_eventws 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_secondsrcrSr0r\rXcodereasonz: message)statusrlrN)r<rPrUr?poprBr7rgr_r`r*raHTTP_STATUS_GONErrest ApiExceptionclose release_conn)r rargsr r@ watch_argdisable_retriesretry_after_410rcr3reventrfrls r r)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 _ _/ sr~s %?'%%%%%%%% ...@ffffffffffr