+ 4O|jApRt^RIHt^RIt^RIHtHt^RIHtH t H t H t H t ^RI Ht^RIHtHt^RIHtHt^RIHtHt]'d^R IHt^R IHt^R IHt]!R Re4t]!.....4t!R R4t!RR]4t !RR]4t!!RR]4t"!RR]4t#!RR]4t$RRlt%RRlt&RRlt'RR lt(!R!R"4t)!R#R$])4t*!R%R&])4t+!R'R(])4t,!R)R*4t-!R+R,]-4t.!R-R.]-4t/!R/R0]-4t0!R1R2]-4t1!R3R44t2!R5R64t3!R7R84t4!R9R:]44t5!R;R<]54t6!R=R>]54t7!R?R@]64t8!RARB]54t9!RCRD]44t:!RERF]64t;!RGRH]64t<!RIRJ]54t=!RKRL4t>!RMRN]>4t?!RORP]>4t@!RQRR]>4tA!RSRT4tB!RURV]B4tC!RWRX]B4tD!RYRZ]B4tE!R[R\4tF!R]R^]F4tG!R_R`]F4tH!RaRb]F4tI!RcRd4tJR#)faTools 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. .. seealso:: This module is compatible with both the synchronous and asynchronous PyMongo APIs. Use :func:`register` to register global listeners for specific events. Listeners must inherit from one of the abstract classes below and implement the correct functions for that class. For example, a simple command logger might be implemented like this:: import logging from pymongo import monitoring class CommandLogger(monitoring.CommandListener): def started(self, event): logging.info("Command {0.command_name} with request id " "{0.request_id} started on server " "{0.connection_id}".format(event)) def succeeded(self, event): logging.info("Command {0.command_name} with request id " "{0.request_id} on server {0.connection_id} " "succeeded in {0.duration_micros} " "microseconds".format(event)) def failed(self, event): logging.info("Command {0.command_name} with request id " "{0.request_id} on server {0.connection_id} " "failed in {0.duration_micros} " "microseconds".format(event)) monitoring.register(CommandLogger()) Server discovery and monitoring events are also available. For example:: class ServerLogger(monitoring.ServerListener): def opened(self, event): logging.info("Server {0.server_address} added to topology " "{0.topology_id}".format(event)) def description_changed(self, event): previous_server_type = event.previous_description.server_type new_server_type = event.new_description.server_type if new_server_type != previous_server_type: # server_type_name was added in PyMongo 3.4 logging.info( "Server {0.server_address} changed type from " "{0.previous_description.server_type_name} to " "{0.new_description.server_type_name}".format(event)) def closed(self, event): logging.warning("Server {0.server_address} removed from topology " "{0.topology_id}".format(event)) class HeartbeatLogger(monitoring.ServerHeartbeatListener): def started(self, event): logging.info("Heartbeat sent to server " "{0.connection_id}".format(event)) def succeeded(self, event): # The reply.document attribute was added in PyMongo 3.4. logging.info("Heartbeat to server {0.connection_id} " "succeeded with reply " "{0.reply.document}".format(event)) def failed(self, event): logging.warning("Heartbeat to server {0.connection_id} " "failed with error {0.reply}".format(event)) class TopologyLogger(monitoring.TopologyListener): def opened(self, event): logging.info("Topology with id {0.topology_id} " "opened".format(event)) def description_changed(self, event): logging.info("Topology description updated for " "topology id {0.topology_id}".format(event)) previous_topology_type = event.previous_description.topology_type new_topology_type = event.new_description.topology_type if new_topology_type != previous_topology_type: # topology_type_name was added in PyMongo 3.4 logging.info( "Topology {0.topology_id} changed type from " "{0.previous_description.topology_type_name} to " "{0.new_description.topology_type_name}".format(event)) # The has_writable_server and has_readable_server methods # were added in PyMongo 3.4. if not event.new_description.has_writable_server(): logging.warning("No writable servers available.") if not event.new_description.has_readable_server(): logging.warning("No readable servers available.") def closed(self, event): logging.info("Topology with id {0.topology_id} " "closed".format(event)) Connection monitoring and pooling events are also available. For example:: class ConnectionPoolLogger(ConnectionPoolListener): def pool_created(self, event): logging.info("[pool {0.address}] pool created".format(event)) def pool_ready(self, event): logging.info("[pool {0.address}] pool is ready".format(event)) def pool_cleared(self, event): logging.info("[pool {0.address}] pool cleared".format(event)) def pool_closed(self, event): logging.info("[pool {0.address}] pool closed".format(event)) def connection_created(self, event): logging.info("[pool {0.address}][connection #{0.connection_id}] " "connection created".format(event)) def connection_ready(self, event): logging.info("[pool {0.address}][connection #{0.connection_id}] " "connection setup succeeded".format(event)) def connection_closed(self, event): logging.info("[pool {0.address}][connection #{0.connection_id}] " "connection closed, reason: " "{0.reason}".format(event)) def connection_check_out_started(self, event): logging.info("[pool {0.address}] connection check out " "started".format(event)) def connection_check_out_failed(self, event): logging.info("[pool {0.address}] connection check out " "failed, reason: {0.reason}".format(event)) def connection_checked_out(self, event): logging.info("[pool {0.address}][connection #{0.connection_id}] " "connection checked out of pool".format(event)) def connection_checked_in(self, event): logging.info("[pool {0.address}][connection #{0.connection_id}] " "connection checked into pool".format(event)) Event listeners can also be registered per instance of :class:`~pymongo.mongo_client.MongoClient`:: client = MongoClient(event_listeners=[CommandLogger()]) Note that previously registered global listeners are automatically included when configuring per client event listeners. Registering a new global listener will not add that listener to existing client instances. .. note:: Events are delivered **synchronously**. Application threads block waiting for event handlers (e.g. :meth:`~CommandListener.started`) to return. Care must be taken to ensure that your event handlers are efficient enough to not adversely affect overall application performance. .. warning:: The command documents published through this API are *not* copies. If you intend to modify them in any way you must copy them in your event handler first. ) annotationsN)abc namedtuple) TYPE_CHECKINGAnyMappingOptionalSequence)ObjectId)Hello HelloCompat)_SENSITIVE_COMMANDS_handle_exception)_Address _DocumentOut) timedelta)ServerDescription)TopologyDescription _Listenersc]tRt^tRtRtR#)_EventListenerz,Abstract base class for all event listeners.N)__name__ __module__ __qualname____firstlineno____doc____static_attributes__rKC:\Users\alokc\chatbot\backend\venv\Lib\site-packages\pymongo/monitoring.pyrrs6rrc>]tRt^tRtRRltRRltRRltRtR #) CommandListenerz~Abstract base class for command listeners. Handles `CommandStartedEvent`, `CommandSucceededEvent`, and `CommandFailedEvent`. c V^8dQhRRRR/#)eventCommandStartedEventreturnNoner)formats"r __annotate__CommandListener.__annotate__s""0"T"rc \h)zoAbstract method to handle a `CommandStartedEvent`. :param event: An instance of :class:`CommandStartedEvent`. NotImplementedErrorselfr$s&&rstartedCommandListener.started "!rc V^8dQhRRRR/#)r#r$CommandSucceededEventr&r'r)r(s"rr)r*s""4""rc \h)zsAbstract method to handle a `CommandSucceededEvent`. :param event: An instance of :class:`CommandSucceededEvent`. r,r.s&&r succeededCommandListener.succeededr2rc V^8dQhRRRR/#)r#r$CommandFailedEventr&r'r)r(s"rr)r*""."4"rc \h)zmAbstract method to handle a `CommandFailedEvent`. :param event: An instance of :class:`CommandFailedEvent`. r,r.s&&rfailedCommandListener.failedr2rrN rrrrrr0r6r<rrrrr!r!s """"rr!c]tRt^tRtRRltRRltRRltRR ltR R lt R R lt RRlt RRlt RRlt RRltRRltRtR#)ConnectionPoolListeneraAbstract 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 c V^8dQhRRRR/#)r#r$PoolCreatedEventr&r'r)r(s"rr)#ConnectionPoolListener.__annotate__"""2"t"rc \h)zAbstract method to handle a :class:`PoolCreatedEvent`. Emitted when a connection Pool is created. :param event: An instance of :class:`PoolCreatedEvent`. r,r.s&&r pool_created#ConnectionPoolListener.pool_created "!rc V^8dQhRRRR/#)r#r$PoolReadyEventr&r'r)r(s"rr)rCs " " "4 "rc \h)zAbstract method to handle a :class:`PoolReadyEvent`. Emitted when a connection Pool is marked ready. :param event: An instance of :class:`PoolReadyEvent`. .. versionadded:: 4.0 r,r.s&&r pool_ready!ConnectionPoolListener.pool_readys "!rc V^8dQhRRRR/#)r#r$PoolClearedEventr&r'r)r(s"rr)rC"rDrc \h)zAbstract method to handle a `PoolClearedEvent`. Emitted when a connection Pool is cleared. :param event: An instance of :class:`PoolClearedEvent`. r,r.s&&r pool_cleared#ConnectionPoolListener.pool_cleared"rHrc V^8dQhRRRR/#)r#r$PoolClosedEventr&r'r)r(s"rr)rC+s"""T"rc \h)zAbstract method to handle a `PoolClosedEvent`. Emitted when a connection Pool is closed. :param event: An instance of :class:`PoolClosedEvent`. r,r.s&&r pool_closed"ConnectionPoolListener.pool_closed+rHrc V^8dQhRRRR/#)r#r$ConnectionCreatedEventr&r'r)r(s"rr)rC4s""(>"4"rc \h)zAbstract method to handle a :class:`ConnectionCreatedEvent`. Emitted when a connection Pool creates a Connection object. :param event: An instance of :class:`ConnectionCreatedEvent`. r,r.s&&rconnection_created)ConnectionPoolListener.connection_created4rHrc V^8dQhRRRR/#)r#r$ConnectionReadyEventr&r'r)r(s"rr)rC=s""&:"t"rc \h)zAbstract method to handle a :class:`ConnectionReadyEvent`. Emitted when a connection has finished its setup, and is now ready to use. :param event: An instance of :class:`ConnectionReadyEvent`. r,r.s&&rconnection_ready'ConnectionPoolListener.connection_ready= "!rc V^8dQhRRRR/#)r#r$ConnectionClosedEventr&r'r)r(s"rr)rCGs""'<""rc \h)zAbstract method to handle a :class:`ConnectionClosedEvent`. Emitted when a connection Pool closes a connection. :param event: An instance of :class:`ConnectionClosedEvent`. r,r.s&&rconnection_closed(ConnectionPoolListener.connection_closedGrHrc V^8dQhRRRR/#)r#r$ConnectionCheckOutStartedEventr&r'r)r(s"rr)rCPs""2P"UY"rc \h)zAbstract method to handle a :class:`ConnectionCheckOutStartedEvent`. Emitted when the driver starts attempting to check out a connection. :param event: An instance of :class:`ConnectionCheckOutStartedEvent`. r,r.s&&rconnection_check_out_started3ConnectionPoolListener.connection_check_out_startedPrHrc V^8dQhRRRR/#)r#r$ConnectionCheckOutFailedEventr&r'r)r(s"rr)rCYs""1N"SW"rc \h)zAbstract method to handle a :class:`ConnectionCheckOutFailedEvent`. Emitted when the driver's attempt to check out a connection fails. :param event: An instance of :class:`ConnectionCheckOutFailedEvent`. r,r.s&&rconnection_check_out_failed2ConnectionPoolListener.connection_check_out_failedYrHrc V^8dQhRRRR/#)r#r$ConnectionCheckedOutEventr&r'r)r(s"rr)rCbs"",E"$"rc \h)zAbstract method to handle a :class:`ConnectionCheckedOutEvent`. Emitted when the driver successfully checks out a connection. :param event: An instance of :class:`ConnectionCheckedOutEvent`. r,r.s&&rconnection_checked_out-ConnectionPoolListener.connection_checked_outbrHrc V^8dQhRRRR/#)r#r$ConnectionCheckedInEventr&r'r)r(s"rr)rCks""+C""rc \h)zAbstract method to handle a :class:`ConnectionCheckedInEvent`. Emitted when the driver checks in a connection back to the connection Pool. :param event: An instance of :class:`ConnectionCheckedInEvent`. r,r.s&&rconnection_checked_in,ConnectionPoolListener.connection_checked_inkrbrrN)rrrrrrFrLrQrVr[r`rfrkrprurzrrrrr@r@sC " """""""""""rr@c>]tRtRtRtRRltRRltRRltR tR #) ServerHeartbeatListenerivzAbstract base class for server heartbeat listeners. Handles `ServerHeartbeatStartedEvent`, `ServerHeartbeatSucceededEvent`, and `ServerHeartbeatFailedEvent`. .. versionadded:: 3.3 c V^8dQhRRRR/#)r#r$ServerHeartbeatStartedEventr&r'r)r(s"rr)$ServerHeartbeatListener.__annotate__s""8"T"rc \h)zAbstract method to handle a `ServerHeartbeatStartedEvent`. :param event: An instance of :class:`ServerHeartbeatStartedEvent`. r,r.s&&rr0ServerHeartbeatListener.startedr2rc V^8dQhRRRR/#)r#r$ServerHeartbeatSucceededEventr&r'r)r(s"rr)rs""<""rc \h)zAbstract method to handle a `ServerHeartbeatSucceededEvent`. :param event: An instance of :class:`ServerHeartbeatSucceededEvent`. r,r.s&&rr6!ServerHeartbeatListener.succeededr2rc V^8dQhRRRR/#)r#r$ServerHeartbeatFailedEventr&r'r)r(s"rr)rs""6"4"rc \h)z}Abstract method to handle a `ServerHeartbeatFailedEvent`. :param event: An instance of :class:`ServerHeartbeatFailedEvent`. r,r.s&&rr<ServerHeartbeatListener.failedr2rrNr>rrrr}r}vs""""rr}c>]tRtRtRtRRltRRltRRltR tR #) TopologyListenerizAbstract base class for topology monitoring listeners. Handles `TopologyOpenedEvent`, `TopologyDescriptionChangedEvent`, and `TopologyClosedEvent`. .. versionadded:: 3.3 c V^8dQhRRRR/#)r#r$TopologyOpenedEventr&r'r)r(s"rr)TopologyListener.__annotate__""/"D"rc \h)zoAbstract method to handle a `TopologyOpenedEvent`. :param event: An instance of :class:`TopologyOpenedEvent`. r,r.s&&ropenedTopologyListener.openedr2rc V^8dQhRRRR/#)r#r$TopologyDescriptionChangedEventr&r'r)r(s"rr)rs"")H"T"rc \h)zAbstract method to handle a `TopologyDescriptionChangedEvent`. :param event: An instance of :class:`TopologyDescriptionChangedEvent`. r,r.s&&rdescription_changed$TopologyListener.description_changedr2rc V^8dQhRRRR/#)r#r$TopologyClosedEventr&r'r)r(s"rr)rrrc \h)zoAbstract method to handle a `TopologyClosedEvent`. :param event: An instance of :class:`TopologyClosedEvent`. r,r.s&&rclosedTopologyListener.closedr2rrN rrrrrrrrrrrrrr""""rrc>]tRtRtRtRRltRRltRRltR tR #) ServerListenerizAbstract base class for server listeners. Handles `ServerOpeningEvent`, `ServerDescriptionChangedEvent`, and `ServerClosedEvent`. .. versionadded:: 3.3 c V^8dQhRRRR/#)r#r$ServerOpeningEventr&r'r)r(s"rr)ServerListener.__annotate__r:rc \h)zmAbstract method to handle a `ServerOpeningEvent`. :param event: An instance of :class:`ServerOpeningEvent`. r,r.s&&rrServerListener.openedr2rc V^8dQhRRRR/#)r#r$ServerDescriptionChangedEventr&r'r)r(s"rr)rs"")F"4"rc \h)zAbstract method to handle a `ServerDescriptionChangedEvent`. :param event: An instance of :class:`ServerDescriptionChangedEvent`. r,r.s&&rr"ServerListener.description_changedr2rc V^8dQhRRRR/#)r#r$ServerClosedEventr&r'r)r(s"rr)rs""-"$"rc \h)zkAbstract method to handle a `ServerClosedEvent`. :param event: An instance of :class:`ServerClosedEvent`. r,r.s&&rrServerListener.closedr2rrNrrrrrrrrrc V^8dQhRRRR/#)r#durrr&intr)r(s"rr)r)s++I+#+rcB\VP4R,4#)z'Convert duration 'dur' to microseconds.g.A)r total_seconds)rs&r _to_microsrs s  "T) **rc$V^8dQhRRRRRR/#)r#optionstr listenerszSequence[_EventListeners]r&r)r(s"rr)r)s$ 5rc \V\P4'g\V R\ V4 24hVF3p\V\ 4'dK\RV R\ V4 24h V#)zValidate event listenersz must be a list or tuple, not Listeners for | must be either a CommandListener, ServerHeartbeatListener, ServerListener, TopologyListener, or ConnectionPoolListener,not ) isinstancerr TypeErrortyper)rrlisteners&& r_validate_event_listenersrsz i . .6("@i@QRSS(N33 )H~& (  rc V^8dQhRRRR/#)r#rrr&r'r)r(s"rr)r)s33~3$3rc|\V\4'g\RV R\V4 24h\V\4'd \ P PV4\V\4'd \ PPV4\V\4'd \ PPV4\V\4'd \ PPV4\V\4'd"\ PPV4R#R#)zRegister a global event listener. :param listener: A subclasses of :class:`CommandListener`, :class:`ServerHeartbeatListener`, :class:`ServerListener`, :class:`TopologyListener`, or :class:`ConnectionPoolListener`. rrN)rrrrr! _LISTENERScommand_listenersappendr}server_heartbeat_listenersrserver_listenersrtopology_listenersr@cmap_listeners)rs&rregisterrs h / /XJ'>"  $  (O,,$$++H5(344--44X>(N++##**84(,--%%,,X6(233!!((24rc$V^8dQhRRRRRR/#)r# command_namerdoczMapping[str, Any]r&boolr)r(s"rr)r)s"s9JtrcbVP4R\P39d RV9dR#R#)hellospeculativeAuthenticateTF)lowerr LEGACY_CMD)rrs&&r_is_speculative_authenticaters,+*@*@ AA % , rc]tRtRtRtRtRRRllt]RRl4t]RR l4t ]R R l4t ]R R l4t ]RRl4t ]RRl4t ]RRl4tRtR#) _CommandEventizBase class for command events.Nc8V^8dQhRRRRRRRRR R R RR RR R/#)r#rr request_idr connection_idr operation_id Optional[int] service_idOptional[ObjectId] database_nameserver_connection_idr&r'r)r(s"rr)_CommandEvent.__annotate__sZ5555 5 $ 5 ' 55,5 5rc ZWnW nW0nW@nWPnW`nWpnR#N)_CommandEvent__cmd_name_CommandEvent__rqst_id_CommandEvent__conn_id_CommandEvent__op_id_CommandEvent__service_id_CommandEvent__db_CommandEvent__server_conn_id)r/rrrrrrrs&&&&&&&&r__init___CommandEvent.__init__s)'#&# &! 4rcV^8dQhRR/#r#r&rr)r(s"rr)r.scrc VP#)zThe command name.)rr/s&rr_CommandEvent.command_name-rcV^8dQhRR/#r#r&rr)r(s"rr)r3sCrc VP#)z"The request id for this operation.)rrs&rr_CommandEvent.request_id2~~rcV^8dQhRR/#r#r&rr)r(s"rr)r8sxrc VP#)z@The address (host, port) of the server this command was sent to.)rrs&rr_CommandEvent.connection_id7rrcV^8dQhRR/#r#r&rr)r(s"rr)r=s!!.!rc VP#)zNThe service_id this command was sent to, or ``None``. .. versionadded:: 3.12 )rrs&rr_CommandEvent.service_id<s    rcV^8dQhRR/#r#r&rr)r(s"rr)rEsmrc VP#)z(An id for this series of events or None.)rrs&rr_CommandEvent.operation_idD||rcV^8dQhRR/#rr)r(s"rr)rJssrc VP#)zNThe database_name this command was sent to, or ``""``. .. versionadded:: 4.6 )rrs&rr_CommandEvent.database_nameIs yyrcV^8dQhRR/#rr)r(s"rr)rRs%%m%rc VP#)zoThe server-side connection id for the connection this command was sent on, or ``None``. .. versionadded:: 4.7 )rrs&rr"_CommandEvent.server_connection_idQs $$$r) __cmd_name __conn_id__db__op_id __rqst_id__server_conn_id __service_id)r rr r rr rNN)rrrrr __slots__rpropertyrrrrrrrrrrrrrs(I5$!!%%rrcxa]tRtRtRtR tR RV3Rlllt]RRl4t]RV3Rll4t R R lt R t V;t #) r%iZaEvent published when a command starts. :param command: The command document. :param database_name: The name of the database this command was run against. :param request_id: The request id for this operation. :param connection_id: The address (host, port) of the server this command was sent to. :param operation_id: An optional identifier for a series of related events. :param service_id: The service_id this command was sent to, or ``None``. c8V^8dQhRRRRRRRRR R R R R R RR/#)r#commandrrrrrrrrrrrrr&r'r)r(s"rr) CommandStartedEvent.__annotate__hsZ!!!! !  ! $ !'!,! !rc  <V'g\V: R24h\\V44p\S V`VVVVVVVR7VP 4p V \ 9g\W4'd /VnR#WnR#)z is not a valid commandrrrN) ValueErrornextitersuperrrr r_CommandStartedEvent__cmd) r/rrrrrrrrcmd_name __class__s &&&&&&&& rrCommandStartedEvent.__init__hs{*ABC CDM*      !'!5   %%' * *.J8.].]')DJ JrcV^8dQhRR/#r#r&rr)r(s"rr)rsrc VP#)zThe command document.)rrs&rrCommandStartedEvent.commandszzrcV^8dQhRR/#rr)r(s"rr)rs%%s%rc <\SV`#)z6The name of the database this command was run against.)rrr/r!s&rr!CommandStartedEvent.database_namesw$$rcV^8dQhRR/#rr)r(s"rr)rs   #  rc  RPVPPVPVPVP VP VPVP4#)z[<{} {} db: {!r}, command: {!r}, operation_id: {}, service_id: {}, server_connection_id: {}>) r(r!rrrrrrrrs&r__repr__CommandStartedEvent.__repr__sU i & NN # #             OO  % %  r)__cmdNN) rrrrrrrrrrr-r __classcell__r!s@rr%r%ZsK I!!:%%   rr%cra]tRtRtRtR tR RV3Rlllt]RRl4t]RRl4t R R lt R t V;t #) r4ia'Event published when a command succeeds. :param duration: The command duration as a datetime.timedelta. :param reply: The server reply document. :param command_name: The command name. :param request_id: The request id for this operation. :param connection_id: The address (host, port) of the server this command was sent to. :param operation_id: An optional identifier for a series of related events. :param service_id: The service_id this command was sent to, or ``None``. :param database_name: The database this command was sent to, or ``""``. c@V^8dQhRRRRRRRRR R R R R RRRRR RR/ #)r#durationdatetime.timedeltareplyrrrrrrrrrrrrrr&r'r)r(s"rr)"CommandSucceededEvent.__annotate__sn!!$!! !  !  !$!'!!,! !rc  <\S V`VVVVVVV R7\V4VnVP 4p V \ 9g\ W4'd /VnR#W nR#rN)rrr'_CommandSucceededEvent__duration_microsrr r_CommandSucceededEvent__reply) r/r5r7rrrrrrrr r!s &&&&&&&&&& rrCommandSucceededEvent.__init__si     !'!5  ",H!5%%' * *.J8.[.[)+DL LrcV^8dQhRR/#rr)r(s"rr)r8&&&rc VP#z/The duration of this operation in microseconds.)r;rs&rduration_micros%CommandSucceededEvent.duration_micros%%%rcV^8dQhRR/#r$r)r(s"rr)r8s|rc VP#z/The server failure document for this operation.)r<rs&rr7CommandSucceededEvent.replyrrcV^8dQhRR/#rr)r(s"rr)r8s   #  rc  RPVPPVPVPVP VP VPVPVP4#)zp<{} {} db: {!r}, command: {!r}, operation_id: {}, duration_micros: {}, service_id: {}, server_connection_id: {}>) r(r!rrrrrrBrrrs&rr-CommandSucceededEvent.__repr__s^ ~ & NN # #              OO  % %  r)__duration_micros__replyr) rrrrrrrrrBr7r-rr1r2s@rr4r4sK 1I!!8&&   rr4cra]tRtRtRtR tR RV3Rlllt]RRl4t]RRl4t R R lt R t V;t #) r9ia&Event published when a command fails. :param duration: The command duration as a datetime.timedelta. :param failure: The server reply document. :param command_name: The command name. :param request_id: The request id for this operation. :param connection_id: The address (host, port) of the server this command was sent to. :param operation_id: An optional identifier for a series of related events. :param service_id: The service_id this command was sent to, or ``None``. :param database_name: The database this command was sent to, or ``""``. c@V^8dQhRRRRRRRRR R R R R RRRRR RR/ #)r#r5r6failurerrrrrrrrrrrrrr&r'r)r(s"rr)CommandFailedEvent.__annotate__sn!!$!! !  !  !$!'!!,! !rc  `<\S V`VVVVVVV R7\V4VnW nR#r:)rrr$_CommandFailedEvent__duration_micros_CommandFailedEvent__failure) r/r5rPrrrrrrrr!s &&&&&&&&&&rrCommandFailedEvent.__init__s@     !'!5  ",H!5 rcV^8dQhRR/#rr)r(s"rr)rQ r?rc VP#rA)rSrs&rrB"CommandFailedEvent.duration_micros rDrcV^8dQhRR/#r$r)r(s"rr)rQsrc VP#rG)rTrs&rrPCommandFailedEvent.failurerrcV^8dQhRR/#rr)r(s"rr)rQs  # rc  RPVPPVPVPVP VP VPVPVPVP4 #)z<{} {} db: {!r}, command: {!r}, operation_id: {}, duration_micros: {}, failure: {!r}, service_id: {}, server_connection_id: {}>) r(r!rrrrrrBrPrrrs&rr-CommandFailedEvent.__repr__sh G & NN # #              LL OO  % %  r)rL __failurer) rrrrrrrrrBrPr-rr1r2s@rr9r9sK 3I!!0&&  rr9cL]tRtRtRtR tRRlt]RRl4tRRlt R t R #) _PoolEventi%zBase class for pool events.c V^8dQhRRRR/#r#addressrr&r'r)r(s"rr)_PoolEvent.__annotate__*!!!T!rc WnR#r_PoolEvent__addressr/rds&&rr_PoolEvent.__init__* rcV^8dQhRR/#rr)r(s"rr)re.rc VP#)zRThe address (host, port) pair of the server the pool is attempting to connect to. rhrs&rrd_PoolEvent.address- ~~rcV^8dQhRR/#rr)r(s"rr)re4@@#@rc PVPP RVP: R2#())r!rrirs&rr-_PoolEvent.__repr__4%..))*!DNN+=Q??r __addressN rrrrrrrrrdr-rrrrrara%s/%I! @@rracXa]tRtRtRtR tRV3Rllt]RRl4tRRlt R t V;t #) rBi8zPublished when a Connection Pool is created. :param address: The address (host, port) pair of the server this Pool is attempting to connect to. .. versionadded:: 3.9 c$V^8dQhRRRRRR/#r#rdroptionsdict[str, Any]r&r'r)r(s"rr)PoolCreatedEvent.__annotate__Cs!!!!>!d!rc 2<\SV`V4W nR#r)rr_PoolCreatedEvent__options)r/rdrr!s&&&rrPoolCreatedEvent.__init__Cs ! rcV^8dQhRR/#)r#r&rr)r(s"rr)rHsrc VP#)zCAny non-default pool options that were set on this Connection Pool.)rrs&rrPoolCreatedEvent.optionsGrrcV^8dQhRR/#rr)r(s"rr)rLsRR#Rrc lVPP RVP: RVP: R2#rvz, rw)r!rrdrrs&rr-PoolCreatedEvent.__repr__Ls0..))*!DLL+;2dnn=OqQQr) __options) rrrrrrrrrr-rr1r2s@rrBrB8s9I!!RRrrBc]tRtRtRtRtRtR#)rJiPzPublished when a Connection Pool is marked ready. :param address: The address (host, port) pair of the server this Pool is attempting to connect to. .. versionadded:: 4.0 rNrrrrrrrrrrrJrJPIrrJcra]tRtRtRtR tR RV3Rlllt]RRl4t]RRl4t R R lt R t V;t #)rOi\a_Published when a Connection Pool is cleared. :param address: The address (host, port) pair of the server this Pool is attempting to connect to. :param service_id: The service_id this command was sent to, or ``None``. :param interrupt_connections: True if all active connections were interrupted by the Pool during clearing. .. versionadded:: 3.9 c(V^8dQhRRRRRRRR/# r#rdrrrinterrupt_connectionsrr&r'r)r(s"rr)PoolClearedEvent.__annotate__is2==='= $ =  =rc ><\SV`V4W nW0nR#r)rr_PoolClearedEvent__service_id(_PoolClearedEvent__interrupt_connections)r/rdrrr!s&&&&rrPoolClearedEvent.__init__is !&'<$rcV^8dQhRR/#rr)r(s"rr)rts!!.!rc VP#)zConnections with this service_id are cleared. When service_id is ``None``, all connections in the pool are cleared. .. versionadded:: 3.12 )rrs&rrPoolClearedEvent.service_idss   rcV^8dQhRR/#r#r&rr)r(s"rr)r~s,,t,rc VP#)zTIf True, active connections are interrupted during clearing. .. versionadded:: 4.7 )rrs&rr&PoolClearedEvent.interrupt_connections}s +++rcV^8dQhRR/#rr)r(s"rr)rsww#wrc VPP RVP: RVP: RVP: R2#r)r!rrdrrrs&rr-PoolClearedEvent.__repr__sB..))*!DLL+;2d>O>O=RRTUYUqUqTttuvvr)__interrupt_connectionsr)rr)NF) rrrrrrrrrrr-rr1r2s@rrOrO\sMR>R=UUVWWr)__connection_id) rrrrrrrrrr-rr1r2s@rrrs5>$I--$$XXrrcXa]tRtRtRtR tRV3Rllt]RRl4tRRlt R t V;t #) _ConnectionDurationEventiz9Private base class for connection events with a duration.c(V^8dQhRRRRRRRR/#) r#rdrrrr5Optional[float]r&r'r)r(s"rr)%_ConnectionDurationEvent.__annotate__s)#####\`#rc 2<\SV`W4W0nR#r)rr"_ConnectionDurationEvent__duration)r/rdrr5r!s&&&&rr!_ConnectionDurationEvent.__init__s 0"rcV^8dQhRR/#)r#r&rr)r(s"rr)rs/rc VP#)z=The duration of the connection event. .. versionadded:: 4.7 )rrs&rr5!_ConnectionDurationEvent.durations rcV^8dQhRR/#rr)r(s"rr)rskk#krc VPP RVP: RVP: RVP: R2#r)r!rrdrrrs&rr-!_ConnectionDurationEvent.__repr__sB..))*!DLL+;2d>P>P=SSUVZVeVeUhhijjr) __duration) rrrrrrrrr5r-rr1r2s@rrrs5CI##kkrrc]tRtRtRtRtRtR#)rYiaiPublished when a Connection Pool creates a Connection object. NOTE: This connection is not ready for use until the :class:`ConnectionReadyEvent` is published. :param address: The address (host, port) pair of the server this Connection is attempting to connect to. :param connection_id: The integer ID of the Connection in this Pool. .. versionadded:: 3.9 rNrrrrrYrYs IrrYc]tRtRtRtRtRtR#)r^iaPublished when a Connection has finished its setup, and is ready to use. :param address: The address (host, port) pair of the server this Connection is attempting to connect to. :param connection_id: The integer ID of the Connection in this Pool. .. versionadded:: 3.9 rNrrrrr^r^Irr^cXa]tRtRtRtR tRV3Rllt]RRl4tRRlt R t V;t #) rdia3Published when a Connection is closed. :param address: The address (host, port) pair of the server this Connection is attempting to connect to. :param connection_id: The integer ID of the Connection in this Pool. :param reason: A reason explaining why this connection was closed. .. versionadded:: 3.9 c$V^8dQhRRRRRR/#)r#rdrrrreasonrr)r(s"rr)"ConnectionClosedEvent.__annotate__!s!crc 2<\SV`W4W0nR#r)rr_ConnectionClosedEvent__reason)r/rdrrr!s&&&&rrConnectionClosedEvent.__init__!s 0 rcV^8dQhRR/#rr)r(s"rr)r&rc VP#)zA reason explaining why this connection was closed. The reason must be one of the strings from the :class:`ConnectionClosedReason` enum. )rrs&rrConnectionClosedEvent.reason%}}rcV^8dQhRR/#rr)r(s"rr)r.  # rc RPVPPVPVPVP 4#)z{}({!r}, {!r}, {!r}))r(r!rrdrrrs&rr-ConnectionClosedEvent.__repr__.s9%,, NN # # LL    MM   r__reason rrrrrrrrrr-rr1r2s@rrdrds7I  rrdc]tRtRtRtRtRtR#)rii7zPublished when the driver starts attempting to check out a connection. :param address: The address (host, port) pair of the server this Connection is attempting to connect to. .. versionadded:: 3.9 rNrrrrriri7rrricXa]tRtRtRtR tRV3Rllt]RRl4tRRlt R t V;t #) rniCa Published when the driver's attempt to check out a connection fails. :param address: The address (host, port) pair of the server this Connection is attempting to connect to. :param reason: A reason explaining why connection check out failed. .. versionadded:: 3.9 c(V^8dQhRRRRRRRR/#) r#rdrrrr5rr&r'r)r(s"rr)*ConnectionCheckOutFailedEvent.__annotate__Os)#UYrc 8<\SV`V^VR7W nR#))rdrr5N)rr&_ConnectionCheckOutFailedEvent__reason)r/rdrr5r!s&&&&rr&ConnectionCheckOutFailedEvent.__init__Os HM rcV^8dQhRR/#rr)r(s"rr)rTrrc VP#)zA reason explaining why connection check out failed. The reason must be one of the strings from the :class:`ConnectionCheckOutFailedReason` enum. )rrs&rr$ConnectionCheckOutFailedEvent.reasonSrrcV^8dQhRR/#rr)r(s"rr)r\dd#drc VPP RVP: RVP: RVP: R2#r)r!rrdrr5rs&rr-&ConnectionCheckOutFailedEvent.__repr__\s?..))*!DLL+;2dmm=NbQUQ^Q^Paabccrrrr2s@rrnrnCs9Iddrrnc]tRtRtRtRtRtR#)rsi`a Published when the driver successfully checks out a connection. :param address: The address (host, port) pair of the server this Connection is attempting to connect to. :param connection_id: The integer ID of the Connection in this Pool. .. versionadded:: 3.9 rNrrrrrsrs`rrrsc]tRtRtRtRtRtR#)rxima Published when the driver checks in a Connection into the Pool. :param address: The address (host, port) pair of the server this Connection is attempting to connect to. :param connection_id: The integer ID of the Connection in this Pool. .. versionadded:: 3.9 rNrrrrrxrxmrrrxcb]tRtRtRtR tRRlt]RRl4t]RRl4t R R lt R t R #) _ServerEventizzBase class for server events.c$V^8dQhRRRRRR/#r#server_addressr topology_idr r&r'r)r(s"rr)_ServerEvent.__annotate__s!))x)h)4)rc WnW nR#r)_ServerEvent__server_address_ServerEvent__topology_id)r/r rs&&&rr_ServerEvent.__init__s .(rcV^8dQhRR/#rr)r(s"rr)rs%%%rc VP#)z+The address (host, port) pair of the server)rrs&rr _ServerEvent.server_addresss$$$rcV^8dQhRR/#r#r&r r)r(s"rr)r""X"rc VP#z>A unique identifier for the topology this server is a part of.)rrs&rr_ServerEvent.topology_id!!!rcV^8dQhRR/#rr)r(s"rr)rrrc jRVPP RVP RVP R2#)<  topology_id: >)r!rr rrs&rr-_ServerEvent.__repr__s84>>**+1T-@-@,APTP`P`Oaabccr)__server_address __topology_idN) rrrrrrrrr rr-rrrrr r zsC'5I)%%""ddrr cna]tRtRtRtR tRV3Rllt]RRl4t]RRl4t R R lt R t V;t #) rizBPublished when server description changes. .. versionadded:: 3.3 c(V^8dQhRRRRRRRR/#)r#previous_descriptionrnew_descriptionargsrr&r'r)r(s"rr)*ServerDescriptionChangedEvent.__annotate__s211/1+1 1  1rc <<\SV`!V!WnW nR#r)rr4_ServerDescriptionChangedEvent__previous_description/_ServerDescriptionChangedEvent__new_descriptionr/r)r*r+r!s&&&*rr&ServerDescriptionChangedEvent.__init__ $&:#!0rcV^8dQhRR/#r#r&rr)r(s"rr)r,s++&7+rc VP#)zEThe previous :class:`~pymongo.server_description.ServerDescription`. )r.rs&rr)2ServerDescriptionChangedEvent.previous_description ***rcV^8dQhRR/#r4r)r(s"rr)r,s&&!2&rc VP#)z@The new :class:`~pymongo.server_description.ServerDescription`. )r/rs&rr*-ServerDescriptionChangedEvent.new_description %%%rcV^8dQhRR/#rr)r(s"rr)r,rrc RPVPPVPVPVP 4#)z <{} {} changed from: {}, to: {}>)r(r!rr r)r*rs&rr-&ServerDescriptionChangedEvent.__repr__s=188 NN # #     % %    r__new_description__previous_descriptionrAr@ rrrrrrrrr)r*r-rr1r2s@rrrL @I11++ &&   rrc]tRtRtRtRtRtR#)riz=Published when server is initialized. .. versionadded:: 3.3 rNrrrrrr Irrc]tRtRtRtRtRtR#)riz8Published when server is closed. .. versionadded:: 3.3 rNrrrrrrrFrrcL]tRtRtRtR tRRlt]RRl4tRRlt R t R #) TopologyEventiz+Base class for topology description events.c V^8dQhRRRR/#r#rr r&r'r)r(s"rr)TopologyEvent.__annotate__s))H))rc WnR#r_TopologyEvent__topology_id)r/rs&&rrTopologyEvent.__init__s(rcV^8dQhRR/#rr)r(s"rr)rLrrc VP#rrNrs&rrTopologyEvent.topology_idrrcV^8dQhRR/#rr)r(s"rr)rLsNN#Nrc PRVPP RVP R2#)r r"r#)r!rrrs&rr-TopologyEvent.__repr__s)4>>**+>$:J:J9K1MMr)r&N) rrrrrrrrrr-rrrrrIrIs/5"I)""NNrrIcna]tRtRtRtR tRV3Rllt]RRl4t]RRl4t R R lt R t V;t #) rizHPublished when the topology description changes. .. versionadded:: 3.3 c(V^8dQhRRRRRRRR/#)r#r)rr*r+rr&r'r)r(s"rr),TopologyDescriptionChangedEvent.__annotate__s21111-1 1  1rc <<\SV`!V!WnW nR#r)rr6_TopologyDescriptionChangedEvent__previous_description1_TopologyDescriptionChangedEvent__new_descriptionr0s&&&*rr(TopologyDescriptionChangedEvent.__init__r2rcV^8dQhRR/#r#r&rr)r(s"rr)rYs++&9+rc VP#)zIThe previous :class:`~pymongo.topology_description.TopologyDescription`. )r[rs&rr)4TopologyDescriptionChangedEvent.previous_descriptionr7rcV^8dQhRR/#r_r)r(s"rr)rYs&&!4&rc VP#)zDThe new :class:`~pymongo.topology_description.TopologyDescription`. )r\rs&rr*/TopologyDescriptionChangedEvent.new_descriptionr;rcV^8dQhRR/#rr)r(s"rr)rYrrc RPVPPVPVPVP 4#)z-<{} topology_id: {} changed from: {}, to: {}>)r(r!rrr)r*rs&rr-(TopologyDescriptionChangedEvent.__repr__s=>EE NN # #     % %    rr?rBrCr2s@rrrrDrrc]tRtRtRtRtRtR#)rizCPublished when the topology is initialized. .. versionadded:: 3.3 rNrrrrrrrFrrc]tRtRtRtRtRtR#)riz>Published when the topology is closed. .. versionadded:: 3.3 rNrrrrrrrFrrcf]tRtRtRtR tRRRllt]RRl4t]RRl4t R R lt R t R #)_ServerHeartbeatEventiz'Base class for server heartbeat events.c$V^8dQhRRRRRR/#r#rrawaitedrr&r'r)r(s"rr)"_ServerHeartbeatEvent.__annotate__s!!!h!!$!rc WnW nR#r)$_ServerHeartbeatEvent__connection_id_ServerHeartbeatEvent__awaited)r/rrns&&&rr_ServerHeartbeatEvent.__init__s , rcV^8dQhRR/#rr)r(s"rr)ro"s$$x$rc VP#)zCThe address (host, port) of the server this heartbeat was sent to. )rqrs&rr#_ServerHeartbeatEvent.connection_id!s ###rcV^8dQhRR/#rr)r(s"rr)ro)src VP#)zWWhether the heartbeat was issued as an awaitable hello command. .. versionadded:: 4.6 )rrrs&rrn_ServerHeartbeatEvent.awaited(s ~~rcV^8dQhRR/#rr)r(s"rr)ro0s[[#[rc jRVPP RVP RVP R2#)r r!z awaited: r#)r!rrrnrs&rr-_ServerHeartbeatEvent.__repr__0s44>>**+1T-?-?,@ 4<<.XYZZr) __awaitedrN)rr}F) rrrrrrrrrrnr-rrrrrkrksC10I!$$ [[rrkc]tRtRtRtRtRtR#)ri4z>Published when a heartbeat is started. .. versionadded:: 3.3 rNrrrrrr4rFrrca]tRtRtRtR tRRV3Rlllt]RRl4t]RRl4t ]R V3R ll4t R R lt R t V;t #)ri=zAFired when the server heartbeat succeeds. .. versionadded:: 3.3 c ,V^8dQhRRRRRRRRR R /#) r#r5floatr7Hello[dict[str, Any]]rrrnrr&r'r)r(s"rr)*ServerHeartbeatSucceededEvent.__annotate__Es<   %      rc ><\SV`W44WnW nR#r)rr(_ServerHeartbeatSucceededEvent__duration%_ServerHeartbeatSucceededEvent__replyr/r5r7rrnr!s&&&&&rr&ServerHeartbeatSucceededEvent.__init__Es 0" rcV^8dQhRR/#r#r&rr)r(s"rr)rQ%rc VP#z/The duration of this heartbeat in microseconds.)rrs&rr5&ServerHeartbeatSucceededEvent.durationPrrcV^8dQhRR/#)r#r&rr)r(s"rr)rVs,rc VP#)z-An instance of :class:`~pymongo.hello.Hello`.)rrs&rr7#ServerHeartbeatSucceededEvent.replyUrrcV^8dQhRR/#rr)r(s"rr)r[   rc <\SV`#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. .. versionadded:: 3.11 rrnr)s&rrn%ServerHeartbeatSucceededEvent.awaitedZwrcV^8dQhRR/#rr)r(s"rr)rf  # rc RPVPPVPVPVP VP 4#)z,<{} {} duration: {}, awaited: {}, reply: {}>r(r!rrr5rnr7rs&rr-&ServerHeartbeatSucceededEvent.__repr__fs@=DD NN # #    MM LL JJ   rrrMr~rrrrrrrrr5r7rnr-rr1r2s@rrr=s_ *I      rrca]tRtRtRtR tRRV3Rlllt]RRl4t]RRl4t ]R V3R ll4t R R lt R t V;t #)ripzlFired when the server heartbeat fails, either with an "ok: 0" or a socket exception. .. versionadded:: 3.3 c ,V^8dQhRRRRRRRRR R /#) r#r5rr7 Exceptionrrrnrr&r'r)r(s"rr)'ServerHeartbeatFailedEvent.__annotate__ys4&/@HSW rc ><\SV`W44WnW nR#r)rr%_ServerHeartbeatFailedEvent__duration"_ServerHeartbeatFailedEvent__replyrs&&&&&rr#ServerHeartbeatFailedEvent.__init__ys 0" rcV^8dQhRR/#rr)r(s"rr)rrrc VP#r)rrs&rr5#ServerHeartbeatFailedEvent.durationrrcV^8dQhRR/#)r#r&rr)r(s"rr)rsyrc VP#)zA subclass of :exc:`Exception`.)rrs&rr7 ServerHeartbeatFailedEvent.replyrrcV^8dQhRR/#rr)r(s"rr)rrrc <\SV`#rrr)s&rrn"ServerHeartbeatFailedEvent.awaitedrrcV^8dQhRR/#rr)r(s"rr)rrrc RPVPPVPVPVP VP 4#)z.<{} {} duration: {}, awaited: {}, reply: {!r}>rrs&rr-#ServerHeartbeatFailedEvent.__repr__s@?FF NN # #    MM LL JJ   rrr~rr2s@rrrps_ *I    rrc]tRtRtRtRRlt]RRl4t]RRl4t]R R l4t ]R R l4t ]R Rl4t RRlt RARRllt RBRRlltRCRRlltRRltRRltRRltRRltR R!ltR"R#ltR$R%ltR&R'ltR(R)ltR*R+ltR,R-ltRDR.R/lltR0R1ltR2R3ltR4R5ltR6R7ltR8R9lt R:R;lt!R<R=lt"R>R?lt#R@t$R#)E_EventListenersizConfigure event listeners for a client instance. Any event listeners registered globally are included by default. :param listeners: A list of event listeners. cV^8dQhRR/#)r#rz"Optional[Sequence[_EventListener]]r)r(s"rr)_EventListeners.__annotate__s>>"D>rc 0\PR,Vn\PR,Vn\P pVR,Vn\PR,Vn\PR,Vn VEeVFp\V\4'dVPPV4\V\4'dVPPV4\V\4'dVP PV4\V\ 4'dVPPV4\V\"4'gKVPPV4K \%VP4Vn\%VP4Vn\%VP 4Vn\%VP4Vn\%VP4VnR#):NNNN)rr"_EventListeners__command_listenersr!_EventListeners__server_listenersr+_EventListeners__server_heartbeat_listenersr#_EventListeners__topology_listenersr_EventListeners__cmap_listenersrr!rrr}rr@r%_EventListeners__enabled_for_commands#_EventListeners__enabled_for_server-_EventListeners__enabled_for_server_heartbeat%_EventListeners__enabled_for_topology!_EventListeners__enabled_for_cmap)r/rlsts&& rr_EventListeners.__init__s~#-#?#?#B ","="=a"@33,/F)$.$A$A!$D! * 9 9! <   c?33,,33C8c>22++2237c#:;;55<?11J $!!%(2 $!# $rc$V^8dQhRRRRRR/#r r)r(s"rr)rrrc \W4pVPFpVPV4K R# \d\ 4K3i;i)zPublish a ServerClosedEvent to all server listeners. :param server_address: The address (host, port) pair of the server. :param topology_id: A unique identifier for the topology this server is a part of. N)rrrrrrs&&& rpublish_server_closed%_EventListeners.publish_server_closedsH".>11J $!!%(2 $!# $rc ,V^8dQhRRRRRRRRRR /#) r#r)rr*r rrr r&r'r)r(s"rr)rs<$$/$+$! $  $  $rc \WW44pVPFpVPV4K R# \d\ 4K3i;i)aNPublish a ServerDescriptionChangedEvent to all server listeners. :param previous_description: The previous server description. :param server_address: The address (host, port) pair of the server. :param new_description: The new server description. :param topology_id: A unique identifier for the topology this server is a part of. N)rrrrr)r/r)r*r rr$rs&&&&& r"publish_server_description_changed2_EventListeners.publish_server_description_changedsO. > 11J $..u52 $!# $rc V^8dQhRRRR/#rKr)r(s"rr)r $ $8 $ $rc \V4pVPFpVPV4K R# \d\ 4K3i;i)zPublish a TopologyOpenedEvent to all topology listeners. :param topology_id: A unique identifier for the topology this server is a part of. N)rrrrrr/rr$rs&& rpublish_topology_opened'_EventListeners.publish_topology_openedH $K033J $!!%(4 $!# $rc V^8dQhRRRR/#rKr)r(s"rr)rr rc \V4pVPFpVPV4K R# \d\ 4K3i;i)zPublish a TopologyClosedEvent to all topology listeners. :param topology_id: A unique identifier for the topology this server is a part of. N)rrrrrrs&& rpublish_topology_closed'_EventListeners.publish_topology_closedrrc(V^8dQhRRRRRRRR/#)r#r)rr*rr r&r'r)r(s"rr)rs2$$1$-$ $  $rc \WV4pVPFpVPV4K R# \d\ 4K3i;i)aPublish a TopologyDescriptionChangedEvent to all topology listeners. :param previous_description: The previous topology description. :param new_description: The new topology description. :param topology_id: A unique identifier for the topology this server is a part of. N)rrrrr)r/r)r*rr$rs&&&& r$publish_topology_description_changed4_EventListeners.publish_topology_description_changedsL00DWbc33J $..u54 $!# $rc$V^8dQhRRRRRR/#rr)r(s"rr)rs"$$H$~$RV$rc \W4pVPFpVPV4K R# \d\ 4K3i;i)z:Publish a :class:`PoolCreatedEvent` to all pool listeners.N)rBrrFrr)r/rdrr$rs&&& rpublish_pool_created$_EventListeners.publish_pool_createdsF 2//J $''.0 $!# $rc V^8dQhRRRR/#rcr)r(s"rr)rs$$($t$rc \V4pVPFpVPV4K R# \d\ 4K3i;i)z8Publish a :class:`PoolReadyEvent` to all pool listeners.N)rJrrLrrr/rdr$rs&& rpublish_pool_ready"_EventListeners.publish_pool_readysFw'//J $%%e,0 $!# $rc(V^8dQhRRRRRRRR/#rr)r(s"rr)rs2 $ $ $' $ $ $  $rc \WV4pVPFpVPV4K R# \d\ 4K3i;i)z:Publish a :class:`PoolClearedEvent` to all pool listeners.N)rOrrQrr)r/rdrrr$rs&&&& rpublish_pool_cleared$_EventListeners.publish_pool_clearedsK!6KL//J $''.0 $!# $rc V^8dQhRRRR/#rcr)r(s"rr)rs$$8$$rc \V4pVPFpVPV4K R# \d\ 4K3i;i)z9Publish a :class:`PoolClosedEvent` to all pool listeners.N)rTrrVrrr!s&& rpublish_pool_closed#_EventListeners.publish_pool_closedsF(//J $&&u-0 $!# $rc$V^8dQhRRRRRR/#rr)r(s"rr)r&s" $ $( $3 $SW $rc \W4pVPFpVPV4K R# \d\ 4K3i;i)zGPublish a :class:`ConnectionCreatedEvent` to all connection listeners. N)rYrr[rrr/rdrr$rs&&& rpublish_connection_created*_EventListeners.publish_connection_created&sH'w>//J $--e40 $!# $rc(V^8dQhRRRRRRRR/# r#rdrrrr5rr&r'r)r(s"rr)r1s, $ $ $03 $?D $  $rc \WV4pVPFpVPV4K R# \d\ 4K3i;i)zDPublish a :class:`ConnectionReadyEvent` to all connection listeners.N)r^rr`rrr/rdrr5r$rs&&&& rpublish_connection_ready(_EventListeners.publish_connection_ready1sJ%WXF//J $++E20 $!# $rc(V^8dQhRRRRRRRR/#) r#rdrrrrrr&r'r)r(s"rr)r<s* $ $ $# $WZ $_c $rc \WV4pVPFpVPV4K R# \d\ 4K3i;i)zFPublish a :class:`ConnectionClosedEvent` to all connection listeners. N)rdrrfrr)r/rdrrr$rs&&&& rpublish_connection_closed)_EventListeners.publish_connection_closed<sJ&gfE//J $,,U30 $!# $rc V^8dQhRRRR/#rcr)r(s"rr)rGs $ $H $ $rc \V4pVPFpVPV4K R# \d\ 4K3i;i)zOPublish a :class:`ConnectionCheckOutStartedEvent` to all connection listeners. N)rirrkrrr!s&& r$publish_connection_check_out_started4_EventListeners.publish_connection_check_out_startedGsH/w7//J $77>0 $!# $rc(V^8dQhRRRRRRRR/#) r#rdrrrr5rr&r'r)r(s"rr)rRs, $ $ $), $8= $  $rc \WV4pVPFpVPV4K R# \d\ 4K3i;i)zNPublish a :class:`ConnectionCheckOutFailedEvent` to all connection listeners. N)rnrrprr)r/rdrr5r$rs&&&& r#publish_connection_check_out_failed3_EventListeners.publish_connection_check_out_failedRsJ .gxH//J $66u=0 $!# $rc(V^8dQhRRRRRRRR/#r2r)r(s"rr)r_s, $ $ $03 $?D $  $rc \WV4pVPFpVPV4K R# \d\ 4K3i;i)zJPublish a :class:`ConnectionCheckedOutEvent` to all connection listeners. N)rsrrurrr4s&&&& rpublish_connection_checked_out._EventListeners.publish_connection_checked_out_sJ *'(K//J $11%80 $!# $rc$V^8dQhRRRRRR/#rr)r(s"rr)rls" $ $X $c $VZ $rc \W4pVPFpVPV4K R# \d\ 4K3i;i)zIPublish a :class:`ConnectionCheckedInEvent` to all connection listeners. N)rxrrzrrr.s&&& rpublish_connection_checked_in-_EventListeners.publish_connection_checked_inlsH)@//J $0070 $!# $r) __cmap_listeners__command_listeners__enabled_for_cmap__enabled_for_commands__enabled_for_server__enabled_for_server_heartbeat__enabled_for_topology__server_heartbeat_listeners__server_listeners__topology_listenersr0)NNFr)NNrr~)%rrrrrrrrrrrrrrrrrrrrrr rrrrr"r&r*r/r5r9r=rArErIrrrrrrs>2++))33++'' $$L/$b*$X $$&$& $ $$0 $ $$($$ $$ $ $ $ $ $ $ $ $rr)rrrrr)Kr __future__rdatetime collectionsrrtypingrrrrr bson.objectidr pymongo.hellor r pymongo.helpers_sharedr rpymongo.typingsrrrpymongo.server_descriptionrpymongo.topology_descriptionrrrrr!r@r}rrrrrrrr%r4r9rarBrJrOrTrrrrrrYr^rdrirnrsrxr rrrrIrrrrkrrrrrrrr_svl\#'BB",I2"<@  BB + 77"n":u"^u"p"n">"~"<"^"<+ $3:I%I%X@ -@ FB MB J@ @ F@@&RzR0 Z *wz*wZ j FF*&@@&X)X$k1k* /  3   .  F %5 d$<d:  8  1 dd.& L& R NN"& m& R--[[8"70 $90 f- !6- `U$U$r