=hyXUdZddlmZddlZddlmZmZddlmZm Z m Z m Z m Z ddl mZddlmZmZddlmZdd lmZmZerdd lmZdd lmZdd lmZed dZegggggZGddZGddeZGddeZ GddeZ!GddeZ"GddeZ#dddZ$ dedZ%dfdZ&hdZ'de(d <dgd!Z)Gd"d#Z*Gd$d%e*Z+Gd&d'e*Z,Gd(d)e*Z-Gd*d+Z.Gd,d-e.Z/Gd.d/e.Z0Gd0d1e.Z1Gd2d3e.Z2Gd4d5Z3Gd6d7Z4Gd8d9Z5Gd:d;e5Z6Gd<d=e6Z7Gd>d?e6Z8Gd@dAe6Z9GdBdCe5Z:GdDdEe5Z;GdFdGe6Z<GdHdIe6Z=GdJdKZ>GdLdMe>Z?GdNdOe>Z@GdPdQe>ZAGdRdSZBGdTdUeBZCGdVdWeBZDGdXdYeBZEGdZd[ZFGd\d]eFZGGd^d_eFZHGd`daeFZIGdbdcZJy)haTools to monitor driver events. .. versionadded:: 3.1 .. attention:: Starting in PyMongo 3.11, the monitoring classes outlined below are included in the PyMongo distribution under the :mod:`~pymongo.event_loggers` submodule. Use :func:`register` to register global listeners for specific events. Listeners must inherit from one of the abstract classes below and implement the correct functions for that class. For example, a simple command logger might be implemented like this:: import logging from pymongo import monitoring class CommandLogger(monitoring.CommandListener): def started(self, event): logging.info("Command {0.command_name} with request id " "{0.request_id} started on server " "{0.connection_id}".format(event)) def succeeded(self, event): logging.info("Command {0.command_name} with request id " "{0.request_id} on server {0.connection_id} " "succeeded in {0.duration_micros} " "microseconds".format(event)) def failed(self, event): logging.info("Command {0.command_name} with request id " "{0.request_id} on server {0.connection_id} " "failed in {0.duration_micros} " "microseconds".format(event)) monitoring.register(CommandLogger()) Server discovery and monitoring events are also available. For example:: class ServerLogger(monitoring.ServerListener): def opened(self, event): logging.info("Server {0.server_address} added to topology " "{0.topology_id}".format(event)) def description_changed(self, event): previous_server_type = event.previous_description.server_type new_server_type = event.new_description.server_type if new_server_type != previous_server_type: # server_type_name was added in PyMongo 3.4 logging.info( "Server {0.server_address} changed type from " "{0.previous_description.server_type_name} to " "{0.new_description.server_type_name}".format(event)) def closed(self, event): logging.warning("Server {0.server_address} removed from topology " "{0.topology_id}".format(event)) class HeartbeatLogger(monitoring.ServerHeartbeatListener): def started(self, event): logging.info("Heartbeat sent to server " "{0.connection_id}".format(event)) def succeeded(self, event): # The reply.document attribute was added in PyMongo 3.4. logging.info("Heartbeat to server {0.connection_id} " "succeeded with reply " "{0.reply.document}".format(event)) def failed(self, event): logging.warning("Heartbeat to server {0.connection_id} " "failed with error {0.reply}".format(event)) class TopologyLogger(monitoring.TopologyListener): def opened(self, event): logging.info("Topology with id {0.topology_id} " "opened".format(event)) def description_changed(self, event): logging.info("Topology description updated for " "topology id {0.topology_id}".format(event)) previous_topology_type = event.previous_description.topology_type new_topology_type = event.new_description.topology_type if new_topology_type != previous_topology_type: # topology_type_name was added in PyMongo 3.4 logging.info( "Topology {0.topology_id} changed type from " "{0.previous_description.topology_type_name} to " "{0.new_description.topology_type_name}".format(event)) # The has_writable_server and has_readable_server methods # were added in PyMongo 3.4. if not event.new_description.has_writable_server(): logging.warning("No writable servers available.") if not event.new_description.has_readable_server(): logging.warning("No readable servers available.") def closed(self, event): logging.info("Topology with id {0.topology_id} " "closed".format(event)) Connection monitoring and pooling events are also available. For example:: class ConnectionPoolLogger(ConnectionPoolListener): def pool_created(self, event): logging.info("[pool {0.address}] pool created".format(event)) def pool_ready(self, event): logging.info("[pool {0.address}] pool is ready".format(event)) def pool_cleared(self, event): logging.info("[pool {0.address}] pool cleared".format(event)) def pool_closed(self, event): logging.info("[pool {0.address}] pool closed".format(event)) def connection_created(self, event): logging.info("[pool {0.address}][connection #{0.connection_id}] " "connection created".format(event)) def connection_ready(self, event): logging.info("[pool {0.address}][connection #{0.connection_id}] " "connection setup succeeded".format(event)) def connection_closed(self, event): logging.info("[pool {0.address}][connection #{0.connection_id}] " "connection closed, reason: " "{0.reason}".format(event)) def connection_check_out_started(self, event): logging.info("[pool {0.address}] connection check out " "started".format(event)) def connection_check_out_failed(self, event): logging.info("[pool {0.address}] connection check out " "failed, reason: {0.reason}".format(event)) def connection_checked_out(self, event): logging.info("[pool {0.address}][connection #{0.connection_id}] " "connection checked out of pool".format(event)) def connection_checked_in(self, event): logging.info("[pool {0.address}][connection #{0.connection_id}] " "connection checked into pool".format(event)) Event listeners can also be registered per instance of :class:`~pymongo.mongo_client.MongoClient`:: client = MongoClient(event_listeners=[CommandLogger()]) Note that previously registered global listeners are automatically included when configuring per client event listeners. Registering a new global listener will not add that listener to existing client instances. .. note:: Events are delivered **synchronously**. Application threads block waiting for event handlers (e.g. :meth:`~CommandListener.started`) to return. Care must be taken to ensure that your event handlers are efficient enough to not adversely affect overall application performance. .. warning:: The command documents published through this API are *not* copies. If you intend to modify them in any way you must copy them in your event handler first. ) annotationsN)abc namedtuple) TYPE_CHECKINGAnyMappingOptionalSequence)ObjectId)Hello HelloCompat)_handle_exception)_Address _DocumentOut) timedelta)ServerDescription)TopologyDescription _Listeners)command_listenersserver_listenersserver_heartbeat_listenerstopology_listenerscmap_listenersceZdZdZy)_EventListenerz,Abstract base class for all event listeners.N)__name__ __module__ __qualname____doc__b/var/www/html/phonemate/phone_mate_backend/venv/lib/python3.12/site-packages/pymongo/monitoring.pyrrs6r!rc(eZdZdZddZddZddZy) CommandListenerzAbstract base class for command listeners. Handles `CommandStartedEvent`, `CommandSucceededEvent`, and `CommandFailedEvent`. ct)zAbstract method to handle a `CommandStartedEvent`. :Parameters: - `event`: An instance of :class:`CommandStartedEvent`. NotImplementedErrorselfevents r"startedzCommandListener.started "!r!ct)zAbstract method to handle a `CommandSucceededEvent`. :Parameters: - `event`: An instance of :class:`CommandSucceededEvent`. r&r(s r" succeededzCommandListener.succeededr,r!ct)zAbstract method to handle a `CommandFailedEvent`. :Parameters: - `event`: An instance of :class:`CommandFailedEvent`. r&r(s r"failedzCommandListener.failedr,r!N)r*CommandStartedEventreturnNone)r*CommandSucceededEventr2r3)r*CommandFailedEventr2r3rrrrr+r.r0r r!r"r$r$s """r!r$cheZdZdZddZddZddZddZddZddZ ddZ dd Z dd Z dd Z dd Zy )ConnectionPoolListenera-Abstract base class for connection pool listeners. Handles all of the connection pool events defined in the Connection Monitoring and Pooling Specification: :class:`PoolCreatedEvent`, :class:`PoolClearedEvent`, :class:`PoolClosedEvent`, :class:`ConnectionCreatedEvent`, :class:`ConnectionReadyEvent`, :class:`ConnectionClosedEvent`, :class:`ConnectionCheckOutStartedEvent`, :class:`ConnectionCheckOutFailedEvent`, :class:`ConnectionCheckedOutEvent`, and :class:`ConnectionCheckedInEvent`. .. versionadded:: 3.9 ct)zAbstract method to handle a :class:`PoolCreatedEvent`. Emitted when a connection Pool is created. :Parameters: - `event`: An instance of :class:`PoolCreatedEvent`. r&r(s r" pool_createdz#ConnectionPoolListener.pool_created "!r!ct)zAbstract method to handle a :class:`PoolReadyEvent`. Emitted when a connection Pool is marked ready. :Parameters: - `event`: An instance of :class:`PoolReadyEvent`. .. versionadded:: 4.0 r&r(s r" pool_readyz!ConnectionPoolListener.pool_readys "!r!ct)zAbstract method to handle a `PoolClearedEvent`. Emitted when a connection Pool is cleared. :Parameters: - `event`: An instance of :class:`PoolClearedEvent`. r&r(s r" pool_clearedz#ConnectionPoolListener.pool_cleared$r;r!ct)zAbstract method to handle a `PoolClosedEvent`. Emitted when a connection Pool is closed. :Parameters: - `event`: An instance of :class:`PoolClosedEvent`. r&r(s r" pool_closedz"ConnectionPoolListener.pool_closed.r;r!ct)zAbstract method to handle a :class:`ConnectionCreatedEvent`. Emitted when a connection Pool creates a Connection object. :Parameters: - `event`: An instance of :class:`ConnectionCreatedEvent`. r&r(s r"connection_createdz)ConnectionPoolListener.connection_created8r;r!ct)zAbstract method to handle a :class:`ConnectionReadyEvent`. Emitted when a connection has finished its setup, and is now ready to use. :Parameters: - `event`: An instance of :class:`ConnectionReadyEvent`. r&r(s r"connection_readyz'ConnectionPoolListener.connection_readyB "!r!ct)zAbstract method to handle a :class:`ConnectionClosedEvent`. Emitted when a connection Pool closes a connection. :Parameters: - `event`: An instance of :class:`ConnectionClosedEvent`. r&r(s r"connection_closedz(ConnectionPoolListener.connection_closedMr;r!ct)zAbstract method to handle a :class:`ConnectionCheckOutStartedEvent`. Emitted when the driver starts attempting to check out a connection. :Parameters: - `event`: An instance of :class:`ConnectionCheckOutStartedEvent`. r&r(s r"connection_check_out_startedz3ConnectionPoolListener.connection_check_out_startedWr;r!ct)zAbstract method to handle a :class:`ConnectionCheckOutFailedEvent`. Emitted when the driver's attempt to check out a connection fails. :Parameters: - `event`: An instance of :class:`ConnectionCheckOutFailedEvent`. r&r(s r"connection_check_out_failedz2ConnectionPoolListener.connection_check_out_failedar;r!ct)zAbstract method to handle a :class:`ConnectionCheckedOutEvent`. Emitted when the driver successfully checks out a connection. :Parameters: - `event`: An instance of :class:`ConnectionCheckedOutEvent`. r&r(s r"connection_checked_outz-ConnectionPoolListener.connection_checked_outkr;r!ct)aAbstract method to handle a :class:`ConnectionCheckedInEvent`. Emitted when the driver checks in a connection back to the connection Pool. :Parameters: - `event`: An instance of :class:`ConnectionCheckedInEvent`. r&r(s r"connection_checked_inz,ConnectionPoolListener.connection_checked_inurFr!N)r*PoolCreatedEventr2r3)r*PoolReadyEventr2r3)r*PoolClearedEventr2r3)r*PoolClosedEventr2r3)r*ConnectionCreatedEventr2r3)r*ConnectionReadyEventr2r3)r*ConnectionClosedEventr2r3)r*ConnectionCheckOutStartedEventr2r3)r*ConnectionCheckOutFailedEventr2r3)r*ConnectionCheckedOutEventr2r3)r*ConnectionCheckedInEventr2r3)rrrrr:r=r?rArCrErHrJrLrNrPr r!r"r8r8s> " """" """"" "r!r8c(eZdZdZddZddZddZy) ServerHeartbeatListenerzAbstract base class for server heartbeat listeners. Handles `ServerHeartbeatStartedEvent`, `ServerHeartbeatSucceededEvent`, and `ServerHeartbeatFailedEvent`. .. versionadded:: 3.3 ct)zAbstract method to handle a `ServerHeartbeatStartedEvent`. :Parameters: - `event`: An instance of :class:`ServerHeartbeatStartedEvent`. r&r(s r"r+zServerHeartbeatListener.startedr,r!ct)zAbstract method to handle a `ServerHeartbeatSucceededEvent`. :Parameters: - `event`: An instance of :class:`ServerHeartbeatSucceededEvent`. r&r(s r"r.z!ServerHeartbeatListener.succeededr,r!ct)zAbstract method to handle a `ServerHeartbeatFailedEvent`. :Parameters: - `event`: An instance of :class:`ServerHeartbeatFailedEvent`. r&r(s r"r0zServerHeartbeatListener.failedr,r!N)r*ServerHeartbeatStartedEventr2r3)r*ServerHeartbeatSucceededEventr2r3)r*ServerHeartbeatFailedEventr2r3r6r r!r"r]r]s"""r!r]c(eZdZdZddZddZddZy) TopologyListenerzAbstract base class for topology monitoring listeners. Handles `TopologyOpenedEvent`, `TopologyDescriptionChangedEvent`, and `TopologyClosedEvent`. .. versionadded:: 3.3 ct)zAbstract method to handle a `TopologyOpenedEvent`. :Parameters: - `event`: An instance of :class:`TopologyOpenedEvent`. r&r(s r"openedzTopologyListener.openedr,r!ct)zAbstract method to handle a `TopologyDescriptionChangedEvent`. :Parameters: - `event`: An instance of :class:`TopologyDescriptionChangedEvent`. r&r(s r"description_changedz$TopologyListener.description_changedr,r!ct)zAbstract method to handle a `TopologyClosedEvent`. :Parameters: - `event`: An instance of :class:`TopologyClosedEvent`. r&r(s r"closedzTopologyListener.closedr,r!N)r*TopologyOpenedEventr2r3)r*TopologyDescriptionChangedEventr2r3)r*TopologyClosedEventr2r3rrrrrgrirkr r!r"rere"""r!rec(eZdZdZddZddZddZy) ServerListenerzAbstract base class for server listeners. Handles `ServerOpeningEvent`, `ServerDescriptionChangedEvent`, and `ServerClosedEvent`. .. versionadded:: 3.3 ct)zAbstract method to handle a `ServerOpeningEvent`. :Parameters: - `event`: An instance of :class:`ServerOpeningEvent`. r&r(s r"rgzServerListener.openedr,r!ct)zAbstract method to handle a `ServerDescriptionChangedEvent`. :Parameters: - `event`: An instance of :class:`ServerDescriptionChangedEvent`. r&r(s r"riz"ServerListener.description_changedr,r!ct)zAbstract method to handle a `ServerClosedEvent`. :Parameters: - `event`: An instance of :class:`ServerClosedEvent`. r&r(s r"rkzServerListener.closedr,r!N)r*ServerOpeningEventr2r3)r*ServerDescriptionChangedEventr2r3)r*ServerClosedEventr2r3ror r!r"rrrrrpr!rrc:t|jdzS)z'Convert duration 'dur' to microseconds.g.A)int total_seconds)durs r" _to_microsr}s s  "T) **r!ct|tjst|d|D]!}t|trtd|d|S)zValidate event listenersz must be a list or tupleListeners for x must be either a CommandListener, ServerHeartbeatListener, ServerListener, TopologyListener, or ConnectionPoolListener.) isinstancerr TypeErrorr)option listenerslisteners r"_validate_event_listenersrs_ i .6(":;<<(N3 )**  r!ct|tstd|dt|trtj j |t|trtjj |t|trtjj |t|trtjj |t|tr tjj |yy)aRegister a global event listener. :Parameters: - `listener`: A subclasses of :class:`CommandListener`, :class:`ServerHeartbeatListener`, :class:`ServerListener`, :class:`TopologyListener`, or :class:`ConnectionPoolListener`. rrN)rrrr$ _LISTENERSrappendr]rrrrrerr8r)rs r"registerrs h /XJ'& &  (O,$$++H5(34--44X>(N+##**84(,-%%,,X6(23!!((24r!> copydbgetnonce saslstart createuser updateuser authenticate saslcontinuecopydbgetnoncecopydbsaslstartset_SENSITIVE_COMMANDScR|jdtjfvrd|vryy)NhellospeculativeAuthenticateTF)lowerr LEGACY_CMD) command_namedocs r"_is_speculative_authenticater(s,+*@*@ AA % , r!ceZdZdZdZ d d dZed dZeddZeddZ eddZ edd Z ed d Z y) _CommandEventzBase class for command events.) __cmd_name __rqst_id __conn_id__op_id __service_id__dbNcX||_||_||_||_||_||_yN)_CommandEvent__cmd_name_CommandEvent__rqst_id_CommandEvent__conn_id_CommandEvent__op_id_CommandEvent__service_id_CommandEvent__db)r)r request_id connection_id operation_id service_id database_names r"__init__z_CommandEvent.__init__6s/'#&# &! r!c|jS)zThe command name.)rr)s r"rz_CommandEvent.command_nameFr!c|jS)z"The request id for this operation.)rrs r"rz_CommandEvent.request_idK~~r!c|jS)z@The address (host, port) of the server this command was sent to.)rrs r"rz_CommandEvent.connection_idPrr!c|jS)z^The service_id this command was sent to, or ``None``. .. versionadded:: 3.12 )rrs r"rz_CommandEvent.service_idUs    r!c|jS)z(An id for this series of events or None.)rrs r"rz_CommandEvent.operation_id]||r!c|jS)z^The database_name this command was sent to, or ``""``. .. versionadded:: 4.6 )rrs r"rz_CommandEvent.database_namebs yyr!N)rstrrrzrrr Optional[int]rOptional[ObjectId]rrr2r3r2rr2rzr2rr2r)r2r) rrrr __slots__rpropertyrrrrrrr r!r"rr1s([I*.""" " $ " ' "" " !!r!rcveZdZdZdZ d dfd Zed dZed fd Zd dZ xZ S) r1aEvent published when a command starts. :Parameters: - `command`: The command document. - `database_name`: The name of the database this command was run against. - `request_id`: The request id for this operation. - `connection_id`: The address (host, port) of the server this command was sent to. - `operation_id`: An optional identifier for a series of related events. - `service_id`: The service_id this command was sent to, or ``None``. )__cmdc|st|dtt|}t ||||||||j }|t vs t||ri|_y||_y)Nz is not a valid commandrr) ValueErrornextitersuperrrrr_CommandStartedEvent__cmd) r)commandrrrrrrcmd_name __class__s r"rzCommandStartedEvent.__init__zs{*ABC CDM*      !'   %%' * *.J8U\.]')DJ DJr!c|jS)zThe command document.)rrs r"rzCommandStartedEvent.commandszzr!ct|S)z6The name of the database this command was run against.)rrr)rs r"rz!CommandStartedEvent.database_namesw$$r!cdj|jj|j|j|j |j |jS)NzA<{} {} db: {!r}, command: {!r}, operation_id: {}, service_id: {}>)formatrrrrrrrrs r"__repr__zCommandStartedEvent.__repr__sMS[[ NN # #             OO   r!r)rrrrrrzrrrrrrr2r3r2rr) rrrrrrrrrr __classcell__rs@r"r1r1ks I*.!!! !  ! $ !'! !6%% r!r1c|eZdZdZdZ d dfd Zed dZed dZd dZ xZ S) r4aXEvent published when a command succeeds. :Parameters: - `duration`: The command duration as a datetime.timedelta. - `reply`: The server reply document. - `command_name`: The command name. - `request_id`: The request id for this operation. - `connection_id`: The address (host, port) of the server this command was sent to. - `operation_id`: An optional identifier for a series of related events. - `service_id`: The service_id this command was sent to, or ``None``. - `database_name`: The database this command was sent to, or ``""``. )__duration_micros__replyc t |||||||t||_|j } | t vs t | |ri|_y||_yNr)rrr}'_CommandSucceededEvent__duration_microsrrr_CommandSucceededEvent__reply) r)durationreplyrrrrrrrrs r"rzCommandSucceededEvent.__init__sh     !'  ",H!5%%' * *.J8UZ.[)+DL DLr!c|jSz/The duration of this operation in microseconds.)rrs r"duration_microsz%CommandSucceededEvent.duration_micros%%%r!c|jSz/The server failure document for this operation.)rrs r"rzCommandSucceededEvent.replyrr!c dj|jj|j|j|j |j |j|jS)NzV<{} {} db: {!r}, command: {!r}, operation_id: {}, duration_micros: {}, service_id: {}>) rrrrrrrrrrs r"rzCommandSucceededEvent.__repr__sU d & NN # #              OO  r!r)rdatetime.timedeltarrrrrrzrrrrrrrrr2r3rrr) rrrrrrrrrrrrs@r"r4r4s 1I*.!$!! !  !  !$!'!! !4&&  r!r4c|eZdZdZdZ d dfd Zed dZed dZd dZ xZ S) r5aWEvent published when a command fails. :Parameters: - `duration`: The command duration as a datetime.timedelta. - `failure`: The server reply document. - `command_name`: The command name. - `request_id`: The request id for this operation. - `connection_id`: The address (host, port) of the server this command was sent to. - `operation_id`: An optional identifier for a series of related events. - `service_id`: The service_id this command was sent to, or ``None``. - `database_name`: The database this command was sent to, or ``""``. )r __failurec ^t |||||||t||_||_yr)rrr}$_CommandFailedEvent__duration_micros_CommandFailedEvent__failure) r)rfailurerrrrrrrs r"rzCommandFailedEvent.__init__s?     !'  ",H!5 r!c|jSr)rrs r"rz"CommandFailedEvent.duration_microsrr!c|jSr)rrs r"rzCommandFailedEvent.failurerr!c dj|jj|j|j|j |j |j|j|jS)Nze<{} {} db: {!r}, command: {!r}, operation_id: {}, duration_micros: {}, failure: {!r}, service_id: {}>) rrrrrrrrrrrs r"rzCommandFailedEvent.__repr__s^ - & NN # #              LL OO  r!r)rrrrrrrrzrrrrrrrrr2r3rrr) rrrrrrrrrrrrs@r"r5r5s 3I*.!$!! !  !  !$!'!! !,&&  r!r5c6eZdZdZdZddZeddZd dZy) _PoolEventzBase class for pool events. __addressc||_yr_PoolEvent__addressr)addresss r"rz_PoolEvent.__init__3  r!c|jS)zbThe address (host, port) pair of the server the pool is attempting to connect to. rrs r"rz_PoolEvent.address6 ~~r!cN|jjd|jdSN())rrrrs r"rz_PoolEvent.__repr__=%..))*!DNN+=Q??r!Nrrr2r3rr rrrrrrrrrr r!r"rr.s)%I! @r!rcBeZdZdZdZdfd ZeddZddZxZ S) rQzPublished when a Connection Pool is created. :Parameters: - `address`: The address (host, port) pair of the server this Pool is attempting to connect to. .. versionadded:: 3.9 ) __optionsc2t||||_yr)rr_PoolCreatedEvent__options)r)roptionsrs r"rzPoolCreatedEvent.__init__Ms ! r!c|jS)zCAny non-default pool options that were set on this Connection Pool.)rrs r"rzPoolCreatedEvent.optionsQrr!ch|jjd|jd|jdSNrz, r)rrrrrs r"rzPoolCreatedEvent.__repr__Vs0..))*!DLL+;2dnn=OqQQr!rrrdict[str, Any]r2r3)r2rr) rrrrrrrrrrrs@r"rQrQAs.I!Rr!rQceZdZdZdZy)rRzPublished when a Connection Pool is marked ready. :Parameters: - `address`: The address (host, port) pair of the server this Pool is attempting to connect to. .. versionadded:: 4.0 r Nrrrrrr r!r"rRrRZIr!rRcDeZdZdZdZddfd ZeddZd dZxZ S) rSaPublished when a Connection Pool is cleared. :Parameters: - `address`: The address (host, port) pair of the server this Pool is attempting to connect to. - `service_id`: The service_id this command was sent to, or ``None``. .. versionadded:: 3.9 )rc2t||||_yr)rr_PoolClearedEvent__service_id)r)rrrs r"rzPoolClearedEvent.__init__ts !&r!c|jS)zConnections with this service_id are cleared. When service_id is ``None``, all connections in the pool are cleared. .. versionadded:: 3.12 )rrs r"rzPoolClearedEvent.service_idxs   r!ch|jjd|jd|jdSr)rrrrrs r"rzPoolClearedEvent.__repr__s3..))*!DLL+;2d>O>O=RRSTTr!rrrrrr2r3rr) rrrrrrrrrrrs@r"rSrSgs."I'!!Ur!rSceZdZdZdZy)rTzPublished when a Connection Pool is closed. :Parameters: - `address`: The address (host, port) pair of the server this Pool is attempting to connect to. .. versionadded:: 3.9 r Nrr r!r"rTrTrr!rTc&eZdZdZdZ dZ dZ dZy)ConnectionClosedReasonzqAn enum that defines values for `reason` on a :class:`ConnectionClosedEvent`. .. versionadded:: 3.9 staleidleerror poolClosedN)rrrrSTALEIDLEERROR POOL_CLOSEDr r!r"r r s- EF D EIKEr!r c eZdZdZdZ dZ dZy)ConnectionCheckOutFailedReasonzyAn enum that defines values for `reason` on a :class:`ConnectionCheckOutFailedEvent`. .. versionadded:: 3.9 timeoutr$connectionErrorN)rrrrTIMEOUTr( CONN_ERRORr r!r"r*r*s# GJKM"Jr!r*c6eZdZdZdZddZeddZd dZy) _ConnectionEventz)Private base class for connection events.rc||_yr_ConnectionEvent__addressrs r"rz_ConnectionEvent.__init__rr!c|jS)ziThe address (host, port) pair of the server this connection is attempting to connect to. r2rs r"rz_ConnectionEvent.addressrr!cN|jjd|jdSr)rrr3rs r"rz_ConnectionEvent.__repr__rr!Nr rrr r r!r"r0r0s)3I! @r!r0cBeZdZdZdZdfd ZeddZddZxZ S) _ConnectionIdEventz4Private base class for connection events with an id.)__connection_idc2t||||_yr)rr!_ConnectionIdEvent__connection_id)r)rrrs r"rz_ConnectionIdEvent.__init__s !,r!c|jS)zThe ID of the connection.)r:rs r"rz _ConnectionIdEvent.connection_ids###r!ch|jjd|jd|jdSr)rrrr:rs r"rz_ConnectionIdEvent.__repr__s3..))*!DLL+;2d>R>R=UUVWWr!rrrrzr2r3rr) rrrrrrrrrrrs@r"r7r7s*>$I-$$Xr!r7ceZdZdZdZy)rUaPublished when a Connection Pool creates a Connection object. NOTE: This connection is not ready for use until the :class:`ConnectionReadyEvent` is published. :Parameters: - `address`: The address (host, port) pair of the server this Connection is attempting to connect to. - `connection_id`: The integer ID of the Connection in this Pool. .. versionadded:: 3.9 r Nrr r!r"rUrUs Ir!rUceZdZdZdZy)rVa3Published when a Connection has finished its setup, and is ready to use. :Parameters: - `address`: The address (host, port) pair of the server this Connection is attempting to connect to. - `connection_id`: The integer ID of the Connection in this Pool. .. versionadded:: 3.9 r Nrr r!r"rVrVIr!rVcBeZdZdZdZdfd ZeddZddZxZ S)rWaVPublished when a Connection is closed. :Parameters: - `address`: The address (host, port) pair of the server this Connection is attempting to connect to. - `connection_id`: The integer ID of the Connection in this Pool. - `reason`: A reason explaining why this connection was closed. .. versionadded:: 3.9 __reasonc4t|||||_yr)rr_ConnectionClosedEvent__reason)r)rrreasonrs r"rzConnectionClosedEvent.__init__ s -0 r!c|jS)zA reason explaining why this connection was closed. The reason must be one of the strings from the :class:`ConnectionClosedReason` enum. )rErs r"rFzConnectionClosedEvent.reason}}r!cdj|jj|j|j|j S)Nz{}({!r}, {!r}, {!r}))rrrrrrErs r"rzConnectionClosedEvent.__repr__s9%,, NN # # LL    MM   r!)rrrrzrFrr rrrrrrrrFrrrs@r"rWrWs- I r!rWceZdZdZdZy)rXzPublished when the driver starts attempting to check out a connection. :Parameters: - `address`: The address (host, port) pair of the server this Connection is attempting to connect to. .. versionadded:: 3.9 r Nrr r!r"rXrX#rr!rXcBeZdZdZdZdfd ZeddZddZxZ S)rYa.Published when the driver's attempt to check out a connection fails. :Parameters: - `address`: The address (host, port) pair of the server this Connection is attempting to connect to. - `reason`: A reason explaining why connection check out failed. .. versionadded:: 3.9 rBc2t||||_yr)rr&_ConnectionCheckOutFailedEvent__reason)r)rrFrs r"rz&ConnectionCheckOutFailedEvent.__init__=s ! r!c|jS)zA reason explaining why connection check out failed. The reason must be one of the strings from the :class:`ConnectionCheckOutFailedReason` enum. )rNrs r"rFz$ConnectionCheckOutFailedEvent.reasonArHr!ch|jjd|jd|jdSr)rrrrNrs r"rz&ConnectionCheckOutFailedEvent.__repr__Js0..))*!DLL+;2dmm=NaPPr!rrrFrr2r3rrJrs@r"rYrY0s.IQr!rYceZdZdZdZy)rZa*Published when the driver successfully checks out a connection. :Parameters: - `address`: The address (host, port) pair of the server this Connection is attempting to connect to. - `connection_id`: The integer ID of the Connection in this Pool. .. versionadded:: 3.9 r Nrr r!r"rZrZNr@r!rZceZdZdZdZy)r[a*Published when the driver checks in a Connection into the Pool. :Parameters: - `address`: The address (host, port) pair of the server this Connection is attempting to connect to. - `connection_id`: The integer ID of the Connection in this Pool. .. versionadded:: 3.9 r Nrr r!r"r[r[\r@r!r[cHeZdZdZdZddZed dZed dZd dZ y) _ServerEventzBase class for server events.)__server_address __topology_idc ||_||_yr)_ServerEvent__server_address_ServerEvent__topology_id)r)server_address topology_ids r"rz_ServerEvent.__init__os .(r!c|jS)z+The address (host, port) pair of the server)rYrs r"r[z_ServerEvent.server_addressss$$$r!c|jSz>A unique identifier for the topology this server is a part of.)rZrs r"r\z_ServerEvent.topology_idx!!!r!cjd|jjd|jd|jdS)N<  topology_id: >)rrr[r\rs r"rz_ServerEvent.__repr__}s84>>**+1T-@-@,APTP`P`Oaabccr!Nr[rr\r r2r3rr2r r) rrrrrrrr[r\rr r!r"rUrUjs='5I)%%""dr!rUcdeZdZdZdZ dfd ZeddZeddZd dZ xZ S) rwzJPublished when server description changes. .. versionadded:: 3.3 __previous_description__new_descriptionc:t||||_||_yr)rr4_ServerDescriptionChangedEvent__previous_description/_ServerDescriptionChangedEvent__new_descriptionr)previous_descriptionnew_descriptionargsrs r"rz&ServerDescriptionChangedEvent.__init__" $&:#!0r!c|jS)zUThe previous :class:`~pymongo.server_description.ServerDescription`. )rmrs r"rpz2ServerDescriptionChangedEvent.previous_description ***r!c|jS)zPThe new :class:`~pymongo.server_description.ServerDescription`. )rnrs r"rqz-ServerDescriptionChangedEvent.new_description %%%r!cdj|jj|j|j|j S)Nz <{} {} changed from: {}, to: {}>)rrrr[rprqrs r"rz&ServerDescriptionChangedEvent.__repr__s=188 NN # #     % %    r!)rprrqrrrrr2r3)r2rr rrrrrrrrprqrrrs@r"rwrwsh @I1/1+1 1  1++ &&  r!rwceZdZdZdZy)rvzEPublished when server is initialized. .. versionadded:: 3.3 r Nrr r!r"rvrv Ir!rvceZdZdZdZy)rxz@Published when server is closed. .. versionadded:: 3.3 r Nrr r!r"rxrxr{r!rxc6eZdZdZdZddZeddZd dZy) TopologyEventz+Base class for topology description events.)rWc||_yr_TopologyEvent__topology_id)r)r\s r"rzTopologyEvent.__init__s (r!c|jSr_rrs r"r\zTopologyEvent.topology_idr`r!cPd|jjd|jdS)Nrbrdre)rrr\rs r"rzTopologyEvent.__repr__s)4>>**+>$:J:J9K1MMr!Nr\r r2r3rgr) rrrrrrrr\rr r!r"r~r~s)5"I)""Nr!r~cdeZdZdZdZ dfd ZeddZeddZd dZ xZ S) rmzPPublished when the topology description changes. .. versionadded:: 3.3 ric:t||||_||_yr)rr6_TopologyDescriptionChangedEvent__previous_description1_TopologyDescriptionChangedEvent__new_descriptionros r"rz(TopologyDescriptionChangedEvent.__init__rsr!c|jS)zYThe previous :class:`~pymongo.topology_description.TopologyDescription`. )rrs r"rpz4TopologyDescriptionChangedEvent.previous_descriptionrur!c|jS)zTThe new :class:`~pymongo.topology_description.TopologyDescription`. )rrs r"rqz/TopologyDescriptionChangedEvent.new_descriptionrwr!cdj|jj|j|j|j S)Nz-<{} topology_id: {} changed from: {}, to: {}>)rrrr\rprqrs r"rz(TopologyDescriptionChangedEvent.__repr__s=>EE NN # #     % %    r!)rprrqrrrrr2r3)r2rrryrs@r"rmrmsh @I111-1 1  1++ &&  r!rmceZdZdZdZy)rlzKPublished when the topology is initialized. .. versionadded:: 3.3 r Nrr r!r"rlrlr{r!rlceZdZdZdZy)rnzFPublished when the topology is closed. .. versionadded:: 3.3 r Nrr r!r"rnrnr{r!rncJeZdZdZdZdd dZed dZed dZd dZ y) _ServerHeartbeatEventz'Base class for server heartbeat events.)r8 __awaitedc ||_||_yr)$_ServerHeartbeatEvent__connection_id_ServerHeartbeatEvent__awaited)r)rawaiteds r"rz_ServerHeartbeatEvent.__init__ s, r!c|jS)zSThe address (host, port) of the server this heartbeat was sent to. )rrs r"rz#_ServerHeartbeatEvent.connection_ids ###r!c|jS)zgWhether the heartbeat was issued as an awaitable hello command. .. versionadded:: 4.6 )rrs r"rz_ServerHeartbeatEvent.awaiteds ~~r!cjd|jjd|jd|jdS)Nrbrcz awaited: re)rrrrrs r"rz_ServerHeartbeatEvent.__repr__ s44>>**+1T-?-?,@ 4<<.XYZZr!NFrrrboolr2r3rr2rr) rrrrrrrrrrr r!r"rrs=10I!$$ [r!rceZdZdZdZy)razFPublished when a heartbeat is started. .. versionadded:: 3.3 r Nrr r!r"rara$r{r!raceZdZdZdZ d d fd Zed dZed dZed fd Z d dZ xZ S)rbzIFired when the server heartbeat succeeds. .. versionadded:: 3.3  __durationrcBt|||||_||_yr)rr(_ServerHeartbeatSucceededEvent__duration%_ServerHeartbeatSucceededEvent__replyr)rrrrrs r"rz&ServerHeartbeatSucceededEvent.__init__5" 0" r!c|jSz/The duration of this heartbeat in microseconds.)rrs r"rz&ServerHeartbeatSucceededEvent.duration<rr!c|jS)z-An instance of :class:`~pymongo.hello.Hello`.)rrs r"rz#ServerHeartbeatSucceededEvent.replyArr!ct|SzWhether the heartbeat was awaited. If true, then :meth:`duration` reflects the sum of the round trip time to the server and the time that the server waited before sending a response. .. versionadded:: 3.11 rrrs r"rz%ServerHeartbeatSucceededEvent.awaitedFwr!cdj|jj|j|j|j |j S)Nz,<{} {} duration: {}, awaited: {}, reply: {}>rrrrrrrrs r"rz&ServerHeartbeatSucceededEvent.__repr__Rs@=DD NN # #    MM LL JJ   r!r) rfloatrr rrrrr2r3r2r)r2r rr rrrrrrrrrrrrrs@r"rbrb-s *IW\&+rrs r"rz#ServerHeartbeatFailedEvent.__repr__s@?FF NN # #    MM LL JJ   r!r) rrr Exceptionrrrrr2r3r)r2rrrrrs@r"rcrc\s *I[`&/@HSW    r!rcceZdZdZd!dZed"dZed"dZed"dZed"dZ ed"dZ d#dZ d$ d%d Z d& d'd Z d( d)d Zd*d Z d+dZ d,dZd-dZd-dZ d.dZd/dZd/dZ d0dZd1dZd2dZd3dZd2dZd4dZd4dZd5dZd2dZd6dZ d4dZ!d4d Z"y )7_EventListenerszConfigure event listeners for a client instance. Any event listeners registered globally are included by default. :Parameters: - `listeners`: A list of event listeners. ctjdd|_tjdd|_tj }|dd|_tjdd|_tjdd|_ ||D]}t|tr|jj|t|tr|jj|t|tr|j j|t|t r|jj|t|t"s|jj|t%|j|_t%|j|_t%|j |_t%|j|_t%|j|_yr)rr"_EventListeners__command_listenersr!_EventListeners__server_listenersr+_EventListeners__server_heartbeat_listenersr#_EventListeners__topology_listenersr_EventListeners__cmap_listenersrr$rrrr]rer8r%_EventListeners__enabled_for_commands#_EventListeners__enabled_for_server-_EventListeners__enabled_for_server_heartbeat%_EventListeners__enabled_for_topology!_EventListeners__enabled_for_cmap)r)rlsts r"rz_EventListeners.__init__so#-#?#?#B ","="=a"@33,/F)$.$A$A!$D! * 9 9! <   c?3,,33C8c>2++2237c#:;55<;?11J $!!%(2 $!# $rct||}|jD]} |j|y#t$r t Y-wxYw)aPublish a ServerClosedEvent to all server listeners. :Parameters: - `server_address`: The address (host, port) pair of the server. - `topology_id`: A unique identifier for the topology this server is a part of. N)rxrrkrrrs r"publish_server_closedz%_EventListeners.publish_server_closedsJ".+>11J $!!%(2 $!# $rct||||}|jD]} |j|y#t$r t Y-wxYw)aPublish a ServerDescriptionChangedEvent to all server listeners. :Parameters: - `previous_description`: The previous server description. - `server_address`: The address (host, port) pair of the server. - `new_description`: The new server description. - `topology_id`: A unique identifier for the topology this server is a part of. N)rwrrirr)r)rprqr[r\r*rs r""publish_server_description_changedz2_EventListeners.publish_server_description_changedsS . />; 11J $..u52 $!# $rct|}|jD]} |j|y#t$r t Y-wxYw)zPublish a TopologyOpenedEvent to all topology listeners. :Parameters: - `topology_id`: A unique identifier for the topology this server is a part of. N)rlrrgrrr)r\r*rs r"publish_topology_openedz'_EventListeners.publish_topology_openedH$K033J $!!%(4 $!# $0AAct|}|jD]} |j|y#t$r t Y-wxYw)zPublish a TopologyClosedEvent to all topology listeners. :Parameters: - `topology_id`: A unique identifier for the topology this server is a part of. N)rnrrkrrrs r"publish_topology_closedz'_EventListeners.publish_topology_closedrrct|||}|jD]} |j|y#t$r t Y-wxYw)aIPublish a TopologyDescriptionChangedEvent to all topology listeners. :Parameters: - `previous_description`: The previous topology description. - `new_description`: The new topology description. - `topology_id`: A unique identifier for the topology this server is a part of. N)rmrrirr)r)rprqr\r*rs r"$publish_topology_description_changedz4_EventListeners.publish_topology_description_changedsN00DoWbc33J $..u54 $!# $2AAct||}|jD]} |j|y#t$r t Y-wxYw)z:Publish a :class:`PoolCreatedEvent` to all pool listeners.N)rQrr:rr)r)rrr*rs r"publish_pool_createdz$_EventListeners.publish_pool_createdsH '2//J $''.0 $!# $rct|}|jD]} |j|y#t$r t Y-wxYw)z8Publish a :class:`PoolReadyEvent` to all pool listeners.N)rRrr=rrr)rr*rs r"publish_pool_readyz"_EventListeners.publish_pool_readysFw'//J $%%e,0 $!# $rct||}|jD]} |j|y#t$r t Y-wxYw)z:Publish a :class:`PoolClearedEvent` to all pool listeners.N)rSrr?rr)r)rrr*rs r"publish_pool_clearedz$_EventListeners.publish_pool_clearedsH *5//J $''.0 $!# $rct|}|jD]} |j|y#t$r t Y-wxYw)z9Publish a :class:`PoolClosedEvent` to all pool listeners.N)rTrrArrrs r"publish_pool_closedz#_EventListeners.publish_pool_closedsF(//J $&&u-0 $!# $rct||}|jD]} |j|y#t$r t Y-wxYw)zWPublish a :class:`ConnectionCreatedEvent` to all connection listeners. N)rUrrCrrr)rrr*rs r"publish_connection_createdz*_EventListeners.publish_connection_createdsJ'w >//J $--e40 $!# $rct||}|jD]} |j|y#t$r t Y-wxYw)zDPublish a :class:`ConnectionReadyEvent` to all connection listeners.N)rVrrErrrs r"publish_connection_readyz(_EventListeners.publish_connection_readysH$Wm<//J $++E20 $!# $rct|||}|jD]} |j|y#t$r t Y-wxYw)zVPublish a :class:`ConnectionClosedEvent` to all connection listeners. N)rWrrHrr)r)rrrFr*rs r"publish_connection_closedz)_EventListeners.publish_connection_closed#sL&g}fE//J $,,U30 $!# $rct|}|jD]} |j|y#t$r t Y-wxYw)z_Publish a :class:`ConnectionCheckOutStartedEvent` to all connection listeners. N)rXrrJrrrs r"$publish_connection_check_out_startedz4_EventListeners.publish_connection_check_out_started.sH/w7//J $77>0 $!# $rct||}|jD]} |j|y#t$r t Y-wxYw)z^Publish a :class:`ConnectionCheckOutFailedEvent` to all connection listeners. N)rYrrLrr)r)rrFr*rs r"#publish_connection_check_out_failedz3_EventListeners.publish_connection_check_out_failed9sJ.gv>//J $66u=0 $!# $rct||}|jD]} |j|y#t$r t Y-wxYw)zZPublish a :class:`ConnectionCheckedOutEvent` to all connection listeners. N)rZrrNrrrs r"publish_connection_checked_outz._EventListeners.publish_connection_checked_outDsJ*'=A//J $11%80 $!# $rct||}|jD]} |j|y#t$r t Y-wxYw)zYPublish a :class:`ConnectionCheckedInEvent` to all connection listeners. N)r[rrPrrrs r"publish_connection_checked_inz-_EventListeners.publish_connection_checked_inOsJ)-@//J $0070 $!# $r)rz"Optional[Sequence[_EventListener]]r)r2zlist[_EventListeners])NN)rrrrrrzrrrrrrr2r3)NNFr)rrrrrrrrzrrrrrrrrrrr2r3)NNr)rrrrrrrrzrrrrrrrrr2r3r) rrrrrr rrr2r3) rrrrrrrrr2r3rf) rprrqrr[rr\r r2r3r)rprrqrr\r r2r3rr rr=)rrrrzrFrr2r3rQ)#rrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrr r r rr r!r"rrs>2++))33++'' $)-$$$ $  $  $'$ $N $)-"'.$.$.$ .$  .$  .$.$'.$ .$.$ .$n $)-)$)$)$ )$  )$  )$)$')$)$ )$V $$%$16$?D$OS$ $($%$16$?H$SW$ $( $ $$/$+$! $  $  $2 $ $$1$-$ $  $*$$$$ $$ $ $ $ $ $r!r)r|rr2rz)rrrSequence[_EventListeners]r2r)rrr2r3)rrrzMapping[str, Any]r2r)Kr __future__rdatetime collectionsrrtypingrrrr r bson.objectidr pymongo.hellor r pymongo.helpersrpymongo.typingsrrrpymongo.server_descriptionrpymongo.topology_descriptionrrrrr$r8r]rerrr}rrr__annotations__rrr1r4r5rrQrRrSrTr r*r0r7rUrVrWrXrYrZr[rUrwrvrxr~rmrlrnrrarbrcrr r!r"rsiV#'BB",-2"<@  BB + 77"n"@@"^@"F"n"D"~"B"^"B+  5"3< S 77t< -< ~@ M@ F> > B@@&RzR2 Z UzU> j FF*&@@&X)X$/" - ! .! H %5 Q$4Q<  2  1 dd.& L& R NN"& m& R--[[8"7, $9, ^- !6- `L$L$r!