IiSSKrSSKrSSKrSSKJr SrSrSr\RSS:Hr \ (aSSK r \ Rr OSSK r \ RRr "SS5rS rS r"S S \5rg) N)clientz:return:z:param bool follow:Listc\rSrSrSrSrg)SimpleNamespace)c :URRU5 gN)__dict__update)selfkwargss B Bc<\rSrSrS SjrSrSrSrSrSr S r g) WatchGNc`XlSUl[R"5UlSUlg)NF)_raw_return_type_stopr ApiClient _api_clientresource_version)r return_types rrWatch.__init__Is( + !++- $rcSUlg)NT)r;)r s rstop Watch.stopOs  rcUR(a UR$[U5nUR[5(aUS[ [5*$U$r )r:r$r0TYPE_LIST_SUFFIXr )r r"r?s rget_return_typeWatch.get_return_typeRsP  (( ('-    0 1 16%5!6 67 7rcB[[R"U5;agg)Nfollowwatch)PYDOC_FOLLOW_PARAMrr)r r"s rget_watch_argument_nameWatch.get_watch_argument_nameZs d!3 3rc[R"U5nUSUS'U(aUSS:waUSS:wa[[R"US5S9nURR XB5US'[ USS5(a USRRUlU$[US[5(a%SUS;aSUSS;aUSSSUlU$) Nobject raw_objecttypeERRORBOOKMARK)datametadataresourceVersion) jsonloadsrdumpsr= deserializehasattrrUr>r,dict)r rTr?jsobjs runmarshal_eventWatch.unmarshal_event`s ZZ h<< 2f:0RZ:5M!tzz"\2B'CDC++77IBxLr(|Z00(*8 (=(=(N(N% R\400Z2h<5O'2h< +CC(*8 Z(@%)'% rc/v# SUlURU5nURU5nSX5'SUS'SU;a USUlSU;nSnU"U0UD6n[ U5Hn US:XaUR X5n [ U [5(a]U SS:XaTU S n U(dU(dU S [:XaSn ORU S <S U S <3n [RRU S U S9eSnU v OU v UR(dM O UR5 UR5 URbURUS'OSUlUR(dU(agGM#!UR5 UR5 URbURUS'fSUlf=f7f)aWatch 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_secondsrJrQrRrPcodereasonz: message)statusreN)r;rFrLr>r5r_r,r\HTTP_STATUS_GONErrest ApiExceptionclose release_conn) r r"argsrr? watch_argdisable_retriesretry_after_410r1r#eventr^res rr+ Watch.streamtsD **40 006  %*!"  '$*+=$>D !-6((D! &+D1D!G+ $ 4 4T G%eT22$)&MW$<"' "5C$3?$'K3C$C26 %%(M3y>*C&,kk&>&>+.v;v'?'G!G/4O"'K" zzz326 !!#((4151F1FF-.!%DJzz_M< !!#((4151F1FF-.!%DJs'AF9B1E0 E0A!F90AF66F9)r=r:r;r>r ) rrrrrrBrFrLr_r+rrrrr7r7Gs!%  (Trr7)rWrsys kubernetesrrrKrE version_infoPY2httplibGONErhhttp HTTPStatusrr$r5rOr7rrrr{s * qQ||++%% "AFAr