bSSKrSSKrSSKJr SrSrSr"SS5rSrS r "S S \ 5r g) N)clientz:return:z:param bool follow:Listc\rSrSrSrSrg)SimpleNamespace!c :URRU5 gN)__dict__update)selfkwargss )lib/third_party/kubernetes/watch/watch.py__init__SimpleNamespace.__init__#sMM N)__name__ __module__ __qualname____firstlineno__r__static_attributes__rrrrr!s!rrc[R"U5R5H?nUR[5(dMU[ [5SR 5s $ g)N)pydocgetdoc splitlines startswithPYDOC_RETURN_LABELlenstrip)funclines r_find_return_typer#'sPll4 ++-d )** #()* + 1 1 33. rc#$# SnURSS9Hwn[U[5(aURS5nX-nUR S5nUR S5(d USnUSSnOSnUHnU(dM Uv M My g7f)NrF)decode_contentutf8 ) read_chunked isinstancebytesdecodesplitendswith)respprevseglinesr"s riter_resp_linesr3.s $   e  4c#u JJv c *C IIdOE <<   2YdCRje d  5s A=B Bc<\rSrSrS SjrSrSrSrSrSr S r g) Watch?Nc`XlSUl[R"5UlSUlg)NF)_raw_return_type_stopr ApiClient _api_clientresource_version)r return_types rrWatch.__init__As('DJ'')D DrcSUlg)NT)r9)r s rstop Watch.stopGs DJrcUR(a UR$[U5nUR[5(aUS[ [5*$U$r )r8r#r.TYPE_LIST_SUFFIXr)r r!r=s rget_return_typeWatch.get_return_typeJsP   " ""#D)K,-- 03/00 11 rcB[[R"U5;agg)Nfollowwatch)PYDOC_FOLLOW_PARAMrr)r r!s rget_watch_argument_nameWatch.get_watch_argument_nameRsU\\$//  rc[R"U5nUSUS'U(a[[R"US5S9nUR R XB5US'[USS5(a USRRUl U$[US[5(a%SUS;aSUSS;aUSSSUl U$![a Us$f=f)Nobject raw_object)datametadataresourceVersion) jsonloads ValueErrorrdumpsr; deserializehasattrrPr<r*dict)r rOr=jsobjs runmarshal_eventWatch.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 C'&C'c/j# SUlURU5nSX0RU5'SUS'SU;a USUlSU;nU"U0UD6n[ U5H)nUR Xt5v UR(dM) O UR 5 UR5 URbURUS'OSUlU(dUR(agM!UR 5 UR5 URbURUS'fSUlf=f7f)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_contentr<timeout_secondsN)r9rDrJr<r3r[close release_conn)r r!argsr r=timeoutsr/r"s rstream Watch.streamjs'4DJ&&t,K15F ' ' -.!&F V#$%78d!V+H  4 "6 "d #D)D$$T7 7 ZZZ *    ,'+'<'<&# $$* TZZ !     ,'+'<'<&# $$*s&AD30C*C* A D3*AD00D3)r;r8r9r<r ) rrrrrr@rDrJr[rdrrrrr5r5?s !  $2rr5) rRr kubernetesrrrIrCrr#r3rMr5rrrrgsF" *!!  "]F]r