3 O6b @sdZddlmZddlmZddlmZddlmZeddhZ e gggggZ Gd d d e Z Gddde Z Gddde ZGddde ZGddde ZGddde ZddZddZddZeddd d!d"d#d$d%d&g Zd'd(ZGd)d*d*e ZGd+d,d,eZGd-d.d.eZGd/d0d0eZGd1d2d2e ZGd3d4d4eZGd5d6d6eZGd7d8d8eZGd9d:d:e Z Gd;d<dd>e Z"Gd?d@d@e"Z#GdAdBdBe"Z$GdCdDdDe"Z%GdEdFdFe Z&GdGdHdHe Z'GdIdJdJe"Z(GdKdLdLe"Z)GdMdNdNe Z*GdOdPdPe*Z+GdQdRdRe*Z,GdSdTdTe*Z-GdUdVdVe Z.GdWdXdXe.Z/GdYdZdZe.Z0Gd[d\d\e.Z1Gd]d^d^e Z2Gd_d`d`e2Z3Gdadbdbe2Z4Gdcdddde2Z5Gdedfdfe Z6dgS)iaTools 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_exceptionZ Listenerscommand_listenersserver_listenersserver_heartbeat_listenerstopology_listenerscmap_listenersc@seZdZdZdS)_EventListenerz,Abstract base class for all event listeners.N)__name__ __module__ __qualname____doc__rrQ/var/www/html/sandeepIITI/myenv/lib/python3.6/site-packages/pymongo/monitoring.pyr sr c@s(eZdZdZddZddZddZdS) CommandListenerzAbstract base class for command listeners. Handles `CommandStartedEvent`, `CommandSucceededEvent`, and `CommandFailedEvent`. cCstdS)zAbstract method to handle a `CommandStartedEvent`. :Parameters: - `event`: An instance of :class:`CommandStartedEvent`. N)NotImplementedError)selfeventrrrstartedszCommandListener.startedcCstdS)zAbstract method to handle a `CommandSucceededEvent`. :Parameters: - `event`: An instance of :class:`CommandSucceededEvent`. N)r)rrrrr succeededszCommandListener.succeededcCstdS)zAbstract method to handle a `CommandFailedEvent`. :Parameters: - `event`: An instance of :class:`CommandFailedEvent`. N)r)rrrrrfailedszCommandListener.failedN)r r rrrrrrrrrrsrc@s`eZdZdZddZddZddZdd Zd d Zd d Z ddZ ddZ ddZ ddZ dS)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 cCstdS)zAbstract method to handle a :class:`PoolCreatedEvent`. Emitted when a Connection Pool is created. :Parameters: - `event`: An instance of :class:`PoolCreatedEvent`. N)r)rrrrr pool_createdsz#ConnectionPoolListener.pool_createdcCstdS)zAbstract method to handle a `PoolClearedEvent`. Emitted when a Connection Pool is cleared. :Parameters: - `event`: An instance of :class:`PoolClearedEvent`. N)r)rrrrr pool_clearedsz#ConnectionPoolListener.pool_clearedcCstdS)zAbstract method to handle a `PoolClosedEvent`. Emitted when a Connection Pool is closed. :Parameters: - `event`: An instance of :class:`PoolClosedEvent`. N)r)rrrrr pool_closed sz"ConnectionPoolListener.pool_closedcCstdS)zAbstract method to handle a :class:`ConnectionCreatedEvent`. Emitted when a Connection Pool creates a Connection object. :Parameters: - `event`: An instance of :class:`ConnectionCreatedEvent`. N)r)rrrrrconnection_createdsz)ConnectionPoolListener.connection_createdcCstdS)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`. N)r)rrrrrconnection_ready!s z'ConnectionPoolListener.connection_readycCstdS)zAbstract method to handle a :class:`ConnectionClosedEvent`. Emitted when a Connection Pool closes a Connection. :Parameters: - `event`: An instance of :class:`ConnectionClosedEvent`. N)r)rrrrrconnection_closed,sz(ConnectionPoolListener.connection_closedcCstdS)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`. N)r)rrrrrconnection_check_out_started6sz3ConnectionPoolListener.connection_check_out_startedcCstdS)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`. N)r)rrrrrconnection_check_out_failed@sz2ConnectionPoolListener.connection_check_out_failedcCstdS)zAbstract method to handle a :class:`ConnectionCheckedOutEvent`. Emitted when the driver successfully checks out a Connection. :Parameters: - `event`: An instance of :class:`ConnectionCheckedOutEvent`. N)r)rrrrrconnection_checked_outJsz-ConnectionPoolListener.connection_checked_outcCstdS)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`. N)r)rrrrrconnection_checked_inTs z,ConnectionPoolListener.connection_checked_inN)r r rrrrrrrrr r!r"r#rrrrrs         rc@s(eZdZdZddZddZddZdS) ServerHeartbeatListenerzAbstract base class for server heartbeat listeners. Handles `ServerHeartbeatStartedEvent`, `ServerHeartbeatSucceededEvent`, and `ServerHeartbeatFailedEvent`. .. versionadded:: 3.3 cCstdS)zAbstract method to handle a `ServerHeartbeatStartedEvent`. :Parameters: - `event`: An instance of :class:`ServerHeartbeatStartedEvent`. N)r)rrrrrriszServerHeartbeatListener.startedcCstdS)zAbstract method to handle a `ServerHeartbeatSucceededEvent`. :Parameters: - `event`: An instance of :class:`ServerHeartbeatSucceededEvent`. N)r)rrrrrrqsz!ServerHeartbeatListener.succeededcCstdS)zAbstract method to handle a `ServerHeartbeatFailedEvent`. :Parameters: - `event`: An instance of :class:`ServerHeartbeatFailedEvent`. N)r)rrrrrryszServerHeartbeatListener.failedN)r r rrrrrrrrrr$`sr$c@s(eZdZdZddZddZddZdS) TopologyListenerzAbstract base class for topology monitoring listeners. Handles `TopologyOpenedEvent`, `TopologyDescriptionChangedEvent`, and `TopologyClosedEvent`. .. versionadded:: 3.3 cCstdS)zAbstract method to handle a `TopologyOpenedEvent`. :Parameters: - `event`: An instance of :class:`TopologyOpenedEvent`. N)r)rrrrropenedszTopologyListener.openedcCstdS)zAbstract method to handle a `TopologyDescriptionChangedEvent`. :Parameters: - `event`: An instance of :class:`TopologyDescriptionChangedEvent`. N)r)rrrrrdescription_changedsz$TopologyListener.description_changedcCstdS)zAbstract method to handle a `TopologyClosedEvent`. :Parameters: - `event`: An instance of :class:`TopologyClosedEvent`. N)r)rrrrrclosedszTopologyListener.closedN)r r rrr&r'r(rrrrr%sr%c@s(eZdZdZddZddZddZdS) ServerListenerzAbstract base class for server listeners. Handles `ServerOpeningEvent`, `ServerDescriptionChangedEvent`, and `ServerClosedEvent`. .. versionadded:: 3.3 cCstdS)zAbstract method to handle a `ServerOpeningEvent`. :Parameters: - `event`: An instance of :class:`ServerOpeningEvent`. N)r)rrrrrr&szServerListener.openedcCstdS)zAbstract method to handle a `ServerDescriptionChangedEvent`. :Parameters: - `event`: An instance of :class:`ServerDescriptionChangedEvent`. N)r)rrrrrr'sz"ServerListener.description_changedcCstdS)zAbstract method to handle a `ServerClosedEvent`. :Parameters: - `event`: An instance of :class:`ServerClosedEvent`. N)r)rrrrrr(szServerListener.closedN)r r rrr&r'r(rrrrr)sr)cCst|jdS)z'Convert duration 'dur' to microseconds.g.A)int total_seconds)Zdurrrr _to_microssr,cCsDt|tjstd|fx$|D]}t|ts td|fq W|S)zValidate event listenersz%s must be a list or tuplezListeners for %s must be either a CommandListener, ServerHeartbeatListener, ServerListener, TopologyListener, or ConnectionPoolListener.) isinstancerSequence TypeErrorr )option listenerslistenerrrr_validate_event_listenerss   r3cCst|tstd|ft|tr.tjj|t|trDtjj|t|t rZtj j|t|t rptj j|t|t rtjj|dS)aRegister a global event listener. :Parameters: - `listener`: A subclasses of :class:`CommandListener`, :class:`ServerHeartbeatListener`, :class:`ServerListener`, :class:`TopologyListener`, or :class:`ConnectionPoolListener`. zListeners for %s must be either a CommandListener, ServerHeartbeatListener, ServerListener, TopologyListener, or ConnectionPoolListener.N)r-r r/r _LISTENERSrappendr$rr)rr%r rr )r2rrrregisters           r6Z authenticateZ saslstartZ saslcontinueZgetnonceZ createuserZ updateuserZcopydbgetnonceZcopydbsaslstartZcopydbcCs"|jdtjfkrd|krdSdS)NZhelloZspeculativeAuthenticateTF)lowerrZ LEGACY_CMD) command_namedocrrr_is_speculative_authenticatesr:c@sZeZdZdZdZddd Zed d Zed d ZeddZ eddZ eddZ dS) _CommandEventzBase class for command events. __cmd_name __rqst_id __conn_id__op_id __service_idNcCs"||_||_||_||_||_dS)N)_CommandEvent__cmd_name_CommandEvent__rqst_id_CommandEvent__conn_id_CommandEvent__op_id_CommandEvent__service_id)rr8 request_id connection_id operation_id service_idrrr__init__s z_CommandEvent.__init__cCs|jS)zThe command name.)rA)rrrrr8 sz_CommandEvent.command_namecCs|jS)z"The request id for this operation.)rB)rrrrrFsz_CommandEvent.request_idcCs|jS)z@The address (host, port) of the server this command was sent to.)rC)rrrrrGsz_CommandEvent.connection_idcCs|jS)z^The service_id this command was sent to, or ``None``. .. versionadded:: 3.12 )rE)rrrrrIsz_CommandEvent.service_idcCs|jS)z(An id for this series of events or None.)rD)rrrrrH$sz_CommandEvent.operation_id)r<r=r>r?r@)N) r r rr __slots__rJpropertyr8rFrGrIrHrrrrr;s     r;csFeZdZdZd Zdfdd ZeddZed d Zd d Z Z 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__dbNc st|std|ftt|}tt|j|||||d|j||}} |tks\t||rdi|_ n||_ ||_ dS)Nz%r is not a valid command)rI) ValueErrornextitersuperrMrJr7_SENSITIVE_COMMANDSr:_CommandStartedEvent__cmd_CommandStartedEvent__db) rcommand database_namerFrGrHrIr8cmd_nameZcmd_doc) __class__rrrJ8s   zCommandStartedEvent.__init__cCs|jS)zThe command document.)rU)rrrrrWIszCommandStartedEvent.commandcCs|jS)z6The name of the database this command was run against.)rV)rrrrrXNsz!CommandStartedEvent.database_namecCs"d|jj|j|j|j|j|jfS)Nz=<%s %s db: %r, command: %r, operation_id: %s, service_id: %s>)rZr rGrXr8rHrI)rrrr__repr__Ss  zCommandStartedEvent.__repr__)rNrO)N) r r rrrKrJrLrWrXr[ __classcell__rr)rZrrM*s    rMcsFeZdZdZd Zdfdd ZeddZed d Zd d Z Z 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__replyNc sPtt|j|||||dt||_|j}|tks>t||rFi|_n||_dS)N)rI) rSr]rJr,'_CommandSucceededEvent__duration_microsr7rTr:_CommandSucceededEvent__reply) rdurationreplyr8rFrGrHrIrY)rZrrrJks   zCommandSucceededEvent.__init__cCs|jS)z/The duration of this operation in microseconds.)r`)rrrrduration_microsxsz%CommandSucceededEvent.duration_microscCs|jS)z/The server failure document for this operation.)ra)rrrrrc}szCommandSucceededEvent.replycCs"d|jj|j|j|j|j|jfS)NzJ<%s %s command: %r, operation_id: %s, duration_micros: %s, service_id: %s>)rZr rGr8rHrdrI)rrrrr[s  zCommandSucceededEvent.__repr__)r^r_)N) r r rrrKrJrLrdrcr[r\rr)rZrr]\s    r]csFeZdZdZd Zdfdd ZeddZed d Zd d Z Z 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^ __failureNcs.tt|j|||||dt||_||_dS)N)rI)rSrerJr,$_CommandFailedEvent__duration_micros_CommandFailedEvent__failure)rrbfailurer8rFrGrHrI)rZrrrJs   zCommandFailedEvent.__init__cCs|jS)z/The duration of this operation in microseconds.)rg)rrrrrdsz"CommandFailedEvent.duration_microscCs|jS)z/The server failure document for this operation.)rh)rrrrriszCommandFailedEvent.failurecCs&d|jj|j|j|j|j|j|jfS)NzW<%s %s command: %r, operation_id: %s, duration_micros: %s, failure: %r, service_id: %s>)rZr rGr8rHrdrirI)rrrrr[s zCommandFailedEvent.__repr__)r^rf)N) r r rrrKrJrLrdrir[r\rr)rZrres    rec@s0eZdZdZd ZddZeddZddZd S) _PoolEventzBase class for pool events. __addresscCs ||_dS)N)_PoolEvent__address)raddressrrrrJsz_PoolEvent.__init__cCs|jS)zbThe address (host, port) pair of the server the pool is attempting to connect to. )rl)rrrrrmsz_PoolEvent.addresscCsd|jj|jfS)Nz%s(%r))rZr rl)rrrrr[sz_PoolEvent.__repr__N)rk) r r rrrKrJrLrmr[rrrrrjs  rjcs8eZdZdZd ZfddZeddZddZZ 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 __optionscstt|j|||_dS)N)rSrnrJ_PoolCreatedEvent__options)rrmoptions)rZrrrJszPoolCreatedEvent.__init__cCs|jS)zLAny non-default pool options that were set on this Connection Pool. )rp)rrrrrqszPoolCreatedEvent.optionscCsd|jj|j|jfS)Nz %s(%r, %r))rZr rmrp)rrrrr[szPoolCreatedEvent.__repr__)ro) r r rrrKrJrLrqr[r\rr)rZrrns   rncs:eZdZdZd Zd fdd ZeddZdd ZZ 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@Ncstt|j|||_dS)N)rSrrrJ_PoolClearedEvent__service_id)rrmrI)rZrrrJszPoolClearedEvent.__init__cCs|jS)zConnections with this service_id are cleared. When service_id is ``None``, all connections in the pool are cleared. .. versionadded:: 3.12 )rs)rrrrrIszPoolClearedEvent.service_idcCsd|jj|j|jfS)Nz %s(%r, %r))rZr rmrs)rrrrr[szPoolClearedEvent.__repr__)r@)N) r r rrrKrJrLrIr[r\rr)rZrrrs   rrc@seZdZdZfZdS)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 N)r r rrrKrrrrrtsrtc@s eZdZdZdZdZdZdZdS)ConnectionClosedReasonzqAn enum that defines values for `reason` on a :class:`ConnectionClosedEvent`. .. versionadded:: 3.9 staleidleerror poolClosedN)r r rrZSTALEZIDLEERROR POOL_CLOSEDrrrrru s ruc@seZdZdZdZdZdZdS)ConnectionCheckOutFailedReasonzyAn enum that defines values for `reason` on a :class:`ConnectionCheckOutFailedEvent`. .. versionadded:: 3.9 timeoutryZconnectionErrorN)r r rrTIMEOUTr{Z CONN_ERRORrrrrr|!s r|c@s<eZdZdZd ZddZeddZedd Zd d Z d S)_ConnectionEventz.Private base class for some connection events.rk__connection_idcCs||_||_dS)N)_ConnectionEvent__address_ConnectionEvent__connection_id)rrmrGrrrrJ8sz_ConnectionEvent.__init__cCs|jS)ziThe address (host, port) pair of the server this connection is attempting to connect to. )r)rrrrrm<sz_ConnectionEvent.addresscCs|jS)zThe ID of the Connection.)r)rrrrrGCsz_ConnectionEvent.connection_idcCsd|jj|j|jfS)Nz %s(%r, %r))rZr rr)rrrrr[Hsz_ConnectionEvent.__repr__N)rkr) r r rrrKrJrLrmrGr[rrrrr4s   rc@seZdZdZfZdS)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 N)r r rrrKrrrrrMs rc@seZdZdZfZdS)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 N)r r rrrKrrrrr]s rcs8eZdZdZd ZfddZeddZddZZ 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 __reasoncstt|j||||_dS)N)rSrrJ_ConnectionClosedEvent__reason)rrmrGreason)rZrrrJwszConnectionClosedEvent.__init__cCs|jS)zA reason explaining why this connection was closed. The reason must be one of the strings from the :class:`ConnectionClosedReason` enum. )r)rrrrr{szConnectionClosedEvent.reasoncCsd|jj|j|j|jfS)Nz%s(%r, %r, %r))rZr rmrGr)rrrrr[szConnectionClosedEvent.__repr__)r) r r rrrKrJrLrr[r\rr)rZrrjs    rc@s0eZdZdZd ZddZeddZddZd S) 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 rkcCs ||_dS)N)(_ConnectionCheckOutStartedEvent__address)rrmrrrrJsz'ConnectionCheckOutStartedEvent.__init__cCs|jS)ziThe address (host, port) pair of the server this connection is attempting to connect to. )r)rrrrrmsz&ConnectionCheckOutStartedEvent.addresscCsd|jj|jfS)Nz%s(%r))rZr r)rrrrr[sz'ConnectionCheckOutStartedEvent.__repr__N)rk) r r rrrKrJrLrmr[rrrrrs  rc@s<eZdZdZd ZddZeddZedd Zd d Z d S)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 rkrcCs||_||_dS)N)'_ConnectionCheckOutFailedEvent__address&_ConnectionCheckOutFailedEvent__reason)rrmrrrrrJsz&ConnectionCheckOutFailedEvent.__init__cCs|jS)ziThe address (host, port) pair of the server this connection is attempting to connect to. )r)rrrrrmsz%ConnectionCheckOutFailedEvent.addresscCs|jS)zA reason explaining why connection check out failed. The reason must be one of the strings from the :class:`ConnectionCheckOutFailedReason` enum. )r)rrrrrsz$ConnectionCheckOutFailedEvent.reasoncCsd|jj|j|jfS)Nz %s(%r, %r))rZr rr)rrrrr[sz&ConnectionCheckOutFailedEvent.__repr__N)rkr) r r rrrKrJrLrmrr[rrrrrs    rc@seZdZdZfZdS)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 N)r r rrrKrrrrrs rc@seZdZdZfZdS)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 N)r r rrrKrrrrrs rc@s<eZdZdZd ZddZeddZedd Zd d Z d S) _ServerEventzBase class for server events.__server_address __topology_idcCs||_||_dS)N)_ServerEvent__server_address_ServerEvent__topology_id)rserver_address topology_idrrrrJsz_ServerEvent.__init__cCs|jS)z+The address (host, port) pair of the server)r)rrrrrsz_ServerEvent.server_addresscCs|jS)z>A unique identifier for the topology this server is a part of.)r)rrrrrsz_ServerEvent.topology_idcCsd|jj|j|jfS)Nz<%s %s topology_id: %s>)rZr rr)rrrrr[sz_ServerEvent.__repr__N)rr) r r rrrKrJrLrrr[rrrrrs   rcsDeZdZdZd ZfddZeddZedd Zd d Z Z S) ServerDescriptionChangedEventzJPublished when server description changes. .. versionadded:: 3.3 __previous_description__new_descriptioncs tt|j|||_||_dS)N)rSrrJ4_ServerDescriptionChangedEvent__previous_description/_ServerDescriptionChangedEvent__new_description)rprevious_descriptionnew_descriptionargs)rZrrrJsz&ServerDescriptionChangedEvent.__init__cCs|jS)zLThe previous :class:`~pymongo.server_description.ServerDescription`.)r)rrrrrsz2ServerDescriptionChangedEvent.previous_descriptioncCs|jS)zGThe new :class:`~pymongo.server_description.ServerDescription`.)r)rrrrr sz-ServerDescriptionChangedEvent.new_descriptioncCsd|jj|j|j|jfS)Nz <%s %s changed from: %s, to: %s>)rZr rrr)rrrrr[s z&ServerDescriptionChangedEvent.__repr__)rr) r r rrrKrJrLrrr[r\rr)rZrrs    rc@seZdZdZfZdS)ServerOpeningEventzEPublished when server is initialized. .. versionadded:: 3.3 N)r r rrrKrrrrrsrc@seZdZdZfZdS)ServerClosedEventz@Published when server is closed. .. versionadded:: 3.3 N)r r rrrKrrrrr"src@s0eZdZdZdZddZeddZddZd S) TopologyEventz+Base class for topology description events.rcCs ||_dS)N)_TopologyEvent__topology_id)rrrrrrJ0szTopologyEvent.__init__cCs|jS)z>A unique identifier for the topology this server is a part of.)r)rrrrr3szTopologyEvent.topology_idcCsd|jj|jfS)Nz<%s topology_id: %s>)rZr r)rrrrr[8szTopologyEvent.__repr__N) r r rrrKrJrLrr[rrrrr+s  rcsDeZdZdZd ZfddZeddZedd Zd d Z Z S) TopologyDescriptionChangedEventzPPublished when the topology description changes. .. versionadded:: 3.3 rrcs tt|j|||_||_dS)N)rSrrJ6_TopologyDescriptionChangedEvent__previous_description1_TopologyDescriptionChangedEvent__new_description)rrrr)rZrrrJEsz(TopologyDescriptionChangedEvent.__init__cCs|jS)zPThe previous :class:`~pymongo.topology_description.TopologyDescription`.)r)rrrrrJsz4TopologyDescriptionChangedEvent.previous_descriptioncCs|jS)zKThe new :class:`~pymongo.topology_description.TopologyDescription`.)r)rrrrrPsz/TopologyDescriptionChangedEvent.new_descriptioncCsd|jj|j|j|jfS)Nz-<%s topology_id: %s changed from: %s, to: %s>)rZr rrr)rrrrr[Vs z(TopologyDescriptionChangedEvent.__repr__)rr) r r rrrKrJrLrrr[r\rr)rZrr=s    rc@seZdZdZfZdS)TopologyOpenedEventzKPublished when the topology is initialized. .. versionadded:: 3.3 N)r r rrrKrrrrr\src@seZdZdZfZdS)TopologyClosedEventzFPublished when the topology is closed. .. versionadded:: 3.3 N)r r rrrKrrrrresrc@s0eZdZdZdZddZeddZddZd S) _ServerHeartbeatEventz'Base class for server heartbeat events.rcCs ||_dS)N)$_ServerHeartbeatEvent__connection_id)rrGrrrrJssz_ServerHeartbeatEvent.__init__cCs|jS)zJThe address (host, port) of the server this heartbeat was sent to.)r)rrrrrGvsz#_ServerHeartbeatEvent.connection_idcCsd|jj|jfS)Nz<%s %s>)rZr rG)rrrrr[|sz_ServerHeartbeatEvent.__repr__N) r r rrrKrJrLrGr[rrrrrns  rc@seZdZdZfZdS)ServerHeartbeatStartedEventzFPublished when a heartbeat is started. .. versionadded:: 3.3 N)r r rrrKrrrrrsrcsReZdZdZdZdfdd Zedd Zed d Zed d Z ddZ Z S)ServerHeartbeatSucceededEventzIFired when the server heartbeat succeeds. .. versionadded:: 3.3 __durationr_ __awaitedFcs&tt|j|||_||_||_dS)N)rSrrJ(_ServerHeartbeatSucceededEvent__duration%_ServerHeartbeatSucceededEvent__reply'_ServerHeartbeatSucceededEvent__awaited)rrbrcrGawaited)rZrrrJsz&ServerHeartbeatSucceededEvent.__init__cCs|jS)z/The duration of this heartbeat in microseconds.)r)rrrrrbsz&ServerHeartbeatSucceededEvent.durationcCs|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. )r)rrrrrcsz#ServerHeartbeatSucceededEvent.replycCs|jS)zWhether 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. )r)rrrrrsz%ServerHeartbeatSucceededEvent.awaitedcCsd|jj|j|j|j|jfS)Nz,<%s %s duration: %s, awaited: %s, reply: %s>)rZr rGrbrrc)rrrrr[s z&ServerHeartbeatSucceededEvent.__repr__)rr_r)F) r r rrrKrJrLrbrcrr[r\rr)rZrrs  rcsReZdZdZdZdfdd Zedd Zed d Zed d Z ddZ Z S)ServerHeartbeatFailedEventzxFired when the server heartbeat fails, either with an "ok: 0" or a socket exception. .. versionadded:: 3.3 rr_rFcs&tt|j|||_||_||_dS)N)rSrrJ%_ServerHeartbeatFailedEvent__duration"_ServerHeartbeatFailedEvent__reply$_ServerHeartbeatFailedEvent__awaited)rrbrcrGr)rZrrrJsz#ServerHeartbeatFailedEvent.__init__cCs|jS)z/The duration of this heartbeat in microseconds.)r)rrrrrbsz#ServerHeartbeatFailedEvent.durationcCs|jS)zA subclass of :exc:`Exception`.)r)rrrrrcsz ServerHeartbeatFailedEvent.replycCs|jS)zWhether 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. )r)rrrrrsz"ServerHeartbeatFailedEvent.awaitedcCsd|jj|j|j|j|jfS)Nz,<%s %s duration: %s, awaited: %s, reply: %r>)rZr rGrbrrc)rrrrr[s z#ServerHeartbeatFailedEvent.__repr__)rr_r)F) r r rrrKrJrLrbrcrr[r\rr)rZrrs   rc@seZdZdZddZeddZeddZedd Zed d Z ed d Z ddZ d>ddZ d?ddZ d@ddZddZddZddZddZd d!Zd"d#Zd$d%Zd&d'Zd(d)Zd*d+Zd,d-Zd.d/Zd0d1Zd2d3Zd4d5Zd6d7Zd8d9Zd:d;Z dtYqXqWdS)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)rrr&rr)rrrrrrrrpublish_server_openeds   z%_EventListeners.publish_server_openedc CsHt||}x8|jD].}y|j|Wqtk r>tYqXqWdS)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)rrr(rr)rrrrrrrrpublish_server_closeds   z%_EventListeners.publish_server_closedc CsLt||||}x8|jD].}y|j|Wqtk rBtYqXqWdS)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)rrr'rr)rrrrrrrrrr"publish_server_description_changeds  z2_EventListeners.publish_server_description_changedc CsFt|}x8|jD].}y|j|Wqtk r<tYqXqWdS)zPublish a TopologyOpenedEvent to all topology listeners. :Parameters: - `topology_id`: A unique identifier for the topology this server is a part of. N)rrr&rr)rrrrrrrpublish_topology_openeds  z'_EventListeners.publish_topology_openedc CsFt|}x8|jD].}y|j|Wqtk r<tYqXqWdS)zPublish a TopologyClosedEvent to all topology listeners. :Parameters: - `topology_id`: A unique identifier for the topology this server is a part of. N)rrr(rr)rrrrrrrpublish_topology_closeds  z'_EventListeners.publish_topology_closedc CsJt|||}x8|jD].}y|j|Wqtk r@tYqXqWdS)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)rrr'rr)rrrrrrrrr$publish_topology_description_changeds  z4_EventListeners.publish_topology_description_changedc CsHt||}x8|jD].}y|j|Wqtk r>tYqXqWdS)zCPublish a :class:`PoolCreatedEvent` to all pool listeners. N)rnrrrr)rrmrqrrrrrpublish_pool_created s   z$_EventListeners.publish_pool_createdc CsHt||}x8|jD].}y|j|Wqtk r>tYqXqWdS)zCPublish a :class:`PoolClearedEvent` to all pool listeners. N)rrrrrr)rrmrIrrrrrpublish_pool_cleareds   z$_EventListeners.publish_pool_clearedc CsFt|}x8|jD].}y|j|Wqtk r<tYqXqWdS)zBPublish a :class:`PoolClosedEvent` to all pool listeners. N)rtrrrr)rrmrrrrrpublish_pool_closed!s  z#_EventListeners.publish_pool_closedc CsHt||}x8|jD].}y|j|Wqtk r>tYqXqWdS)zWPublish a :class:`ConnectionCreatedEvent` to all connection listeners. N)rrrrr)rrmrGrrrrrpublish_connection_created+s   z*_EventListeners.publish_connection_createdc CsHt||}x8|jD].}y|j|Wqtk r>tYqXqWdS)zMPublish a :class:`ConnectionReadyEvent` to all connection listeners. N)rrrrr)rrmrGrrrrrpublish_connection_ready6s   z(_EventListeners.publish_connection_readyc CsJt|||}x8|jD].}y|j|Wqtk r@tYqXqWdS)zVPublish a :class:`ConnectionClosedEvent` to all connection listeners. N)rrrrr)rrmrGrrrrrrpublish_connection_closed@s   z)_EventListeners.publish_connection_closedc CsFt|}x8|jD].}y|j|Wqtk r<tYqXqWdS)z_Publish a :class:`ConnectionCheckOutStartedEvent` to all connection listeners. N)rrr rr)rrmrrrrr$publish_connection_check_out_startedKs  z4_EventListeners.publish_connection_check_out_startedc CsHt||}x8|jD].}y|j|Wqtk r>tYqXqWdS)z^Publish a :class:`ConnectionCheckOutFailedEvent` to all connection listeners. N)rrr rr)rrmrrrrrr#publish_connection_check_out_failedVs   z3_EventListeners.publish_connection_check_out_failedc CsHt||}x8|jD].}y|j|Wqtk r>tYqXqWdS)zZPublish a :class:`ConnectionCheckedOutEvent` to all connection listeners. N)rrr"rr)rrmrGrrrrrpublish_connection_checked_outas   z._EventListeners.publish_connection_checked_outc CsHt||}x8|jD].}y|j|Wqtk r>tYqXqWdS)zYPublish a :class:`ConnectionCheckedInEvent` to all connection listeners. N)rrr#rr)rrmrGrrrrrpublish_connection_checked_inls   z-_EventListeners.publish_connection_checked_in)NN)NNF)NN)"r r rrrJrLrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrsD                 rN)rrrr r )7r collectionsrZbson.py3compatrZpymongo.hello_compatrZpymongo.helpersrZ _Listenersr4objectr rrr$r%r)r,r3r6setrTr:r;rMr]rerjrnrrrtrur|rrrrrrrrrrrrrrrrrrrrrrrrrsj     w"!!  +2/*   %       -)