bddlZddlZddlmZdZdZdZGddZdZd Z Gd d e Z y) N)clientz:return:z:param bool follow:ListceZdZdZy)SimpleNamespacec :|jj|yN)__dict__update)selfkwargss )lib/third_party/kubernetes/watch/watch.py__init__zSimpleNamespace.__init__#sMM N)__name__ __module__ __qualname__rrr rr!s!rrctj|jD]9}|jts|t tdj cSy)N)pydocgetdoc splitlines startswithPYDOC_RETURN_LABELlenstrip)funclines r _find_return_typer'sMll4 ++-d )* #()* + 1 1 33. rc#Kd}|jdD]e}t|tr|jd}||z}|j d}|j ds |d}|dd}nd}|D] }|s| gyw)NrF)decode_contentutf8 ) read_chunked isinstancebytesdecodesplitendswith)respprevseglinesrs r iter_resp_linesr/.s $   e  4c#u JJv c *C IIdOE <<  2YdCRje d  5s A4B7 Bc2eZdZddZdZdZdZdZdZy) WatchNc`||_d|_tj|_d|_y)NF)_raw_return_type_stopr ApiClient _api_clientresource_version)r return_types r rzWatch.__init__As*'DDJ'')D Drcd|_y)NT)r4)r s r stopz Watch.stopGs DJrc|jr |jSt|}|jtr|dt t S|Sr)r3rr*TYPE_LIST_SUFFIXr)r rr8s r get_return_typezWatch.get_return_typeJsM   " ""#D)K,- 03/00 11 rc<ttj|vryy)Nfollowwatch)PYDOC_FOLLOW_PARAMrr)r rs r get_watch_argument_namezWatch.get_watch_argument_nameRsU\\$//  rc tj|}|d|d<|rttj|d}|j j |||d<t|ddr |djj|_ |St|dtr!d|dvrd|ddvr|ddd|_ |S#t$r|cYSwxYw)Nobject raw_object)datametadataresourceVersion) jsonloads ValueErrorrdumpsr6 deserializehasattrrGr7r&dict)r rFr8jsobjs r unmarshal_eventzWatch.unmarshal_eventXs ::d b(|B| B|,c%%11#{Cbl Hz * "8 5 5 F F I r(|T *zR\/I Hj!9 9 "8 Z 89J K I  ksC CCc/@Kd|_|j|}d||j|<d|d<d|vr |d|_d|v} ||i|} t |D]$}|j |||js$n|j |j|j|j|d<nd|_ |s |jry#|j |j|j|j|d<wd|_wxYww)aWatch an API resource and stream the result back via a generator. :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_contentr7timeout_secondsN)r4r=rBr7r/rRclose release_conn)r rargsr r8timeoutsr+rs r streamz Watch.streamjs*4DJ&&t,K15F4 ' ' -.!&F V#$%78d!V+H  4 "6 "d #D)D$$T;7 7 ZZ *    ,'+'<'<&# $$* TZZ !     ,'+'<'<&# $$*s&A D.C?CADADDr) rrrrr:r=rBrRrZrrr r1r1?s !  $2rr1) rIr kubernetesrrrAr<rrr/rDr1rrr r\sF" *!!  "]F]r