?g."ddlZddlZddlZddlmZdZdZdZejddk(Z e rddl Z e jZ nddl Z e jjZ GddZd Zd ZGd d eZy) N)clientz:return:z:param bool follow:ListceZdZdZy)SimpleNamespacec :|jj|yN)__dict__update)selfkwargss K/var/www/openai/venv/lib/python3.12/site-packages/kubernetes/watch/watch.py__init__zSimpleNamespace.__init__+s V$N)__name__ __module__ __qualname__rrrrr)s%rrctj|jD]9}|jts|t tdj cSy)N)pydocgetdoc splitlines startswithPYDOC_RETURN_LABELlenstrip)funclines r_find_return_typer /sM T"--/ ??- ../01779 90 rc#Kt}|jddD]}t|tr|j |nIt|t r!|j |j dntdt|d|jd}|dk7s|d|jdd }||d zd}|r||jd}|dk7r;yw) NF)amtdecode_contentzutf-8zReceived invalid segment type, z-, from stream. Accepts only 'str' or 'bytes'. replace)errors) bytearraystream isinstancebytesextendstrencode TypeErrortypefinddecode)respbuffersegment next_newliners riter_resp_linesr86s [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)r return_types rrzWatch.__init__Vs* + !++- $rcd|_y)NT)r=)r s rstopz Watch.stop\s  rc|jr |jSt|}|jtr|dt t S|Sr )r<r endswithTYPE_LIST_SUFFIXr)r rrAs rget_return_typezWatch.get_return_type_sM  (( ('-    0 16%5!6 67 7rc<ttj|vryy)Nfollowwatch)PYDOC_FOLLOW_PARAMrr)r rs rget_watch_argument_namezWatch.get_watch_argument_namegs d!3 3rctj|}|d|d<|r|ddk7r|ddk7rttj|d}|jj |||d<t |ddr |djj|_|St|dtr!d|dvrd|ddvr|ddd|_|S) Nobject raw_objectr1ERRORBOOKMARK)datametadataresourceVersion) jsonloadsrdumpsr? deserializehasattrrSr@r+dict)r rRrAjsobjs runmarshal_eventzWatch.unmarshal_eventms ZZ h<< 2f:0RZ:5M!tzz"\2B'CDC++77[IBxLr(|Z0(*8 (=(=(N(N% R\40Z2h<5O'2h< +CC(*8 Z(@%)'% rc/(Kd|_|j|}|j|}d||<d|d<d|vr |d|_d|v}d} ||i|} t |D]} |dk(r{|j | |} t | trR| ddk(rJ| d } |s|s| d tk(rd}nL| d d | d } tjj| d | d}| n| |jsn|j|j|j|j|d<nd|_ |js|ry#|j|j|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_secondsrJr1rPrOcodereasonz: message)statusrbN)r=rGrLr@r8r]r+rZHTTP_STATUS_GONErrest ApiExceptionclose release_conn) r rargsr rA watch_argdisable_retriesretry_after_410r4reventr\rbs rr*z Watch.streamsD **40 006  y%*!"  '$*+=$>D !-6((D! &+D1D!G+ $ 4 4T; G%eT2$)&MW$<"' "5C$3?$'K3C$C26 %%(M3y>*C&,kk&>&>+.v;v'?'G!G/4O"'K" zz326 !!#((4151F1FF-.!%DJzz_M< !!#((4151F1FF-.!%DJs'AFBE 3E 6AF AFFr ) rrrrrCrGrLr]r*rrrr:r:Ts!%  (Trr:)rUrsys kubernetesrrrKrF version_infoPY2httplibGONErehttp HTTPStatusrr r8rNr:rrrrws * qQ||++%% .