h?dZddlmZddlmZddlmZddlmZeddZ e gggggZ Gdd e Z Gd d e Z Gd d e ZGdde ZGdde ZGdde ZdZdZdZegdZdZGdde ZGddeZGddeZGdd eZGd!d"e ZGd#d$eZGd%d&eZGd'd(eZGd)d*e Z Gd+d,e Z!Gd-d.e Z"Gd/d0e"Z#Gd1d2e"Z$Gd3d4e"Z%Gd5d6e Z&Gd7d8e Z'Gd9d:e"Z(Gd;de Z*Gd?d@e*Z+GdAdBe*Z,GdCdDe*Z-GdEdFe Z.GdGdHe.Z/GdIdJe.Z0GdKdLe.Z1GdMdNe Z2GdOdPe2Z3GdQdRe2Z4GdSdTe2Z5GdUdVe Z6yW)XaTools 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) HelloCompat)_handle_exception Listeners)command_listenersserver_listenersserver_heartbeat_listenerstopology_listenerscmap_listenersceZdZdZy)_EventListenerz,Abstract base class for all event listeners.N)__name__ __module__ __qualname____doc__P/var/www/html/eduruby.in/venv/lib/python3.12/site-packages/pymongo/monitoring.pyrrs6rrc"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_cleared r)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_closedr)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_closed2r)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_started<r)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_failedFr)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_outPr)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_inZr2rN)rrrrr(r+r-r/r1r4r6r8r:r<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.startedorrct)zAbstract method to handle a `ServerHeartbeatSucceededEvent`. :Parameters: - `event`: An instance of :class:`ServerHeartbeatSucceededEvent`. rrs rr!z!ServerHeartbeatListener.succeededwrrct)zAbstract method to handle a `ServerHeartbeatFailedEvent`. :Parameters: - `event`: An instance of :class:`ServerHeartbeatFailedEvent`. rrs rr#zServerHeartbeatListener.failedrrNr$rrrr>r>fs"""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.closedrrNrrrrrErGrIrrrrCrC"""rrCc"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 rrEzServerListener.openedrrct)zAbstract method to handle a `ServerDescriptionChangedEvent`. :Parameters: - `event`: An instance of :class:`ServerDescriptionChangedEvent`. rrs rrGz"ServerListener.description_changedrrct)zAbstract method to handle a `ServerClosedEvent`. :Parameters: - `event`: An instance of :class:`ServerClosedEvent`. rrs rrIzServerListener.closedrrNrJrrrrMrMrKrrMc:t|jdzS)z'Convert duration 'dur' to microseconds.g.A)int total_seconds)durs r _to_microsrUs 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_sV i .@AA(N3.46  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`. rWrXN)rYrr[r _LISTENERSrappendr>r rMr rCr r&r )r^s rregisterrcs h /*2 4  (O,$$++H5(34--44X>(N+##**84(,-%%,,X6(23!!((24r) authenticate saslstart saslcontinuegetnonce createuser updateusercopydbgetnoncecopydbsaslstartcopydbcR|jdtjfvrd|vryy)NhellospeculativeAuthenticateTF)lowerr LEGACY_CMD) command_namedocs r_is_speculative_authenticatert s,+*@*@ AA % , rcleZdZdZdZd dZedZedZedZ edZ ed Z y) _CommandEventzBase class for command events.) __cmd_name __rqst_id __conn_id__op_id __service_idNcJ||_||_||_||_||_yN)_CommandEvent__cmd_name_CommandEvent__rqst_id_CommandEvent__conn_id_CommandEvent__op_id_CommandEvent__service_id)rrr request_id connection_id operation_id service_ids r__init__z_CommandEvent.__init__s&&#&# &rc|jS)zThe command name.)r~rs rrrz_CommandEvent.command_name"rc|jS)z"The request id for this operation.)rrs rrz_CommandEvent.request_id'~~rc|jS)z@The address (host, port) of the server this command was sent to.)rrs rrz_CommandEvent.connection_id,rrc|jS)z^The service_id this command was sent to, or ``None``. .. versionadded:: 3.12 )rrs rrz_CommandEvent.service_id1s    rc|jS)z(An id for this series of events or None.)rrs rrz_CommandEvent.operation_id9||rr}) rrrr __slots__rpropertyrrrrrrrrrrvrvss(SI'!!rrvcPeZdZdZdZ dfd ZedZedZdZ 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. - `service_id`: The service_id this command was sent to, or ``None``. )__cmd__dbc |st|dtt|}tt|||||||j ||} }|tvs t||ri|_ ||_ y||_ ||_ y)Nz is not a valid commandr) ValueErrornextitersuperrrrp_SENSITIVE_COMMANDSrt_CommandStartedEvent__cmd_CommandStartedEvent__db) rcommand database_namerrrrrrcmd_namecmd_doc __class__s rrzCommandStartedEvent.__init__NsGEF FDM*  !41 *m\j 2 )..0',2G' * *.J8U\.]DJ" !DJ! rc|jS)zThe command document.)rrs rrzCommandStartedEvent.command_szzrc|jS)z6The name of the database this command was run against.)rrs rrz!CommandStartedEvent.database_namedsyyrc d|jjd|jd|jd|jd|j d|j d S)N< z db: z , command: , operation_id: , service_id: >)rrrrrrrrrs r__repr__zCommandStartedEvent.__repr__isD NN # #             OO   rr}) rrrrrrrrrr __classcell__rs@rrr?sH "I[_"" rrcPeZdZdZdZ dfd ZedZedZdZ xZ S)CommandSucceededEventa Event 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``. )__duration_micros__replyctt| |||||t||_|j }|t vs t||ri|_y||_yNr) rrrrU'_CommandSucceededEvent__duration_microsrprrt_CommandSucceededEvent__reply) rdurationreplyrrrrrrrrs rrzCommandSucceededEvent.__init__sd #T3 *m\j 4 ",H!5%%' * *.J8UZ.[DL DLrc|jSz/The duration of this operation in microseconds.)rrs rduration_microsz%CommandSucceededEvent.duration_micros%%%rc|jSz/The server failure document for this operation.)rrs rrzCommandSucceededEvent.replyrrc d|jjd|jd|jd|jd|j d|j d S)Nrr command: r, duration_micros: rr)rrrrrrrrrs rrzCommandSucceededEvent.__repr__sD NN # #           OO   rr}) rrrrrrrrrrrrs@rrrtsF 1I!(&& rrcPeZdZdZdZ dfd ZedZedZdZ xZ S)CommandFailedEventa Event 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``. )r __failurecdtt| |||||t||_||_yr)rrrrU$_CommandFailedEvent__duration_micros_CommandFailedEvent__failure) rrfailurerrrrrrrs rrzCommandFailedEvent.__init__s;  $0 *m\j 1 ",H!5 rc|jSr)rrs rrz"CommandFailedEvent.duration_microsrrc|jSr)rrs rrzCommandFailedEvent.failurerrcd|jjd|jd|jd|jd|j d|j d|jdS) Nrrrrrz , failure: rr)rrrrrrrrrrs rrzCommandFailedEvent.__repr__sM NN # #           LL OO  rr}) rrrrrrrrrrrrs@rrrsF 3I! &&  rrc0eZdZdZdZdZedZdZy) _PoolEventzBase class for pool events. __addressc||_yr}_PoolEvent__addressraddresss rrz_PoolEvent.__init__  rc|jS)zbThe address (host, port) pair of the server the pool is attempting to connect to. rrs rrz_PoolEvent.address ~~rcN|jjd|jdSN())rrrrs rrz_PoolEvent.__repr__>>22DNNCCrN rrrrrrrrrrrrrrs)%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| |||_yr})rrr_PoolCreatedEvent__options)rroptionsrs rrzPoolCreatedEvent.__init__s .w7 rc|jS)zCAny non-default pool options that were set on this Connection Pool.)rrs rrzPoolCreatedEvent.options rrch|jjd|jd|jdSNrz, r)rrrrrs rrzPoolCreatedEvent.__repr__s!#~~66 dnnUUr) rrrrrrrrrrrs@rrrs.I!Vrrc>eZdZdZdZdfd ZedZdZxZ S)PoolClearedEventaPublished 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 )r{c:tt| |||_yr})rrr_PoolClearedEvent__service_id)rrrrs rrzPoolClearedEvent.__init__s .w7&rc|jS)zConnections with this service_id are cleared. When service_id is ``None``, all connections in the pool are cleared. .. versionadded:: 3.12 )rrs rrzPoolClearedEvent.service_id#s   rch|jjd|jd|jdSr)rrrrrs rrzPoolClearedEvent.__repr__-s##~~66 dFWFWXXrr}) rrrrrrrrrrrs@rrrs."I'!!YrrceZdZdZdZy)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 rNrrrrrrrrrr1sIrrc&eZdZdZdZ dZ dZ dZy)ConnectionClosedReasonzqAn enum that defines values for `reason` on a :class:`ConnectionClosedEvent`. .. versionadded:: 3.9 staleidleerror poolClosedN)rrrrSTALEIDLEERROR POOL_CLOSEDrrrrr>s- EF D EIKErrc eZdZdZdZ dZ dZy)ConnectionCheckOutFailedReasonzyAn enum that defines values for `reason` on a :class:`ConnectionCheckOutFailedEvent`. .. versionadded:: 3.9 timeoutrconnectionErrorN)rrrrTIMEOUTr CONN_ERRORrrrrrSs# GJKM"Jrrc@eZdZdZdZdZedZedZdZ y)_ConnectionEventz.Private base class for some connection events.)r__connection_idc ||_||_yr})_ConnectionEvent__address_ConnectionEvent__connection_id)rrrs rrz_ConnectionEvent.__init__ks ,rc|jSziThe address (host, port) pair of the server this connection is attempting to connect to. )rrs rrz_ConnectionEvent.addressorrc|jS)zThe ID of the Connection.)rrs rrz_ConnectionEvent.connection_idvs###rch|jjd|jd|jdSr)rrrrrs rrz_ConnectionEvent.__repr__{s##~~66H\H\]]rN) rrrrrrrrrrrrrrrfs=80I- $$^rrceZdZdZdZy)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 rNrrrrr r s Irr ceZdZdZdZy)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 rNrrrrrrIrrc<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| ||||_yr})rrr_ConnectionClosedEvent__reason)rrrreasonrs rrzConnectionClosedEvent.__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. )rrs rrzConnectionClosedEvent.reason}}rc|jjd|jd|jd|jdSr)rrrrrrs rrzConnectionClosedEvent.__repr__s0 NN # # LL    MM   r) rrrrrrrrrrrs@rrrs- I rrc0eZdZdZdZdZedZdZy)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||_yr}(_ConnectionCheckOutStartedEvent__addressrs rrz'ConnectionCheckOutStartedEvent.__init__rrc|jSrrrs rrz&ConnectionCheckOutStartedEvent.addressrrcN|jjd|jdSr)rrrrs rrz'ConnectionCheckOutStartedEvent.__repr__rrNrrrrrrs-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 ||_||_yr})'_ConnectionCheckOutFailedEvent__address&_ConnectionCheckOutFailedEvent__reason)rrrs rrz&ConnectionCheckOutFailedEvent.__init__s  rc|jSr)r#rs rrz%ConnectionCheckOutFailedEvent.addressrrc|jS)zA reason explaining why connection check out failed. The reason must be one of the strings from the :class:`ConnectionCheckOutFailedReason` enum. )r$rs rrz$ConnectionCheckOutFailedEvent.reasonrrch|jjd|jd|jdSr)rrr#r$rs rrz&ConnectionCheckOutFailedEvent.__repr__s!#~~66 VVrN) rrrrrrrrrrrrrr!r!sA*I Wrr!ceZdZdZdZy)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 rNrrrrr)r)rrr)ceZdZdZdZy)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 rNrrrrr+r+rrr+c@eZdZdZdZdZedZedZdZ y) _ServerEventzBase class for server events.)__server_address __topology_idc ||_||_yr})_ServerEvent__server_address_ServerEvent__topology_id)rserver_address topology_ids rrz_ServerEvent.__init__"s .(rc|jS)z+The address (host, port) pair of the server)r1rs rr3z_ServerEvent.server_address&s$$$rc|jSz>A unique identifier for the topology this server is a part of.)r2rs rr4z_ServerEvent.topology_id+!!!rcjd|jjd|jd|jdS)Nrr topology_id: r)rrr3r4rs rrz_ServerEvent.__repr__0s+ NN # #        rN) rrrrrrrr3r4rrrrr-r-s<'5I)%%"" rr-cLeZdZdZdZfdZedZedZdZ xZ S)ServerDescriptionChangedEventzJPublished when server description changes. .. versionadded:: 3.3 __previous_description__new_descriptioncBtt| |||_||_yr})rr<r4_ServerDescriptionChangedEvent__previous_description/_ServerDescriptionChangedEvent__new_descriptionrprevious_descriptionnew_descriptionargsrs rrz&ServerDescriptionChangedEvent.__init__@s# +T;TB&:#!0rc|jS)zLThe previous :class:`~pymongo.server_description.ServerDescription`.)rArs rrDz2ServerDescriptionChangedEvent.previous_descriptionE***rc|jS)zGThe new :class:`~pymongo.server_description.ServerDescription`.)rBrs rrEz-ServerDescriptionChangedEvent.new_descriptionK%%%rc d|jjd|jd|jd|jd S)Nrr changed from: , to: r)rrr3rDrErs rrz&ServerDescriptionChangedEvent.__repr__Qs4 NN # #     % %    r rrrrrrrrDrErrrs@rr<r<8B @I1 ++ &&  rr<ceZdZdZdZy)ServerOpeningEventzEPublished when server is initialized. .. versionadded:: 3.3 rNrrrrrQrQZ IrrQceZdZdZdZy)ServerClosedEventz@Published when server is closed. .. versionadded:: 3.3 rNrrrrrTrTcrRrrTc0eZdZdZdZdZedZdZy) TopologyEventz+Base class for topology description events.r/c||_yr}_TopologyEvent__topology_id)rr4s rrzTopologyEvent.__init__qs (rc|jSr7rXrs rr4zTopologyEvent.topology_idtr8rcPd|jjd|jdS)Nrr:r)rrr4rs rrzTopologyEvent.__repr__ys)-)@)@$BRBRSSrN) rrrrrrrr4rrrrrVrVls)5I)""TrrVcLeZdZdZdZfdZedZedZdZ xZ S)TopologyDescriptionChangedEventzPPublished when the topology description changes. .. versionadded:: 3.3 r=cBtt| |||_||_yr})rr]r6_TopologyDescriptionChangedEvent__previous_description1_TopologyDescriptionChangedEvent__new_descriptionrCs rrz(TopologyDescriptionChangedEvent.__init__s# -t=tD&:#!0rc|jS)zPThe previous :class:`~pymongo.topology_description.TopologyDescription`.)r_rs rrDz4TopologyDescriptionChangedEvent.previous_descriptionrHrc|jS)zKThe new :class:`~pymongo.topology_description.TopologyDescription`.)r`rs rrEz/TopologyDescriptionChangedEvent.new_descriptionrJrc d|jjd|jd|jd|jd S)Nrr:rLrMr)rrr4rDrErs rrz(TopologyDescriptionChangedEvent.__repr__s4 NN # #     % %    rrNrs@rr]r]}rOrr]ceZdZdZdZy)TopologyOpenedEventzKPublished when the topology is initialized. .. versionadded:: 3.3 rNrrrrrererRrreceZdZdZdZy)TopologyClosedEventzFPublished when the topology is closed. .. versionadded:: 3.3 rNrrrrrgrgrRrrgc0eZdZdZdZdZedZdZy)_ServerHeartbeatEventz'Base class for server heartbeat events.rc||_yr}$_ServerHeartbeatEvent__connection_id)rrs rrz_ServerHeartbeatEvent.__init__s ,rc|jS)zJThe address (host, port) of the server this heartbeat was sent to.rkrs rrz#_ServerHeartbeatEvent.connection_ids###rcPd|jjd|jdS)Nrrr)rrrrs rrz_ServerHeartbeatEvent.__repr__s NN33T5G5GHHrN) rrrrrrrrrrrrriris)1!I-$$ IrriceZdZdZdZy)ServerHeartbeatStartedEventzFPublished when a heartbeat is started. .. versionadded:: 3.3 rNrrrrrprprRrrpc^eZdZdZdZdfd ZedZedZedZ dZ xZ S) ServerHeartbeatSucceededEventzIFired when the server heartbeat succeeds. .. versionadded:: 3.3  __durationr __awaitedcVtt| |||_||_||_yr})rrrr(_ServerHeartbeatSucceededEvent__duration%_ServerHeartbeatSucceededEvent__reply'_ServerHeartbeatSucceededEvent__awaitedrrrrawaitedrs rrz&ServerHeartbeatSucceededEvent.__init__s( +T;MJ"  rc|jSz/The duration of this heartbeat in microseconds.)rwrs rrz&ServerHeartbeatSucceededEvent.durationrrc|jS)aAn instance of :class:`~pymongo.ismaster.IsMaster`. .. warning:: :class:`~pymongo.ismaster.IsMaster` is deprecated. Starting with PyMongo 4.0 this attribute will return an instance of :class:`~pymongo.hello.Hello`, which provides the same API. )rxrs rrz#ServerHeartbeatSucceededEvent.replys||rc|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. )ryrs rr{z%ServerHeartbeatSucceededEvent.awaited~~rc d|jjd|jd|jd|jd|j d SNrrz duration: z , awaited: z , reply: rrrrrr{rrs rrz&ServerHeartbeatSucceededEvent.__repr__7 NN # #    MM LL JJ   rF rrrrrrrrrr{rrrs@rrrrrsU 7I!  rrrc^eZdZdZdZdfd ZedZedZedZ dZ xZ S) ServerHeartbeatFailedEventzxFired when the server heartbeat fails, either with an "ok: 0" or a socket exception. .. versionadded:: 3.3 rscVtt| |||_||_||_yr})rrr%_ServerHeartbeatFailedEvent__duration"_ServerHeartbeatFailedEvent__reply$_ServerHeartbeatFailedEvent__awaitedrzs rrz#ServerHeartbeatFailedEvent.__init__s( ($8G"  rc|jSr})rrs rrz#ServerHeartbeatFailedEvent.duration rrc|jS)zA subclass of :exc:`Exception`.)rrs rrz ServerHeartbeatFailedEvent.replyrrc|jSr)rrs rr{z"ServerHeartbeatFailedEvent.awaitedrrc d|jjd|jd|jd|jd|j d Srrrs rrz#ServerHeartbeatFailedEvent.__repr__ rrrrrs@rrrsU 7I!  rrceZdZdZdZedZedZedZedZ 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|_yr})rar"_EventListeners__command_listenersr !_EventListeners__server_listenersr +_EventListeners__server_heartbeat_listenersr #_EventListeners__topology_listenersr _EventListeners__cmap_listenersrYrrbrMr>rCr&bool%_EventListeners__enabled_for_commands#_EventListeners__enabled_for_server-_EventListeners__enabled_for_server_heartbeat%_EventListeners__enabled_for_topology!_EventListeners__enabled_for_cmap)rr]lsts rrz_EventListeners.__init__3st#-#?#?#B ","="=a"@33,/F)$.$A$A!$D! * 9 9! <   6c?3,,33C8c>2++2237c#:;55<  $ $  - - .  # # $  % % & rNc||}t||||||}|jD]} |j|y#t$r t Y-wxYw)aPublish a CommandStartedEvent to all command listeners. :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. - `op_id`: The (optional) operation id for this operation. - `service_id`: The service_id this command was sent to, or ``None``. Nr)rrr Exceptionr) rrrrrop_idrr subscribers rpublish_command_startz%_EventListeners.publish_command_startnsg =E# ]J uQ[ 22 $J $""5) $ $!# $s:AAc ||}|ri}t|||||||} |jD]} | j| y#t$r t Y-wxYw)aPublish a CommandSucceededEvent to all command listeners. :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. - `op_id`: The (optional) operation id for this operation. - `service_id`: The service_id this command was sent to, or ``None``. - `speculative_hello`: Was the command sent with speculative auth? N)rrr!rr) rrrrrrrrrspeculative_hellorrs rpublish_command_successz'_EventListeners.publish_command_successsr0 =E E% e\:}eZ 22 $J $$$U+ $ $!# $s>AAc ||}t|||||||}|jD]} | j|y#t$r t Y-wxYw)acPublish a CommandFailedEvent to all command listeners. :Parameters: - `duration`: The command duration as a datetime.timedelta. - `failure`: The server reply document or failure description 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. - `op_id`: The (optional) operation id for this operation. - `service_id`: The service_id this command was sent to, or ``None``. Nr)rrr#rr) rrrrrrrrrrrs rpublish_command_failurez'_EventListeners.publish_command_failuresi. =E" g|ZZd 22 $J $!!%( $ $!# $s;AAct|}|jD]} |j|y#t$r t Y-wxYw)zPublish a ServerHeartbeatStartedEvent to all server heartbeat listeners. :Parameters: - `connection_id`: The address (host, port) pair of the connection. N)rprrrr)rrrrs r publish_server_heartbeat_startedz0_EventListeners.publish_server_heartbeat_startedsM,M:;; $J $""5) $ $!# $0AAct||||}|jD]} |j|y#t$r t Y-wxYw)aPublish a ServerHeartbeatSucceededEvent to all server heartbeat listeners. :Parameters: - `connection_id`: The address (host, port) pair of the connection. - `duration`: The execution time of the event in the highest possible resolution for the platform. - `reply`: The command reply. - `awaited`: True if the response was awaited. N)rrrr!rrrrrrr{rrs r"publish_server_heartbeat_succeededz2_EventListeners.publish_server_heartbeat_succeededsS.h}gV;; $J $$$U+ $ $!# $3A A ct||||}|jD]} |j|y#t$r t Y-wxYw)aPublish a ServerHeartbeatFailedEvent to all server heartbeat listeners. :Parameters: - `connection_id`: The address (host, port) pair of the connection. - `duration`: The execution time of the event in the highest possible resolution for the platform. - `reply`: The command reply. - `awaited`: True if the response was awaited. N)rrr#rrrs rpublish_server_heartbeat_failedz/_EventListeners.publish_server_heartbeat_failedsS+8UM7S;; $J $!!%( $ $!# $rct||}|jD]} |j|y#t$r t Y-wxYw)aPublish a ServerOpeningEvent 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)rQrrErrrr3r4rrs rpublish_server_openedz%_EventListeners.publish_server_openedsO#>;?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)rTrrIrrrs rpublish_server_closedz%_EventListeners.publish_server_closedsO".+>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<rrGrr)rrDrEr3r4rrs r"publish_server_description_changedz2_EventListeners.publish_server_description_changed!sX. />; 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)rerrErrrr4rrs rpublish_topology_openedz'_EventListeners.publish_topology_opened6M$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)rgrrIrrrs rpublish_topology_closedz'_EventListeners.publish_topology_closedDrrct|||}|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)r]rrGrr)rrDrEr4rrs r$publish_topology_description_changedz4_EventListeners.publish_topology_description_changedRsS00DoWbc33 $J $..u5 $ $!# $2AAct||}|jD]} |j|y#t$r t Y-wxYw)z:Publish a :class:`PoolCreatedEvent` to all pool listeners.N)rrr(rr)rrrrrs rpublish_pool_createdz$_EventListeners.publish_pool_createddsM '2// $J $''. $ $!# $rct||}|jD]} |j|y#t$r t Y-wxYw)z:Publish a :class:`PoolClearedEvent` to all pool listeners.N)rrr+rr)rrrrrs rpublish_pool_clearedz$_EventListeners.publish_pool_clearedmsM *5// $J $''. $ $!# $rct|}|jD]} |j|y#t$r t Y-wxYw)z9Publish a :class:`PoolClosedEvent` to all pool listeners.N)rrr-rrrrrrs rpublish_pool_closedz#_EventListeners.publish_pool_closedvsK(// $J $&&u- $ $!# $rct||}|jD]} |j|y#t$r t Y-wxYw)zWPublish a :class:`ConnectionCreatedEvent` to all connection listeners. N)r rr/rrrrrrrs rpublish_connection_createdz*_EventListeners.publish_connection_createdsO'w >// $J $--e4 $ $!# $rct||}|jD]} |j|y#t$r t Y-wxYw)zDPublish a :class:`ConnectionReadyEvent` to all connection listeners.N)rrr1rrrs rpublish_connection_readyz(_EventListeners.publish_connection_readysM$Wm<// $J $++E2 $ $!# $rct|||}|jD]} |j|y#t$r t Y-wxYw)zVPublish a :class:`ConnectionClosedEvent` to all connection listeners. N)rrr4rr)rrrrrrs 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)rrr6rrrs 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)r!rr6rr)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)r)rr:rrrs 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)r+rr<rrrs rpublish_connection_checked_inz-_EventListeners.publish_connection_checked_insO)-@// $J $007 $ $!# $r)NN)NNF)"rrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrr*s>2++))33++'' Y]$B%$\ $D $$$$$ $ $$* $ $$$$$$ $$ $ $ $ $ $rrN)7r collectionsrbson.py3compatrpymongo.hello_compatrpymongo.helpersr _Listenersraobjectrrr&r>rCrMrUr_rcsetrrtrvrrrrrrrrrrr rrrr!r)r+r-r<rQrTrVr]rergrirprrrrrrrrsOfP#,-   BB + 7V7"n"@t"^t"n"n"D"~"B"^"B+ 3<  "&F&R2 -2 j6 M6 r6 6 rDD&VzV2YzY> j FVF*V&^v^2-" + ! ,! HDVD4"WF"WJ  0  /  6 6 L D TFT" m D--IFI$"7. $9. b* !6* Z^$f^$r