=Ki$SSKrSSKrSSKrSSKJr 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 X/var/www/html/dynamic-report/venv/lib/python3.13/site-packages/kubernetes/watch/watch.py__init__SimpleNamespace.__init__+s V$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$/sP T"--/ ??- . ../01779 90 rc## [5nURSSS9Hn[U[5(aUR U5 ON[U[ 5(a!UR UR S55 O[S[U5S35eURS5nUS:wdMUSURSSS 9nXS -SnU(aUv OS v URS5nUS:waMCM g7f) NF)amtdecode_contentzutf-8zReceived invalid segment type, z-, from stream. Accepts only 'str' or 'bytes'. replace)errorsr) bytearraystream isinstancebytesextendstrencode TypeErrortypefinddecode)respbuffersegment next_newliner#s riter_resp_linesr<6s [F;;4;> gu % % MM' "  % % MM'..1 21$w-@mnp p{{5) b -<(// 0+DNO,F !;;u-Lb %?sB(C6.AC61C6c<\rSrSrS SjrSrSrSrSrSr S r g) WatchVNc`XlSUl[R"5UlSUlg)NF)_raw_return_type_stopr ApiClient _api_clientresource_version)r return_types rrWatch.__init__Xs( + !++- $rcSUlg)NT)rB)r s rstop Watch.stop^s  rcUR(a UR$[U5nUR[5(aUS[ [5*$U$r )rAr$endswithTYPE_LIST_SUFFIXr )r r"rFs rget_return_typeWatch.get_return_typeasP  (( ('-    0 1 16%5!6 67 7rcB[[R"U5;agg)Nfollowwatch)PYDOC_FOLLOW_PARAMrr)r r"s rget_watch_argument_nameWatch.get_watch_argument_nameis d!3 3rcBU(aUR5(ag[R"U5nUSUS'U(aUSS:waUSS:wa[[R"US5S9nUR R XB5US'[USS5(a USRRUl U$[US[5(a%SUS;aSUSS;aUSSSUl U$![Ra gf=f) Nobject raw_objectr5ERRORBOOKMARK)datametadataresourceVersion) isspacejsonloadsrdumpsrD deserializehasattrr\rEr/dictJSONDecodeError)r r[rFjsobjs runmarshal_eventWatch.unmarshal_eventost||~~ D!B!(|B|  r&zW4Fz9Q%4::b6F+GH#//;;CM8 2h<44,.xL,A,A,R,RD)I !Ht44r(|9S+r(|J/GG,.xL,D)-+D)I##  sB(D>DDDc/# SUlURU5nURU5nSX5'SUS'SU;a USUlSU;nSnUR SS5nU"U0UD6n [ U 5Hn US:XaU(aUR X5n O[R"U 5n [U [5(a]U SS :XaTU S n U(dU(dU S [:XaSn O^U S <S U S<3n [RRU S U S9eSnU v OU (aU v OSv UR(dM O U R5 U R!5 URbURUS'OSUlUR(dU(agGMM!U R5 U R!5 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_contentrEtimeout_secondsrbrRr5rYrXcodereasonz: message)statusrnrN)rBrNrTrEpopr<rhr_r`r/rdHTTP_STATUS_GONErrest ApiExceptionclose release_conn)r r"argsrrF watch_argdisable_retriesretry_after_410rbr8r#eventrgrns rr. Watch.streamsD **40 006  %*!"  '$*+=$>D !-6jj5 ((D( &+D1D!G+&$($8$8$KE%)JJt$4E%eT22$)&MW$<"' "5C$3?$'K3C$C26 %%(M3y>*C&,kk&>&>+.v;v'?'G!G/4O"'K"&J"$HzzzA2D !!#((4151F1FF-.!%DJzz_[J !!#((4151F1FF-.!%DJs'A%G5(CF,F, A!G5,AG22G5)rDrArBrEr ) rrrrrrIrNrTrhr.rrrrr>r>Vs!%  2\rr>)r_rsys kubernetesrrrSrM version_infoPY2httplibGONErrhttp HTTPStatusrr$r<rWr>rrrrs * qQ||++%% .@NFNr