eQj5dZddlZddlZddlZddlmZddlmZddlm Z m Z eje Z dZdZd Zd Zd ZGd d Zy)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_keyADDEDMODIFIEDDELETEDBOOKMARKERRORcbeZdZdZ d dZedZdZdZdZ dZ d Z d Z d Z d Zy)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. Nc D||_||_||_||_||_t ||_tgtgtgtgtgi|_ tj|_d|_d|_tj$|_d|_y)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 a/home/oem/CyberBrain26-unified/.venv/lib/python3.12/site-packages/kubernetes/informer/informer.py__init__zSharedInformer.__init__Gs$#+--!84 Xr7B"eUWX&^^-  $??,!%c|jS)z5The :class:`ObjectCache` maintained by this informer.)rr s r&cachezSharedInformer.cachecs{{r(c ||jvr=tdj|djt |j|j 5|j|j |dddy#1swYyxYw)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_handlerhsy T^^ +9@@ &*@ A     7 NN: & - -g 6 7 7 7s BB c|j5 |j|j|dddy#ttf$rYwxYw#1swYyxYw)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 6AA AA  Ac|j|jjry|jjt j |j dd|_|jjy)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.startsc << # (=(=(?    ''>>!  r(c|jj|j|jj|j|jj d|_y)z:Ask the background watch loop to stop and join the thread.N)rsetrstoprr/r*s r&rEzSharedInformer.stopsO  ;; " KK    << # LL    r(ci}|j|j|d<|j|j|d<|j|j|d<|S)Nr"r$r%)rrr)r kws r& _build_kwargszSharedInformer._build_kwargss]  ?? &"ooB{O    +#'#7#7B    +#'#7#7B  r(c|j5t|jj|g}dddD] } || y#1swYxYw#t$rt j d|Y?H @ B 3  @ @    :J s&A A AA:9A:c|j}|jdi|}t|dgxsg}i}|D]"}|jj |}|||<$t |jj }|D];}||vs|jj|}|&|jt|=|jj||jD]6\}}||vr|jt|!|jt|8d} t|dd} | t| dd} | xsd|_y)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_listsQ   !t$$gr*0b  &D++''-C!%M#  & t{{,,./ 1C-'++005&JJw0  1   '',,. (ICh 8T* 5$'  ( tZ.  148B!#sr(c |jjs+|j |jtj}t|_ |j}|j|d<|jdkDr"t!dt#|j|d< |jj$|j&fi|D]}|jjrnf|j)d }|j)d }|j1|jj*r|jj*|_|t,k(r2|j.j1||jt,||t2k(r2|j.j1||jt2||t4k(r3|j.j7||jt4|2|t8k(r(|jt8|j)d |c|tk(sn|jt||j=|j1|jj*r|jj*|_d|_ |jjse|jY|jdkDrJtj|z |jk\r&t jAd |j|jjs*yy#t$rR}t j d|jt||jjdYd}~d}~wwxYw#t:$rm}|j<d k(rt j?d d|_n t j?d|j<|jt|Yd}~d}~wt$r6}t j d|jt|Yd}~d}~wwxYw#|j=|j1|jj*r|jj*|_d|_ wxYw#t$r6}t j d|jt|Yd}~d}~wwxYw)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""))+%%-&&(..*K'DK##%B%)%;%;B! " ""Q&(+As43F3F/G(H$%7 #/T[[//F2F/E''..0$yy0H))H-C {{.4;;3O3O151M1M.5( ((- 5#.!X- ((- 8S1!W, ++C0 7C0!X- 8UYY|S-IJ!U* 5#.5/b**6 / 44-1[[-I-ID*" $$++-**6''!+^^% 38K8KK 89+&&(y""))++ !$$%JKJJuc*$$))!)4 \ '::$NNM.2D*NNX  5#&& '  !OP 5#&& '**6 / 44-1[[-I-ID*" !+$$%KLJJuc**+suM-FN&N&R1 N#ANN#& Q/A"PQ Q#+QQQQAR.1 S0:+S++S0)NrNNN)__name__ __module__ __qualname____doc__r'propertyr+r5r9rBrErHrRrfrArXr(r&rr*s[>&87*  ",+\h+r(r)rloggingrrpkubernetes.client.exceptionsrkubernetes.watchrr+rr getLoggerr~rMrr r r r rrXr(r&rsW 5"3   8 $    l+l+r(