hdZddlmZddlmZddlmZeddZegggggZGdde Z Gd d e Z Gd d e Z Gd de Z Gdde ZGdde ZdZdZdZegdZGdde ZGddeZGddeZGddeZGdd e ZGd!d"eZGd#d$eZGd%d&eZGd'd(e ZGd)d*e ZGd+d,e ZGd-d.eZ Gd/d0eZ!Gd1d2eZ"Gd3d4e Z#Gd5d6e Z$Gd7d8eZ%Gd9d:eZ&Gd;de'Z(Gd?d@e'Z)GdAdBe'Z*GdCdDe Z+GdEdFe+Z,GdGdHe+Z-GdIdJe+Z.GdKdLe Z/GdMdNe/Z0GdOdPe/Z1GdQdRe/Z2GdSdTe Z3yU)VaTools 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_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}][conn #{0.connection_id}] " "connection created".format(event)) def connection_ready(self, event): logging.info("[pool {0.address}][conn #{0.connection_id}] " "connection setup succeeded".format(event)) def connection_closed(self, event): logging.info("[pool {0.address}][conn #{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}][conn #{0.connection_id}] " "connection checked out of pool".format(event)) def connection_checked_in(self, event): logging.info("[pool {0.address}][conn #{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. ) namedtuple)abc)_handle_exception Listeners)command_listenersserver_listenersserver_heartbeat_listenerstopology_listenerscmap_listenersceZdZdZy)_EventListenerz,Abstract base class for all event listeners.N)__name__ __module__ __qualname____doc__U/var/www/html/ranktracker/api/venv/lib/python3.12/site-packages/pymongo/monitoring.pyr r s6rr c"eZdZdZdZdZdZy)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 rstartedzCommandListener.started "!rct)zAbstract method to handle a `CommandSucceededEvent`. :Parameters: - `event`: An instance of :class:`CommandSucceededEvent`. rrs r succeededzCommandListener.succeededrrct)zAbstract method to handle a `CommandFailedEvent`. :Parameters: - `event`: An instance of :class:`CommandFailedEvent`. rrs rfailedzCommandListener.failedrrNrrrrrr r"rrrrrs """rrcLeZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z y ) 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`. rrs r pool_createdz#ConnectionPoolListener.pool_created "!rct)zAbstract method to handle a `PoolClearedEvent`. Emitted when a Connection Pool is cleared. :Parameters: - `event`: An instance of :class:`PoolClearedEvent`. rrs r pool_clearedz#ConnectionPoolListener.pool_clearedr(rct)zAbstract method to handle a `PoolClosedEvent`. Emitted when a Connection Pool is closed. :Parameters: - `event`: An instance of :class:`PoolClosedEvent`. rrs r pool_closedz"ConnectionPoolListener.pool_closed r(rct)zAbstract method to handle a :class:`ConnectionCreatedEvent`. Emitted when a Connection Pool creates a Connection object. :Parameters: - `event`: An instance of :class:`ConnectionCreatedEvent`. rrs rconnection_createdz)ConnectionPoolListener.connection_createdr(rct)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`. rrs rconnection_readyz'ConnectionPoolListener.connection_ready  "!rct)zAbstract method to handle a :class:`ConnectionClosedEvent`. Emitted when a Connection Pool closes a Connection. :Parameters: - `event`: An instance of :class:`ConnectionClosedEvent`. rrs rconnection_closedz(ConnectionPoolListener.connection_closed+r(rct)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`. rrs rconnection_check_out_startedz3ConnectionPoolListener.connection_check_out_started5r(rct)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`. rrs rconnection_check_out_failedz2ConnectionPoolListener.connection_check_out_failed?r(rct)zAbstract method to handle a :class:`ConnectionCheckedOutEvent`. Emitted when the driver successfully checks out a Connection. :Parameters: - `event`: An instance of :class:`ConnectionCheckedOutEvent`. rrs rconnection_checked_outz-ConnectionPoolListener.connection_checked_outIr(rct)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`. rrs rconnection_checked_inz,ConnectionPoolListener.connection_checked_inSr1rN)rrrrr'r*r,r.r0r3r5r7r9r;rrrr%r%s9 """" """"" "rr%c"eZdZdZdZdZdZy)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`. rrs rrzServerHeartbeatListener.startedhrrct)zAbstract method to handle a `ServerHeartbeatSucceededEvent`. :Parameters: - `event`: An instance of :class:`ServerHeartbeatSucceededEvent`. rrs rr z!ServerHeartbeatListener.succeededprrct)zAbstract method to handle a `ServerHeartbeatFailedEvent`. :Parameters: - `event`: An instance of :class:`ServerHeartbeatFailedEvent`. rrs rr"zServerHeartbeatListener.failedxrrNr#rrrr=r=_s"""rr=c"eZdZdZdZdZdZy)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`. rrs ropenedzTopologyListener.openedrrct)zAbstract method to handle a `TopologyDescriptionChangedEvent`. :Parameters: - `event`: An instance of :class:`TopologyDescriptionChangedEvent`. rrs rdescription_changedz$TopologyListener.description_changedrrct)zAbstract method to handle a `TopologyClosedEvent`. :Parameters: - `event`: An instance of :class:`TopologyClosedEvent`. rrs rclosedzTopologyListener.closedrrNrrrrrDrFrHrrrrBrB"""rrBc"eZdZdZdZdZdZy)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`. rrs rrDzServerListener.openedrrct)zAbstract method to handle a `ServerDescriptionChangedEvent`. :Parameters: - `event`: An instance of :class:`ServerDescriptionChangedEvent`. rrs rrFz"ServerListener.description_changedrrct)zAbstract method to handle a `ServerClosedEvent`. :Parameters: - `event`: An instance of :class:`ServerClosedEvent`. rrs rrHzServerListener.closedrrNrIrrrrLrLrJrrLc:t|jdzS)z'Convert duration 'dur' to microseconds.g.A)int total_seconds)durs r _to_microsrTs s  "T) **rct|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.) isinstancerSequence TypeErrorr )option listenerslisteners r_validate_event_listenersr^s\ i .@AAC(N3:@BC CC rct|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`. rVrWN)rXr rZr _LISTENERSrappendr=r rLrrBr r%r )r]s rregisterrbs h /6>@A A(O,$$++H5(34--44X>(N+##**84(,-%%,,X6(23!!((24r) authenticate saslstart saslcontinuegetnonce createuser updateusercopydbgetnoncecopydbsaslstartcopydbcZeZdZdZdZdZedZedZedZ edZ y) _CommandEventzBase class for command events.) __cmd_name __rqst_id __conn_id__op_idc<||_||_||_||_yN)_CommandEvent__cmd_name_CommandEvent__rqst_id_CommandEvent__conn_id_CommandEvent__op_id)r command_name request_id connection_id operation_ids r__init__z_CommandEvent.__init__s&#&# rc|jS)zThe command name.)rtrs rrxz_CommandEvent.command_namerc|jS)z"The request id for this operation.)rur~s rryz_CommandEvent.request_id~~rc|jS)z@The address (host, port) of the server this command was sent to.)rvr~s rrzz_CommandEvent.connection_id rrc|jS)z(An id for this series of events or None.)rwr~s rr{z_CommandEvent.operation_id||rN) rrrr __slots__r|propertyrxryrzr{rrrrmrms_(CI$ rrmcLeZdZdZdZfdZedZedZdZ xZ S)CommandStartedEventaEvent 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. )__cmd__dbc|st|dtt|}tt||g||j tvri|_||_ y||_||_ y)Nz is not a valid command) ValueErrornextitersuperrr|lower_SENSITIVE_COMMANDS_CommandStartedEvent__cmd_CommandStartedEvent__db)rcommand database_nameargsrx __class__s rr|zCommandStartedEvent.__init__"siGEF FDM*  !41,FF    #6 6DJ" !DJ! rc|jS)zThe command document.)rr~s rrzCommandStartedEvent.command.szzrc|jS)z6The name of the database this command was run against.)rr~s rrz!CommandStartedEvent.database_name3syyrc d|jjd|jd|jd|jd|j d S)N< z db: z , command: , operation_id: >)rrrzrrxr{r~s r__repr__zCommandStartedEvent.__repr__8s: NN # #T%7%79K9K   t002 2r) rrrrrr|rrrr __classcell__rs@rrrsA "I "2rrcLeZdZdZdZfdZedZedZdZ xZ S)CommandSucceededEventaEvent 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. )__duration_micros__replyctt| ||||t||_|j t vri|_y||_yrs)rrr|rT'_CommandSucceededEvent__duration_microsrr_CommandSucceededEvent__reply)rdurationreplyrxryrzr{rs rr|zCommandSucceededEvent.__init__LsJ #T3 *m\ C!+H!5    #6 6DL DLrc|jSz/The duration of this operation in microseconds.)rr~s rduration_microsz%CommandSucceededEvent.duration_microsV%%%rc|jSz/The server failure document for this operation.)rr~s rrzCommandSucceededEvent.reply[rrc d|jjd|jd|jd|jd|j d S)Nrr command: r, duration_micros: r)rrrzrxr{rr~s rrzCommandSucceededEvent.__repr__`s< NN # #T%7%7   t00$2F2FH Hr) rrrrrr|rrrrrrs@rrr>sB 1I!&&HrrcLeZdZdZdZfdZedZedZdZ xZ S)CommandFailedEventaEvent 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. )r __failurecTtt| |t||_||_yrs)rrr|rT$_CommandFailedEvent__duration_micros_CommandFailedEvent__failure)rrfailurerrs rr|zCommandFailedEvent.__init__ts'  $0$7!+H!5 rc|jSr)rr~s rrz"CommandFailedEvent.duration_microsyrrc|jSr)rr~s rrzCommandFailedEvent.failure~rrc d|jjd|jd|jd|jd|j d|j d S)Nrrrrrz , failure: r)rrrzrxr{rrr~s rrzCommandFailedEvent.__repr__sD''););T=N=N!!4#7#7 G Hr) rrrrrr|rrrrrrs@rrrfsB 3I! &&Hrrc0eZdZdZdZdZedZdZy) _PoolEventzBase class for pool events. __addressc||_yrs_PoolEvent__addressraddresss rr|z_PoolEvent.__init__  rc|jS)zbThe address (host, port) pair of the server the pool is attempting to connect to. rr~s rrz_PoolEvent.address ~~rcN|jjd|jdSN())rrrr~s rrz_PoolEvent.__repr__>>22DNNCCrN rrrrrr|rrrrrrrrs)%I! Drrc<eZdZdZdZfdZedZdZxZ S)PoolCreatedEventzPublished 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 ) __optionsc:tt| |||_yrs)rrr|_PoolCreatedEvent__options)rroptionsrs rr|zPoolCreatedEvent.__init__s .w7 rc|jS)zLAny non-default pool options that were set on this Connection Pool. )rr~s rrzPoolCreatedEvent.optionss~~rch|jjd|jd|jdSNrz, r)rrrrr~s rrzPoolCreatedEvent.__repr__s' NN # #T\\4>>C Cr) rrrrrr|rrrrrs@rrrs.I! CrrceZdZdZdZy)PoolClearedEventzPublished when a Connection Pool is cleared. :Parameters: - `address`: The address (host, port) pair of the server this Pool is attempting to connect to. .. versionadded:: 3.9 rNrrrrrrrrrrIrrceZdZdZdZy)PoolClosedEventzPublished 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 rNrrrrrrrrrc&eZdZdZdZ dZ dZ dZy)ConnectionClosedReasonzqAn enum that defines values for `reason` on a :class:`ConnectionClosedEvent`. .. versionadded:: 3.9 staleidleerror poolClosedN)rrrrSTALEIDLEERROR POOL_CLOSEDrrrrrs- EF D EIKErrc eZdZdZdZ dZ dZy)ConnectionCheckOutFailedReasonzyAn enum that defines values for `reason` on a :class:`ConnectionCheckOutFailedEvent`. .. versionadded:: 3.9 timeoutrconnectionErrorN)rrrrTIMEOUTr CONN_ERRORrrrrrs# GJKM"Jrrc@eZdZdZdZdZedZedZdZ y)_ConnectionEventz.Private base class for some connection events.)r__connection_idc ||_||_yrs)_ConnectionEvent__address_ConnectionEvent__connection_id)rrrzs rr|z_ConnectionEvent.__init__s ,rc|jSziThe address (host, port) pair of the server this connection is attempting to connect to. )rr~s rrz_ConnectionEvent.addressrrc|jS)zThe ID of the Connection.)rr~s rrzz_ConnectionEvent.connection_ids###rch|jjd|jd|jdSr)rrrrr~s rrz_ConnectionEvent.__repr__ s) NN # #T^^T5I5IK KrN) rrrrrr|rrrzrrrrrrs=80I- $$KrrceZdZdZdZy)ConnectionCreatedEventaPublished 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 rNrrrrrrs IrrceZdZdZdZy)ConnectionReadyEventa3Published 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 rNrrrrrr Irrc<eZdZdZdZfdZedZdZxZ S)ConnectionClosedEventaVPublished 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 )__reasonc<tt| ||||_yrs)rrr|_ConnectionClosedEvent__reason)rrrzreasonrs rr|zConnectionClosedEvent.__init__:s #T3G]K rc|jS)zA reason explaining why this connection was closed. The reason must be one of the strings from the :class:`ConnectionClosedReason` enum. )rr~s rrzConnectionClosedEvent.reason>}}rc|jjd|jd|jd|jdSr)rrrrzrr~s rrzConnectionClosedEvent.__repr__Gs. NN # #T\\43E3E MM r) rrrrrr|rrrrrs@rrr-s- Irrc0eZdZdZdZdZedZdZy)ConnectionCheckOutStartedEventzPublished 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 rc||_yrs(_ConnectionCheckOutStartedEvent__addressrs rr|z'ConnectionCheckOutStartedEvent.__init__Xrrc|jSrr r~s rrz&ConnectionCheckOutStartedEvent.address[rrcN|jjd|jdSr)rrr r~s rrz'ConnectionCheckOutStartedEvent.__repr__brrNrrrrrrMs-I! Drrc@eZdZdZdZdZedZedZdZ y)ConnectionCheckOutFailedEventa.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 )rrc ||_||_yrs)'_ConnectionCheckOutFailedEvent__address&_ConnectionCheckOutFailedEvent__reason)rrrs rr|z&ConnectionCheckOutFailedEvent.__init__rs  rc|jSr)rr~s rrz%ConnectionCheckOutFailedEvent.addressvrrc|jS)zA reason explaining why connection check out failed. The reason must be one of the strings from the :class:`ConnectionCheckOutFailedReason` enum. )rr~s rrz$ConnectionCheckOutFailedEvent.reason}rrch|jjd|jd|jdSr)rrrrr~s rrz&ConnectionCheckOutFailedEvent.__repr__s' NN # #T^^T]]D DrN) rrrrrr|rrrrrrrrrfsA*I DrrceZdZdZdZy)ConnectionCheckedOutEventa*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 rNrrrrrrrrrceZdZdZdZy)ConnectionCheckedInEventa*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 rNrrrrrrrrrc@eZdZdZdZdZedZedZdZ y) _ServerEventzBase class for server events.)__server_address __topology_idc ||_||_yrs)_ServerEvent__server_address_ServerEvent__topology_id)rserver_address topology_ids rr|z_ServerEvent.__init__s .(rc|jS)z+The address (host, port) pair of the server)rr~s rr!z_ServerEvent.server_addresss$$$rc|jSz>A unique identifier for the topology this server is a part of.)r r~s rr"z_ServerEvent.topology_id!!!rcjd|jjd|jd|jdS)Nrr topology_id: r)rrr!r"r~s rrz_ServerEvent.__repr__s+ NN # #T%8%8$:J:JL LrN) rrrrrr|rr!r"rrrrrrs='5I)%%""LrrcLeZdZdZdZfdZedZedZdZ xZ S)ServerDescriptionChangedEventzJPublished when server description changes. .. versionadded:: 3.3 __previous_description__new_descriptioncBtt| |||_||_yrs)rr*r|4_ServerDescriptionChangedEvent__previous_description/_ServerDescriptionChangedEvent__new_descriptionrprevious_descriptionnew_descriptionrrs rr|z&ServerDescriptionChangedEvent.__init__s# +T;TB&:#!0rc|jS)zLThe previous :class:`~pymongo.server_description.ServerDescription`.)r/r~s rr2z2ServerDescriptionChangedEvent.previous_description***rc|jS)zGThe new :class:`~pymongo.server_description.ServerDescription`.)r0r~s rr3z-ServerDescriptionChangedEvent.new_description%%%rc d|jjd|jd|jd|jd S)Nrr changed from: , to: r)rrr!r2r3r~s rrz&ServerDescriptionChangedEvent.__repr__s2 NN # #T%8%8  % %t';';= =r rrrrrr|rr2r3rrrs@rr*r*B @I1 ++ && =rr*ceZdZdZdZy)ServerOpeningEventzEPublished when server is initialized. .. versionadded:: 3.3 rNrrrrr>r> Irr>ceZdZdZdZy)ServerClosedEventz@Published when server is closed. .. versionadded:: 3.3 rNrrrrrArAr?rrAc0eZdZdZdZdZedZdZy) TopologyEventz+Base class for topology description events.rc||_yrs_TopologyEvent__topology_id)rr"s rr|zTopologyEvent.__init__s (rc|jSr%rEr~s rr"zTopologyEvent.topology_idr&rcPd|jjd|jdS)Nrr(r)rrr"r~s rrzTopologyEvent.__repr__s! NN # #T%5%57 7rN) rrrrrr|rr"rrrrrCrCs(5 I)""7rrCcLeZdZdZdZfdZedZedZdZ xZ S)TopologyDescriptionChangedEventzPPublished when the topology description changes. .. versionadded:: 3.3 r+cBtt| |||_||_yrs)rrJr|6_TopologyDescriptionChangedEvent__previous_description1_TopologyDescriptionChangedEvent__new_descriptionr1s rr|z(TopologyDescriptionChangedEvent.__init__s# -t=tD&:#!0rc|jS)zPThe previous :class:`~pymongo.topology_description.TopologyDescription`.)rLr~s rr2z4TopologyDescriptionChangedEvent.previous_description r5rc|jS)zKThe new :class:`~pymongo.topology_description.TopologyDescription`.)rMr~s rr3z/TopologyDescriptionChangedEvent.new_descriptionr7rc d|jjd|jd|jd|jd S)Nrr(r9r:r)rrr"r2r3r~s rrz(TopologyDescriptionChangedEvent.__repr__s2 NN # #T%5%5  % %t';';= =rr;rs@rrJrJr<rrJceZdZdZdZy)TopologyOpenedEventzKPublished when the topology is initialized. .. versionadded:: 3.3 rNrrrrrRrRr?rrRceZdZdZdZy)TopologyClosedEventzFPublished when the topology is closed. .. versionadded:: 3.3 rNrrrrrTrT(r?rrTc0eZdZdZdZdZedZdZy)_ServerHeartbeatEventz'Base class for server heartbeat events.rc||_yrs$_ServerHeartbeatEvent__connection_id)rrzs rr|z_ServerHeartbeatEvent.__init__6s ,rc|jS)zJThe address (host, port) of the server this heartbeat was sent to.rXr~s rrzz#_ServerHeartbeatEvent.connection_id9s###rcPd|jjd|jdS)Nrrr)rrrzr~s rrz_ServerHeartbeatEvent.__repr__?s NN33T5G5GHHrN) rrrrrr|rrzrrrrrVrV1s)1"I-$$ IrrVceZdZdZdZy)ServerHeartbeatStartedEventzFPublished when a heartbeat is started. .. versionadded:: 3.3 rNrrrrr]r]Cr?rr]c^eZdZdZdZdfd ZedZedZedZ dZ xZ S) ServerHeartbeatSucceededEventzIFired when the server heartbeat succeeds. .. versionadded:: 3.3  __durationr __awaitedcVtt| |||_||_||_yrs)rr_r|(_ServerHeartbeatSucceededEvent__duration%_ServerHeartbeatSucceededEvent__reply'_ServerHeartbeatSucceededEvent__awaitedrrrrzawaitedrs rr|z&ServerHeartbeatSucceededEvent.__init__Ts( +T;MJ"  rc|jSz/The duration of this heartbeat in microseconds.)rdr~s rrz&ServerHeartbeatSucceededEvent.durationZrrc|jS)z3An instance of :class:`~pymongo.ismaster.IsMaster`.)rer~s rrz#ServerHeartbeatSucceededEvent.reply_rrc|jSzWhether 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. )rfr~s rrhz%ServerHeartbeatSucceededEvent.awaitedd~~rc d|jjd|jd|jd|jd|j d SNrrz duration: z , awaited: z , reply: rrrrzrrhrr~s rrz&ServerHeartbeatSucceededEvent.__repr__n4 NN # #T%7%7 MM4<<5 5rF rrrrrr|rrrrhrrrs@rr_r_LsU 7I! 5rr_c^eZdZdZdZdfd ZedZedZedZ dZ xZ S) ServerHeartbeatFailedEventzxFired when the server heartbeat fails, either with an "ok: 0" or a socket exception. .. versionadded:: 3.3 r`cVtt| |||_||_||_yrs)rrvr|%_ServerHeartbeatFailedEvent__duration"_ServerHeartbeatFailedEvent__reply$_ServerHeartbeatFailedEvent__awaitedrgs rr|z#ServerHeartbeatFailedEvent.__init__}s( ($8G"  rc|jSrj)rxr~s rrz#ServerHeartbeatFailedEvent.durationrrc|jS)zA subclass of :exc:`Exception`.)ryr~s rrz ServerHeartbeatFailedEvent.replyrrc|jSrm)rzr~s rrhz"ServerHeartbeatFailedEvent.awaitedrnrc d|jjd|jd|jd|jd|j d Srprqr~s rrz#ServerHeartbeatFailedEvent.__repr__rrrrsrtrs@rrvrvtsU 7I! 5rrvceZdZdZdZedZedZedZedZ edZ dZ d d Z d d Z d d Zd ZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZ dZ!y )!_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|_yrs)r`r"_EventListeners__command_listenersr!_EventListeners__server_listenersr +_EventListeners__server_heartbeat_listenersr #_EventListeners__topology_listenersr _EventListeners__cmap_listenersrXrrarLr=rBr%bool%_EventListeners__enabled_for_commands#_EventListeners__enabled_for_server-_EventListeners__enabled_for_server_heartbeat%_EventListeners__enabled_for_topology!_EventListeners__enabled_for_cmap)rr\lsts rr|z_EventListeners.__init__sw#-#?#?#B ","="=a"@33,/F)$.$A$A!$D! * 9 9! <   6c?3,,33C8c>2++2237c#:;55<rrDrrrr!r"rrs rpublish_server_openedz%_EventListeners.publish_server_opened[sO#>;?11 $J $!!%( $ $!# $1AAct||}|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)rArrHrrrs rpublish_server_closedz%_EventListeners.publish_server_closedjsO".+>11 $J $!!%( $ $!# $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)r*rrFrr)rr2r3r!r"rrs r"publish_server_description_changedz2_EventListeners.publish_server_description_changedysZ..B.=~.9;11 $J $..u5 $ $!# $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)rRrrDrrrr"rrs rpublish_topology_openedz'_EventListeners.publish_topology_openedM$K033 $J $!!%( $ $!# $rct|}|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)rTrrHrrrs rpublish_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)rJrrFrr)rr2r3r"rrs r$publish_topology_description_changedz4_EventListeners.publish_topology_description_changedsV00D0?N33 $J $..u5 $ $!# $2AAct||}|jD]} |j|y#t$r t Y-wxYw)zCPublish a :class:`PoolCreatedEvent` to all pool listeners. N)rrr'rr)rrrrrs rpublish_pool_createdz$_EventListeners.publish_pool_createdsO!'2// $J $''. $ $!# $rct|}|jD]} |j|y#t$r t Y-wxYw)zCPublish a :class:`PoolClearedEvent` to all pool listeners. N)rrr*rrrrrrs rpublish_pool_clearedz$_EventListeners.publish_pool_clearedsM!)// $J $''. $ $!# $rct|}|jD]} |j|y#t$r t Y-wxYw)zBPublish a :class:`PoolClosedEvent` to all pool listeners. N)rrr,rrrs rpublish_pool_closedz#_EventListeners.publish_pool_closedsM (// $J $&&u- $ $!# $rct||}|jD]} |j|y#t$r t Y-wxYw)zWPublish a :class:`ConnectionCreatedEvent` to all connection listeners. N)rrr.rrrrrzrrs rpublish_connection_createdz*_EventListeners.publish_connection_createdsO'w >// $J $--e4 $ $!# $rct||}|jD]} |j|y#t$r t Y-wxYw)zMPublish a :class:`ConnectionReadyEvent` to all connection listeners. N)rrr0rrrs rpublish_connection_readyz(_EventListeners.publish_connection_readysO%Wm<// $J $++E2 $ $!# $rct|||}|jD]} |j|y#t$r t Y-wxYw)zVPublish a :class:`ConnectionClosedEvent` to all connection listeners. N)rrr3rr)rrrzrrrs rpublish_connection_closedz)_EventListeners.publish_connection_closedsQ&g}fE// $J $,,U3 $ $!# $rct|}|jD]} |j|y#t$r t Y-wxYw)z_Publish a :class:`ConnectionCheckOutStartedEvent` to all connection listeners. N)rrr5rrrs r$publish_connection_check_out_startedz4_EventListeners.publish_connection_check_out_startedsM/w7// $J $77> $ $!# $rct||}|jD]} |j|y#t$r t Y-wxYw)z^Publish a :class:`ConnectionCheckOutFailedEvent` to all connection listeners. N)rrr5rr)rrrrrs r#publish_connection_check_out_failedz3_EventListeners.publish_connection_check_out_failedsO.gv>// $J $77> $ $!# $rct||}|jD]} |j|y#t$r t Y-wxYw)zZPublish a :class:`ConnectionCheckedOutEvent` to all connection listeners. N)rrr9rrrs rpublish_connection_checked_outz._EventListeners.publish_connection_checked_outsO*'=A// $J $11%8 $ $!# $rct||}|jD]} |j|y#t$r t Y-wxYw)zYPublish a :class:`ConnectionCheckedInEvent` to all connection listeners. N)rrr;rrrs rpublish_connection_checked_inz-_EventListeners.publish_connection_checked_insO)-@// $J $007 $ $!# $rrs)"rrrrr|rrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrs>4++))33++''.@D$0BF$0BF$0 $$($( $ $$* $ $$$$$$ $$ $ $ $ $ $rrN)4r collectionsrbson.py3compatrpymongo.helpersr _Listenersr`objectr rr%r=rBrLrTr^rbsetrrmrrrrrrrrrrrrrrrrrrr*r>rArCrJrRrTrVr]r_rvrrrrrsHfP#-  +, BB + 7V7"n"@t"^t"n"n"D"~"B"^"B+ 36BC F@&2-&2R%HM%HP"H"HJDD$CzC4 z  j FVF*V&KvK2 -  + ,@DVD2"DF"DJ  0  / L6L0=L=> 7F7$=m=>--IFI$"7%5$9%5P&5!6&5RG$fG$r