o 'Th#@sddlZddlZddlZddlmZdZdZdZejddkZ e r)ddl Z e j Z nddl Z e jj Z GdddZd d Zd d ZGd ddeZdS)N)clientz:return:z:param bool follow:Listc@seZdZddZdS)SimpleNamespacecKs|j|dSN)__dict__update)selfkwargsr W/home/air/segue/gemini/back/venv/lib/python3.10/site-packages/kubernetes/watch/watch.py__init__+szSimpleNamespace.__init__N)__name__ __module__ __qualname__r r r r r r)s rcCs:t|D]}|tr|ttdSqdS)N)pydocgetdoc splitlines startswithPYDOC_RETURN_LABELlenstrip)funcliner r r _find_return_type/s  rccst}|jdddD]S}t|tr||nt|tr&||dn tdt|d| d}|dkr^|d|j ddd }||d d}|rR|Vnd V| d}|dks9q dS) NF)amtdecode_contentzutf-8zReceived invalid segment type, z-, from stream. Accepts only 'str' or 'bytes'. replace)errorsr) bytearraystream isinstancebytesextendstrencode TypeErrortypefinddecode)respbuffersegment next_newlinerr r r iter_resp_lines6s.      r2c@s>eZdZdddZddZddZdd Zd d Zd d ZdS)WatchNcCs ||_d|_t|_d|_dS)NF)_raw_return_type_stopr ApiClient _api_clientresource_version)r return_typer r r r Xs  zWatch.__init__cCs d|_dS)NT)r5)r r r r stop^s z Watch.stopcCs4|jr|jSt|}|tr|dtt S|Sr)r4rendswithTYPE_LIST_SUFFIXr)r rr9r r r get_return_typeas  zWatch.get_return_typecCstt|vr dSdS)Nfollowwatch)PYDOC_FOLLOW_PARAMrr)r rr r r get_watch_argument_nameiszWatch.get_watch_argument_namecCs|r|rdSz^t|}|d|d<|rd|ddkrd|ddkrdtt|dd}|j|||d<t|ddrF|djj |_ |WSt |dt rdd|dvrdd|ddvrd|ddd|_ |WStj yqYdSw) Nobject raw_objectr+ERRORBOOKMARK)datametadataresourceVersion) isspacejsonloadsrdumpsr7 deserializehasattrrGr8r%dictJSONDecodeError)r rFr9jsobjr r r unmarshal_eventos(    zWatch.unmarshal_eventc osvd|_||}||}d||<d|d<d|vr|d|_d|v}d} ||i|}znt|D]Q} |dkru|| |} t| tro| ddkro| d } |s[|s[| d tkr[d}n)d | d | d f} t j j | d | dd}| Vn | r{| VndV|jrnq2W| | |jdur|j|d<nd|_n| | |jdur|j|d<wd|_w|js|rdSq&)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_contentr8timeout_secondsr?r+rDrCcodez%s: %sreasonmessage)statusrWrN)r5r=rAr8r2rSr%rOHTTP_STATUS_GONErrest ApiExceptionclose release_conn) r rargsr r9 watch_argdisable_retriesretry_after_410r.reventrRrWr r r r$sf"               z Watch.streamr) rrrr r:r=rArSr$r r r r r3Vs  r3)rJrsys kubernetesrrr@r< version_infoPY2httplibGONErZhttp HTTPStatusrrr2rBr3r r r r s"