[j5dZddlZddlZddlZddlmZddlmZddlm Z m Z ej e Z dZdZd Zd Zd ZGd d ZdS)zInformer implementation for the Kubernetes Python client. Provides SharedInformer: a background watcher that keeps a local ObjectCache in sync with the Kubernetes API server and notifies registered event-handler callbacks. N) ApiException)Watch) ObjectCache_meta_namespace_keyADDEDMODIFIEDDELETEDBOOKMARKERRORcjeZdZdZ ddZedZdZdZdZ d Z d Z d Z d Z d ZdS)SharedInformera;Watch a Kubernetes resource and maintain a local cache. The informer starts a daemon thread that continuously watches the given resource via ``list_func``. On each event the local :class:`ObjectCache` is updated and registered event-handler callbacks are invoked. Parameters ---------- list_func: Bound API method used for the initial list **and** as the watch source. It must accept a watch keyword argument (e.g. CoreV1Api().list_namespaced_pod). namespace: Kubernetes namespace to watch. Pass None for cluster-scoped or all-namespace list functions. resync_period: How often (seconds) to perform a full re-list from the API server. Defaults to 0 which disables periodic resyncs. label_selector: Optional label selector string forwarded to the API server. field_selector: Optional field selector string forwarded to the API server. key_func: Optional callable (obj) -> str used to key objects in the cache. Defaults to namespace/name. Nrc T||_||_||_||_||_t ||_tgtgtgtgtgi|_ tj|_d|_d|_tj|_d|_dS)N)key_func) _list_func _namespace_resync_period_label_selector_field_selectorr_cacherr r r r _handlers threadingLock _handler_lock_watch_threadEvent _stop_event_resource_version)self list_func namespace resync_periodlabel_selectorfield_selectorrs Y/var/www/FlaskApp/flask-venv/lib/python3.11/site-packages/kubernetes/informer/informer.py__init__zSharedInformer.__init__Gs$#+--!8444 Xr7B"eUWX&^--  $?,,!%c|jS)z5The :class:`ObjectCache` maintained by this informer.)rr s r&cachezSharedInformer.cachecs {r(c (||jvrHtd|dt |j|j5|j||ddddS#1swxYwYdS)a_Register a callback for a specific event type. Parameters ---------- event_type: One of :data:`ADDED`, :data:`MODIFIED`, :data:`DELETED`, :data:`BOOKMARK` or :data:`ERROR`. handler: Callable invoked with the event object (or the raw exception for ERROR events). z'Unknown event_type {!r}. Use one of: {}z, N)r ValueErrorformatjoinsortedrappendr event_typehandlers r&add_event_handlerz SharedInformer.add_event_handlerhs T^ + +9@@ &*@*@ A A    7 7 N: & - -g 6 6 6 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7s!BB B c|j5 |j||n#ttf$rYnwxYwddddS#1swxYwYdS)zeDeregister a previously registered *handler*. No-op if *handler* is not registered. N)rrremoveKeyErrorr-r2s r&remove_event_handlerz#SharedInformer.remove_event_handler}s     z*11'::::j)                      s,A +A?A?AAAc|j|jrdS|jt j|jdd|_|jdS)zStart the background watch loop in a daemon thread. Calling :meth:`start` more than once without an intervening :meth:`stop` is a no-op. NrT)targetnamedaemon)ris_aliverclearrThread _run_loopstartr*s r&rBzSharedInformer.startsy < # (=(=(?(? # F     '>!    r(c|j|j|j|j|jd|_dS)z:Ask the background watch loop to stop and join the thread.N)rsetrstoprr/r*s r&rEzSharedInformer.stopsZ  ; " K      < # L      r(cpi}|j |j|d<|j |j|d<|j |j|d<|S)Nr"r$r%)rrr)r kws r& _build_kwargszSharedInformer._build_kwargssM  ? &"oB{O   +#'#7B   +#'#7B  r(c |j5t|j|g}dddn #1swxYwY|D]9} ||#t$rt d|Y6wxYwdS)aExecute all registered callbacks for *event_type*, passing *obj*. Callbacks are invoked sequentially on the informer's background thread. Any exception raised by an individual handler is logged and swallowed so that remaining handlers still run. Nz$Exception in informer handler for %s)rlistrget Exceptionlogger exception)r r3objhandlersfns r&_firezSharedInformer._fires  @ @DN..z2>>??H @ @ @ @ @ @ @ @ @ @ @ @ @ @ @  B 3     :J   s!)=AA A%BBc|}|jdi|}t|dgpg}i}|D]!}|j|}|||<"t |j}|D]=}||vr7|j|}||t|>|j || D]@\}}||vr|t|%|t|Ad} t|dd} | t| dd} | pd|_dS)aList all objects and populate the cache, firing ADDED/MODIFIED/DELETED events. On the first call (empty cache) every returned item fires ADDED. On subsequent calls (resync or after a 410 Gone) the new list is diffed against the existing cache: * Items absent from the new list fire DELETED. * Items present in both fire MODIFIED. * Items only in the new list fire ADDED. itemsNmetadataresource_version0)rHrgetattrr _key_funcrD list_keys get_by_keyrRr _replace_allrTr rr) r rGresprT new_items_mapitemkeyold_keysold_objrvmetas r& _initial_listzSharedInformer._initial_lists   ! !t$$$$gr**0b  & &D+''--C!%M#  t{,,..// 1 1C-''+0055&JJw000   '''',,.. ( (ICh 8T**** 5$'''' tZ..  1488B!#sr(c |js|j} |ng#t$rZ}t d|t||j dYd}~d}~wwxYwtj }t|_ |}|j|d<|jdkr%t!dt#|j|d< |j j|jfi|D]}|jrnv|d }|d }|j |j jr|j j|_|t,kr6|j||t,||t2kr6|j||t2||t4kr7|j||t4|1|t8kr1|t8|d |m|tkr|t|n#t:$rr}|jd kr"t d d|_n t d|j|t|Yd}~nOd}~wt$r?}t d|t|Yd}~nd}~wwxYw|j$|j |j jr|j j|_d|_ n7#|j$|j |j jr|j j|_d|_ wxYw|js|j|jdkrtj |z |jkr|t d |nL#t$r?}t d|t|Yd}~nd}~wwxYw|jdSdS)aBackground loop: list then watch, reconnect on errors. A full re-list is only performed when ``self._resource_version`` is ``None`` (first start or after a 410 Gone response). On all other reconnects the most recent ``resourceVersion`` is reused so that no events are missed and the API server does not need to send a full object snapshot. Nz#Error during initial list; retrying)timeoutrVrrtimeout_secondstypeobject raw_objectiz3Watch expired (410 Gone); will re-list from scratchz>Watch stream ended with ApiException (status=%s); reconnectingz,Unexpected error in watch loop; reconnectingzInformer resync triggeredz$Error during resync list; continuing)!ris_setrrfrLrMrNrRr waittime monotonicrrrHrmaxintstreamrrKrVrr_putr r _remover rstatuswarningdebug)r exc last_resyncrGeventevt_typerOs r&rAzSharedInformer._run_loops"))++_ +%-&&(((( $$%JKKKJJuc***$))!)444HHHH .**K''DK##%%B%)%;B! " "Q&&(+As43F/G/G(H(H$%7 #/T[/FF2FF//E'..00$yy00H))H--C {.4;3O.151M.5(( ((--- 5#....!X-- ((--- 8S1111!W,, ++C000 7C0000!X-- 8UYY|S-I-IJJJJ!U** 5#... ' ' ':$$NNM.2D**NNX  5#&&&&&&&& ' ' '  !OPPP 5#&&&&&&&& '*6 / 40.2[-ID*" *6 / 40.2[-ID*" """"$++-- +*6'!++^%% 38KKK 8999+&&(((( +++$$%KLLLJJuc********+{"))++_ +_ +_ +_ +_ +sr8 BABBF-KN; N A(L94N;9 N5N;N;NN;;4O/Q,, R565R00R5)NrNNN)__name__ __module__ __qualname____doc__r'propertyr+r5r9rBrErHrRrfrArXr(r&rr*s>&&&&8X777*    ",+,+,+\h+h+h+h+h+r(r)rloggingrrpkubernetes.client.exceptionsrkubernetes.watchrr+rr getLoggerr~rMrr r r r rrXr(r&rs 555555""""""33333333  8 $ $    l+l+l+l+l+l+l+l+l+l+r(