&gpSrSSKJr SSKrSSKJrJr SSKJrJ r J r J r J r SSK Jr SSKJrJr SSKJrJr SS KJrJr \(aSS KJr SS KJr SS KJr \"S S5r\"/////5r"SS5r"SS\5r "SS\5r!"SS\5r""SS\5r#"SS\5r$ScSjr%SdSjr&SeSjr'SfSjr("SS 5r)"S!S"\)5r*"S#S$\)5r+"S%S&\)5r,"S'S(5r-"S)S*\-5r."S+S,\-5r/"S-S.\-5r0"S/S0\-5r1"S1S25r2"S3S45r3"S5S65r4"S7S8\45r5"S9S:\55r6"S;S<\55r7"S=S>\65r8"S?S@\55r9"SASB\45r:"SCSD\65r;"SESF\65r<"SGSH\55r="SISJ5r>"SKSL\>5r?"SMSN\>5r@"SOSP\>5rA"SQSR5rB"SSST\B5rC"SUSV\B5rD"SWSX\B5rE"SYSZ5rF"S[S\\F5rG"S]S^\F5rH"S_S`\F5rI"SaSb5rJg)gaTools 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 _Listeners)command_listenersserver_listenersserver_heartbeat_listenerstopology_listenerscmap_listenersc\rSrSrSrSrg)_EventListenerz,Abstract base class for all event listeners.N)__name__ __module__ __qualname____firstlineno____doc____static_attributes__rWC:\Suresh\moveshuttle\MDcreated\moveengine\venv\Lib\site-packages\pymongo/monitoring.pyrrs6r%rc6\rSrSrSrSSjrS SjrS SjrSrg) CommandListenerz~Abstract base class for command listeners. Handles `CommandStartedEvent`, `CommandSucceededEvent`, and `CommandFailedEvent`. c[e)zoAbstract method to handle a `CommandStartedEvent`. :param event: An instance of :class:`CommandStartedEvent`. NotImplementedErrorselfevents r&startedCommandListener.started "!r%c[e)zsAbstract method to handle a `CommandSucceededEvent`. :param event: An instance of :class:`CommandSucceededEvent`. r+r-s r& succeededCommandListener.succeededr2r%c[e)zmAbstract method to handle a `CommandFailedEvent`. :param event: An instance of :class:`CommandFailedEvent`. r+r-s r&failedCommandListener.failedr2r%rN)r/CommandStartedEventreturnNone)r/CommandSucceededEventr:r;)r/CommandFailedEventr:r; rr r!r"r#r0r4r7r$rr%r&r(r(s """r%r(c\rSrSrSrSSjrSSjrSSjrSSjrSSjr SSjr SS jr SS jr SS jr SS jrSS jrSrg)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[e)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 "!r%c[e)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 "!r%c[e)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"rEr%c[e)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+rEr%c[e)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 r&connection_created)ConnectionPoolListener.connection_created4rEr%c[e)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 r&connection_ready'ConnectionPoolListener.connection_ready= "!r%c[e)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 r&connection_closed(ConnectionPoolListener.connection_closedGrEr%c[e)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 r&connection_check_out_started3ConnectionPoolListener.connection_check_out_startedPrEr%c[e)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 r&connection_check_out_failed2ConnectionPoolListener.connection_check_out_failedYrEr%c[e)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 r&connection_checked_out-ConnectionPoolListener.connection_checked_outbrEr%c[e)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 r&connection_checked_in,ConnectionPoolListener.connection_checked_inkrUr%rN)r/PoolCreatedEventr:r;)r/PoolReadyEventr:r;)r/PoolClearedEventr:r;)r/PoolClosedEventr:r;)r/ConnectionCreatedEventr:r;)r/ConnectionReadyEventr:r;)r/ConnectionClosedEventr:r;)r/ConnectionCheckOutStartedEventr:r;)r/ConnectionCheckOutFailedEventr:r;)r/ConnectionCheckedOutEventr:r;)r/ConnectionCheckedInEventr:r;)rr r!r"r#rCrGrJrMrPrSrWrZr]r`rcr$rr%r&r@r@s> " """"""""""r%r@c6\rSrSrSrSSjrS SjrS SjrSrg) ServerHeartbeatListenerivzAbstract base class for server heartbeat listeners. Handles `ServerHeartbeatStartedEvent`, `ServerHeartbeatSucceededEvent`, and `ServerHeartbeatFailedEvent`. .. versionadded:: 3.3 c[e)zAbstract method to handle a `ServerHeartbeatStartedEvent`. :param event: An instance of :class:`ServerHeartbeatStartedEvent`. r+r-s r&r0ServerHeartbeatListener.startedr2r%c[e)zAbstract method to handle a `ServerHeartbeatSucceededEvent`. :param event: An instance of :class:`ServerHeartbeatSucceededEvent`. r+r-s r&r4!ServerHeartbeatListener.succeededr2r%c[e)z}Abstract method to handle a `ServerHeartbeatFailedEvent`. :param event: An instance of :class:`ServerHeartbeatFailedEvent`. r+r-s r&r7ServerHeartbeatListener.failedr2r%rN)r/ServerHeartbeatStartedEventr:r;)r/ServerHeartbeatSucceededEventr:r;)r/ServerHeartbeatFailedEventr:r;r>rr%r&rqrqvs"""r%rqc6\rSrSrSrSSjrS SjrS SjrSrg) TopologyListenerizAbstract base class for topology monitoring listeners. Handles `TopologyOpenedEvent`, `TopologyDescriptionChangedEvent`, and `TopologyClosedEvent`. .. versionadded:: 3.3 c[e)zoAbstract method to handle a `TopologyOpenedEvent`. :param event: An instance of :class:`TopologyOpenedEvent`. r+r-s r&openedTopologyListener.openedr2r%c[e)zAbstract method to handle a `TopologyDescriptionChangedEvent`. :param event: An instance of :class:`TopologyDescriptionChangedEvent`. r+r-s r&description_changed$TopologyListener.description_changedr2r%c[e)zoAbstract method to handle a `TopologyClosedEvent`. :param event: An instance of :class:`TopologyClosedEvent`. r+r-s r&closedTopologyListener.closedr2r%rN)r/TopologyOpenedEventr:r;)r/TopologyDescriptionChangedEventr:r;)r/TopologyClosedEventr:r; rr r!r"r#r~rrr$rr%r&r|r|"""r%r|c6\rSrSrSrSSjrS SjrS SjrSrg) ServerListenerizAbstract base class for server listeners. Handles `ServerOpeningEvent`, `ServerDescriptionChangedEvent`, and `ServerClosedEvent`. .. versionadded:: 3.3 c[e)zmAbstract method to handle a `ServerOpeningEvent`. :param event: An instance of :class:`ServerOpeningEvent`. r+r-s r&r~ServerListener.openedr2r%c[e)zAbstract method to handle a `ServerDescriptionChangedEvent`. :param event: An instance of :class:`ServerDescriptionChangedEvent`. r+r-s r&r"ServerListener.description_changedr2r%c[e)zkAbstract method to handle a `ServerClosedEvent`. :param event: An instance of :class:`ServerClosedEvent`. r+r-s r&rServerListener.closedr2r%rN)r/ServerOpeningEventr:r;)r/ServerDescriptionChangedEventr:r;)r/ServerClosedEventr:r;rrr%r&rrrr%rc:[UR5S-5$)z'Convert duration 'dur' to microseconds.g.A)int total_seconds)durs r& _to_microsrs s  "T) **r%c [U[R5(d[US[ U535eUH2n[U[ 5(aM[SUS[ U535e U$)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)option listenerslisteners r&_validate_event_listenersrsz i . .6("@i@QRSS(N33 )H~& (  r%cl[U[5(d[SUS[U535e[U[5(a[ R RU5 [U[5(a[ RRU5 [U[5(a[ RRU5 [U[5(a[ RRU5 [U[5(a [ RRU5 gg)zRegister a global event listener. :param listener: A subclasses of :class:`CommandListener`, :class:`ServerHeartbeatListener`, :class:`ServerListener`, :class:`TopologyListener`, or :class:`ConnectionPoolListener`. rrN)rrrrr( _LISTENERSrappendrqrrrr|rr@r)rs r&registerrs h / /XJ'>"  $  (O,,$$++H5(344--44X>(N++##**84(,--%%,,X6(233!!((24r%cZUR5S[R4;aSU;agg)NhellospeculativeAuthenticateTF)lowerr LEGACY_CMD) command_namedocs r&_is_speculative_authenticaters,+*@*@ AA % , r%c\rSrSrSrSrSSSjjr\SSj5r\SSj5r \SSj5r \SS j5r \SS j5r \SS j5r \SS j5rS rg) _CommandEventizBase class for command events.) __cmd_name __rqst_id __conn_id__op_id __service_id__db__server_conn_idNcXXlX lX0lX@lXPlX`lXplgN)_CommandEvent__cmd_name_CommandEvent__rqst_id_CommandEvent__conn_id_CommandEvent__op_id_CommandEvent__service_id_CommandEvent__db_CommandEvent__server_conn_id)r.r request_id connection_id operation_id service_id database_nameserver_connection_ids r&__init___CommandEvent.__init__s)'#&# &! 4r%cUR$)zThe command name.)rr.s r&r_CommandEvent.command_name-r%cUR$)z"The request id for this operation.)rrs r&r_CommandEvent.request_id2~~r%cUR$)z@The address (host, port) of the server this command was sent to.)rrs r&r_CommandEvent.connection_id7rr%cUR$)zNThe service_id this command was sent to, or ``None``. .. versionadded:: 3.12 )rrs r&r_CommandEvent.service_id<s    r%cUR$)z(An id for this series of events or None.)rrs r&r_CommandEvent.operation_idD||r%cUR$)zNThe database_name this command was sent to, or ``""``. .. versionadded:: 4.6 )rrs r&r_CommandEvent.database_nameIs yyr%cUR$)zoThe server-side connection id for the connection this command was sent on, or ``None``. .. versionadded:: 4.7 )rrs r&r"_CommandEvent.server_connection_idQs $$$r%)rrrrrrrNN)rstrrrrrr Optional[int]rOptional[ObjectId]rrrrr:r;r:rr:rr:rr:r)r:r)rr r!r"r# __slots__rpropertyrrrrrrrr$rr%r&rrs(I *..2555 5 $ 5 ' 55,5 5$!!%%r%rc^\rSrSrSrSrSS U4Sjjjr\S Sj5r\S U4Sjj5r S Sjr Sr U=r $) r9iZaEvent 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``. )__cmdc >U(d[U<S35e[[U55n[T U]UUUUUUUS9 UR 5n U [ ;d[X5(a0UlgXlg)Nz is not a valid commandrrr) ValueErrornextitersuperrrrr_CommandStartedEvent__cmd) r.commandrrrrrrrcmd_name __class__s r&rCommandStartedEvent.__init__hs{*ABC CDM*      !'!5   %%' * *.J8.].]')DJ Jr%cUR$)zThe command document.)rrs r&rCommandStartedEvent.commandszzr%c>[TU]$)z6The name of the database this command was run against.)rrr.rs r&r!CommandStartedEvent.database_namesw$$r%c SRURRURURUR UR URUR5$)Nz[<{} {} db: {!r}, command: {!r}, operation_id: {}, service_id: {}, server_connection_id: {}>) formatrrrrrrrrrs r&__repr__CommandStartedEvent.__repr__sU i & NN # #             OO  % %  r%NN)rrrrrrrrrrrrrrr:r;r:rr) rr r!r"r#rrrrrrr$ __classcell__rs@r&r9r9Zs I*..2!!! !  ! $ !'!,! !!:%%   r%r9c^\rSrSrSrSrSS U4Sjjjr\S Sj5r\S Sj5r S Sjr Sr U=r $) r<ia'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 ``""``. )__duration_micros__replyc >[T U]UUUUUUU S9 [U5UlUR 5n U [ ;d[ X5(a0UlgX lgNr)rrr'_CommandSucceededEvent__duration_microsrrr_CommandSucceededEvent__reply) r.durationreplyrrrrrrrrrs r&rCommandSucceededEvent.__init__si     !'!5  ",H!5%%' * *.J8.[.[)+DL Lr%cUR$z/The duration of this operation in microseconds.)rrs r&duration_micros%CommandSucceededEvent.duration_micros%%%r%cUR$z/The server failure document for this operation.)rrs r&r CommandSucceededEvent.replyrr%c SRURRURURUR UR URURUR5$)Nzp<{} {} db: {!r}, command: {!r}, operation_id: {}, duration_micros: {}, service_id: {}, server_connection_id: {}>) rrrrrrrrrrrs r&rCommandSucceededEvent.__repr__s^ ~ & NN # #              OO  % %  r%r)r datetime.timedeltar rrrrrrrrrrrrrrrr:r;rrr) rr r!r"r#rrrrr rr$rrs@r&r<r<s 1I*..2!$!! !  !  !$!'!!,! !!8&&   r%r<c^\rSrSrSrSrSS U4Sjjjr\S Sj5r\S Sj5r S Sjr Sr U=r $) r=ia&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 ``""``. )r __failurec X>[T U]UUUUUUU S9 [U5UlX lgr)rrr$_CommandFailedEvent__duration_micros_CommandFailedEvent__failure) r.r failurerrrrrrrrs r&rCommandFailedEvent.__init__s@     !'!5  ",H!5 r%cUR$r )rrs r&r"CommandFailedEvent.duration_micros rr%cUR$r)rrs r&rCommandFailedEvent.failurerr%c SRURRURURUR UR URURURUR5 $)Nz<{} {} db: {!r}, command: {!r}, operation_id: {}, duration_micros: {}, failure: {!r}, service_id: {}, server_connection_id: {}>) rrrrrrrrrrrrs r&rCommandFailedEvent.__repr__sh G & NN # #              LL OO  % %  r%r)r rrrrrrrrrrrrrrrrrr:r;rrr) rr r!r"r#rrrrrrr$rrs@r&r=r=s 3I*..2!$!! !  !  !$!'!!,! !!0&&  r%r=cD\rSrSrSrSrSSjr\S Sj5rS Sjr Sr g) _PoolEventi%zBase class for pool events. __addresscXlgr_PoolEvent__addressr.addresss r&r_PoolEvent.__init__* r%cUR$)zRThe address (host, port) pair of the server the pool is attempting to connect to. r)rs r&r,_PoolEvent.address- ~~r%cPURRSUR<S3$N())rrr*rs r&r_PoolEvent.__repr__4%..))*!DNN+=Q??r%Nr,rr:r;rr rr r!r"r#rrrr,rr$rr%r&r%r%%s)%I! @r%r%cR^\rSrSrSrSrSU4Sjjr\SSj5rS Sjr Sr U=r $) rei8zPublished 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 ) __optionsc0>[TU]U5 X lgr)rr_PoolCreatedEvent__options)r.r,optionsrs r&rPoolCreatedEvent.__init__Cs ! r%cUR$)zCAny non-default pool options that were set on this Connection Pool.)r=rs r&r>PoolCreatedEvent.optionsGrr%clURRSUR<SUR<S3$Nr4z, r5)rrr,r=rs r&rPoolCreatedEvent.__repr__Ls0..))*!DLL+;2dnn=OqQQr%r,rr>dict[str, Any]r:r;)r:rFr) rr r!r"r#rrrr>rr$rrs@r&rere8s4I!RRr%rec\rSrSrSrSrSrg)rfiPzPublished 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 rNrr r!r"r#rr$rr%r&rfrfPIr%rfc|^\rSrSrSrSrS S U4Sjjjr\S Sj5r\S Sj5r S Sjr Sr U=r $)rgi\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 )r__interrupt_connectionsc<>[TU]U5 X lX0lgr)rr_PoolClearedEvent__service_id(_PoolClearedEvent__interrupt_connections)r.r,rinterrupt_connectionsrs r&rPoolClearedEvent.__init__is !&'<$r%cUR$)zConnections with this service_id are cleared. When service_id is ``None``, all connections in the pool are cleared. .. versionadded:: 3.12 )rMrs r&rPoolClearedEvent.service_idss   r%cUR$)zTIf True, active connections are interrupted during clearing. .. versionadded:: 4.7 )rNrs r&rO&PoolClearedEvent.interrupt_connections}s +++r%cURRSUR<SUR<SUR<S3$rC)rrr,rMrNrs r&rPoolClearedEvent.__repr__sB..))*!DLL+;2d>O>O=RRTUYUqUqTttuvvr%)rKr)NFr,rrrrOboolr:r;rr:rXr) rr r!r"r#rrrrrOrr$rrs@r&rgrg\s{[TU]U5 X lgr)rr!_ConnectionIdEvent__connection_id)r.r,rrs r&r_ConnectionIdEvent.__init__s !,r%cUR$)zThe ID of the connection.)ryrs r&r _ConnectionIdEvent.connection_ids###r%clURRSUR<SUR<S3$rC)rrr,ryrs r&r_ConnectionIdEvent.__repr__s3..))*!DLL+;2d>R>R=UUVWWr%r,rrrr:r;rr) rr r!r"r#rrrrrr$rrs@r&rvrvs0>$I-$$XXr%rvcR^\rSrSrSrSrSU4Sjjr\SSj5rS Sjr Sr U=r $) _ConnectionDurationEventiz9Private base class for connection events with a duration.) __durationc0>[TU]X5 X0lgr)rr"_ConnectionDurationEvent__duration)r.r,rr rs r&r!_ConnectionDurationEvent.__init__s 0"r%cUR$)z=The duration of the connection event. .. versionadded:: 4.7 )rrs r&r !_ConnectionDurationEvent.durations r%cURRSUR<SUR<SUR<S3$rC)rrr,rrrs r&r!_ConnectionDurationEvent.__repr__sB..))*!DLL+;2d>P>P=SSUVZVeVeUhhijjr%)r,rrrr Optional[float]r:r;)r:rr) rr r!r"r#rrrr rr$rrs@r&rrs0CI#kkr%rc\rSrSrSrSrSrg)riiaiPublished 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 rNrHrr%r&riris Ir%ric\rSrSrSrSrSrg)rjiaPublished 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 rNrHrr%r&rjrjIr%rjcR^\rSrSrSrSrSU4Sjjr\SSj5rSSjr Sr U=r $) rkia3Published 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 __reasonc0>[TU]X5 X0lgr)rr_ConnectionClosedEvent__reason)r.r,rreasonrs r&rConnectionClosedEvent.__init__!s 0 r%cUR$)zA reason explaining why this connection was closed. The reason must be one of the strings from the :class:`ConnectionClosedReason` enum. )rrs r&rConnectionClosedEvent.reason%}}r%cSRURRURURUR 5$)Nz{}({!r}, {!r}, {!r}))rrrr,rrrs r&rConnectionClosedEvent.__repr__.s9%,, NN # # LL    MM   r%)r,rrrrrr rr r!r"r#rrrrrr$rrs@r&rkrks2I  r%rkc\rSrSrSrSrSrg)rli7zPublished 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 rNrHrr%r&rlrl7rIr%rlcR^\rSrSrSrSrSU4Sjjr\SSj5rSSjr Sr U=r $) rmiCa 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 rc0>[TU]USUS9 X lg)Nr)r,rr )rr&_ConnectionCheckOutFailedEvent__reason)r.r,rr rs r&r&ConnectionCheckOutFailedEvent.__init__Os HM r%cUR$)zA reason explaining why connection check out failed. The reason must be one of the strings from the :class:`ConnectionCheckOutFailedReason` enum. )rrs r&r$ConnectionCheckOutFailedEvent.reasonSrr%cURRSUR<SUR<SUR<S3$rC)rrr,rr rs r&r&ConnectionCheckOutFailedEvent.__repr__\s?..))*!DLL+;2dmm=NbQUQ^Q^Paabccr%)r,rrrr rr:r;rrrs@r&rmrmCs4Iddr%rmc\rSrSrSrSrSrg)rni`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 rNrHrr%r&rnrn`rr%rnc\rSrSrSrSrSrg)roima 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 rNrHrr%r&roromrr%rocX\rSrSrSrSrS Sjr\S Sj5r\S Sj5r S Sjr Sr g) _ServerEventizzBase class for server events.)__server_address __topology_idcXlX lgr)_ServerEvent__server_address_ServerEvent__topology_id)r.server_address topology_ids r&r_ServerEvent.__init__s .(r%cUR$)z+The address (host, port) pair of the server)rrs r&r_ServerEvent.server_addresss$$$r%cUR$z>A unique identifier for the topology this server is a part of.)rrs r&r_ServerEvent.topology_id!!!r%cjSURRSURSURS3$)N<  topology_id: >)rrrrrs r&r_ServerEvent.__repr__s84>>**+1T-@-@,APTP`P`Oaabccr%Nrrrr r:r;rr:r r) rr r!r"r#rrrrrrr$rr%r&rrzs='5I)%%""dr%rcv^\rSrSrSrSrS U4Sjjr\S Sj5r\S Sj5r S Sjr Sr U=r $) rizBPublished when server description changes. .. versionadded:: 3.3 __previous_description__new_descriptionc8>[TU]"U6 XlX lgr)rr4_ServerDescriptionChangedEvent__previous_description/_ServerDescriptionChangedEvent__new_descriptionr.previous_descriptionnew_descriptionargsrs r&r&ServerDescriptionChangedEvent.__init__ $&:#!0r%cUR$)zEThe previous :class:`~pymongo.server_description.ServerDescription`. )rrs r&r2ServerDescriptionChangedEvent.previous_description ***r%cUR$)z@The new :class:`~pymongo.server_description.ServerDescription`. )rrs r&r-ServerDescriptionChangedEvent.new_description %%%r%cSRURRURURUR 5$)Nz <{} {} changed from: {}, to: {}>)rrrrrrrs r&r&ServerDescriptionChangedEvent.__repr__s=188 NN # #     % %    r%rr)rrrrrrr:r;)r:rr rr r!r"r#rrrrrrr$rrs@r&rrsm @I1/1+1 1  1++ &&   r%rc\rSrSrSrSrSrg)riz=Published when server is initialized. .. versionadded:: 3.3 rNrHrr%r&rr Ir%rc\rSrSrSrSrSrg)riz8Published when server is closed. .. versionadded:: 3.3 rNrHrr%r&rrrr%rcD\rSrSrSrSrSSjr\S Sj5rS Sjr Sr g) TopologyEventiz+Base class for topology description events.)rcXlgr_TopologyEvent__topology_id)r.rs r&rTopologyEvent.__init__s(r%cUR$rrrs r&rTopologyEvent.topology_idrr%cPSURRSURS3$)Nrrr)rrrrs r&rTopologyEvent.__repr__s)4>>**+>$:J:J9K1MMr%Nrr r:r;rr) rr r!r"r#rrrrrr$rr%r&rrs)5"I)""Nr%rcv^\rSrSrSrSrS U4Sjjr\S Sj5r\S Sj5r S Sjr Sr U=r $) rizHPublished when the topology description changes. .. versionadded:: 3.3 rc8>[TU]"U6 XlX lgr)rr6_TopologyDescriptionChangedEvent__previous_description1_TopologyDescriptionChangedEvent__new_descriptionrs r&r(TopologyDescriptionChangedEvent.__init__rr%cUR$)zIThe previous :class:`~pymongo.topology_description.TopologyDescription`. )rrs r&r4TopologyDescriptionChangedEvent.previous_descriptionrr%cUR$)zDThe new :class:`~pymongo.topology_description.TopologyDescription`. )rrs r&r/TopologyDescriptionChangedEvent.new_descriptionrr%cSRURRURURUR 5$)Nz-<{} topology_id: {} changed from: {}, to: {}>)rrrrrrrs r&r(TopologyDescriptionChangedEvent.__repr__s=>EE NN # #     % %    r%r)rrrrrrr:r;)r:rrrrs@r&rrsm @I111-1 1  1++ &&   r%rc\rSrSrSrSrSrg)rizCPublished when the topology is initialized. .. versionadded:: 3.3 rNrHrr%r&rrrr%rc\rSrSrSrSrSrg)riz>Published when the topology is closed. .. versionadded:: 3.3 rNrHrr%r&rrrr%rc\\rSrSrSrSrS S Sjjr\S Sj5r\S Sj5r SSjr Sr g )_ServerHeartbeatEventiz'Base class for server heartbeat events.)rw __awaitedcXlX lgr)$_ServerHeartbeatEvent__connection_id_ServerHeartbeatEvent__awaited)r.rawaiteds r&r_ServerHeartbeatEvent.__init__s , r%cUR$)zCThe address (host, port) of the server this heartbeat was sent to. )rrs r&r#_ServerHeartbeatEvent.connection_id!s ###r%cUR$)zWWhether the heartbeat was issued as an awaitable hello command. .. versionadded:: 4.6 )rrs r&r_ServerHeartbeatEvent.awaited(s ~~r%cjSURRSURSURS3$)Nrrz awaited: r)rrrrrs r&r_ServerHeartbeatEvent.__repr__0s44>>**+1T-?-?,@ 4<<.XYZZr%)rrwNFrrrrXr:r;rrYr) rr r!r"r#rrrrrrr$rr%r&rrs=10I!$$ [r%rc\rSrSrSrSrSrg)rxi4z>Published when a heartbeat is started. .. versionadded:: 3.3 rNrHrr%r&rxrx4rr%rxc^\rSrSrSrSrS S U4Sjjjr\S Sj5r\S Sj5r \S U4Sjj5r SSjr Sr U=r $)ryi=zAFired when the server heartbeat succeeds. .. versionadded:: 3.3 rrc<>[TU]X45 XlX lgr)rr(_ServerHeartbeatSucceededEvent__duration%_ServerHeartbeatSucceededEvent__replyr.r r rrrs r&r&ServerHeartbeatSucceededEvent.__init__E 0" r%cUR$z/The duration of this heartbeat in microseconds.)rrs r&r &ServerHeartbeatSucceededEvent.durationLrr%cUR$)z-An instance of :class:`~pymongo.hello.Hello`.)rrs r&r #ServerHeartbeatSucceededEvent.replyQrr%c>[TU]$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 rrrs r&r%ServerHeartbeatSucceededEvent.awaitedVwr%cSRURRURURUR UR 5$)Nz,<{} {} duration: {}, awaited: {}, reply: {}>rrrrr rr rs r&r&ServerHeartbeatSucceededEvent.__repr__bs@=DD NN # #    MM LL JJ   r%r) r floatr r rrrrXr:r;r:r)r:r rYrrr r!r"r#rrrr r rrr$rrs@r&ryry=s *IW\&+[TU]X45 XlX lgr)rr%_ServerHeartbeatFailedEvent__duration"_ServerHeartbeatFailedEvent__replyrs r&r#ServerHeartbeatFailedEvent.__init__urr%cUR$r )rrs r&r #ServerHeartbeatFailedEvent.duration|rr%cUR$)zA subclass of :exc:`Exception`.)rrs r&r  ServerHeartbeatFailedEvent.replyrr%c>[TU]$rrrs r&r"ServerHeartbeatFailedEvent.awaitedrr%cSRURRURURUR UR 5$)Nz.<{} {} duration: {}, awaited: {}, reply: {!r}>rrs r&r#ServerHeartbeatFailedEvent.__repr__s@?FF NN # #    MM LL JJ   r%r) r rr  ExceptionrrrrXr:r;r)r:r&rYrrrs@r&rzrzls *I[`&/@HSW     r%rzc\rSrSrSrS#Sjr\S$Sj5r\S$Sj5r\S$Sj5r \S$Sj5r \S$Sj5r S%S jr S&S'S jjr S(S)S jjrS*S+S jjrS,SjrS-SjrS.SjrS/SjrS/SjrS0SjrS1SjrS1SjrS2SjrS3SjrS4SjrS5S6SjjrS4SjrS7SjrS8SjrS9SjrS4Sjr S:Sjr!S8S jr"S7S!jr#S"r$g );_EventListenersizConfigure event listeners for a client instance. Any event listeners registered globally are included by default. :param listeners: A list of event listeners. c[RSSUl[RSSUl[R nUSSUl[RSSUl[RSSUl UbUHn[U[5(aURRU5 [U[5(aURRU5 [U[5(aUR RU5 [U[ 5(aURRU5 [U["5(dMURRU5 M [%UR5Ul[%UR5Ul[%UR 5Ul[%UR5Ul[%UR5Ulgr)rr"_EventListeners__command_listenersr!_EventListeners__server_listenersr+_EventListeners__server_heartbeat_listenersr#_EventListeners__topology_listenersr_EventListeners__cmap_listenersrr(rrrqr|r@rX%_EventListeners__enabled_for_commands#_EventListeners__enabled_for_server-_EventListeners__enabled_for_server_heartbeat%_EventListeners__enabled_for_topology!_EventListeners__enabled_for_cmap)r.rlsts r&r_EventListeners.__init__s~#-#?#?#B ","="=a"@33,/F)$.$A$A!$D! * 9 9! <   c?33,,33C8c>22++2237c#:;;55<?11J $!!%(2 $!# $rXc[X5nURHnURU5 M g![a [ 5 M1f=f)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)rr+rr&rrbs r&publish_server_closed%_EventListeners.publish_server_closedsH".>11J $!!%(2 $!# $rXc[XX45nURHnURU5 M g![a [ 5 M1f=f)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)rr+rr&r)r.rrrrr/rKs r&"publish_server_description_changed2_EventListeners.publish_server_description_changedsO. > 11J $..u52 $!# $r]c[U5nURHnURU5 M g![a [ 5 M1f=f)zPublish a TopologyOpenedEvent to all topology listeners. :param topology_id: A unique identifier for the topology this server is a part of. N)rr-r~r&rr.rr/rKs r&publish_topology_opened'_EventListeners.publish_topology_openedH $K033J $!!%(4 $!# $rXc[U5nURHnURU5 M g![a [ 5 M1f=f)zPublish a TopologyClosedEvent to all topology listeners. :param topology_id: A unique identifier for the topology this server is a part of. N)rr-rr&rrls r&publish_topology_closed'_EventListeners.publish_topology_closedrorXc[XU5nURHnURU5 M g![a [ 5 M1f=f)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)rr-rr&r)r.rrrr/rKs r&$publish_topology_description_changed4_EventListeners.publish_topology_description_changedsL00DWbc33J $..u54 $!# $r]c[X5nURHnURU5 M g![a [ 5 M1f=f)z:Publish a :class:`PoolCreatedEvent` to all pool listeners.N)rer.rCr&r)r.r,r>r/rKs r&publish_pool_created$_EventListeners.publish_pool_createdsF 2//J $''.0 $!# $rXc[U5nURHnURU5 M g![a [ 5 M1f=f)z8Publish a :class:`PoolReadyEvent` to all pool listeners.N)rfr.rGr&rr.r,r/rKs r&publish_pool_ready"_EventListeners.publish_pool_readysFw'//J $%%e,0 $!# $rXc[XU5nURHnURU5 M g![a [ 5 M1f=f)z:Publish a :class:`PoolClearedEvent` to all pool listeners.N)rgr.rJr&r)r.r,rrOr/rKs r&publish_pool_cleared$_EventListeners.publish_pool_cleared sK!6KL//J $''.0 $!# $r]c[U5nURHnURU5 M g![a [ 5 M1f=f)z9Publish a :class:`PoolClosedEvent` to all pool listeners.N)rhr.rMr&rrzs r&publish_pool_closed#_EventListeners.publish_pool_closedsF(//J $&&u-0 $!# $rXc[X5nURHnURU5 M g![a [ 5 M1f=f)zGPublish a :class:`ConnectionCreatedEvent` to all connection listeners. N)rir.rPr&rr.r,rr/rKs r&publish_connection_created*_EventListeners.publish_connection_created"sH'w>//J $--e40 $!# $rXc[XU5nURHnURU5 M g![a [ 5 M1f=f)zDPublish a :class:`ConnectionReadyEvent` to all connection listeners.N)rjr.rSr&rr.r,rr r/rKs r&publish_connection_ready(_EventListeners.publish_connection_ready-sJ%WXF//J $++E20 $!# $r]c[XU5nURHnURU5 M g![a [ 5 M1f=f)zFPublish a :class:`ConnectionClosedEvent` to all connection listeners. N)rkr.rWr&r)r.r,rrr/rKs r&publish_connection_closed)_EventListeners.publish_connection_closed8sJ&gfE//J $,,U30 $!# $r]c[U5nURHnURU5 M g![a [ 5 M1f=f)zOPublish a :class:`ConnectionCheckOutStartedEvent` to all connection listeners. N)rlr.rZr&rrzs r&$publish_connection_check_out_started4_EventListeners.publish_connection_check_out_startedCsH/w7//J $77>0 $!# $rXc[XU5nURHnURU5 M g![a [ 5 M1f=f)zNPublish a :class:`ConnectionCheckOutFailedEvent` to all connection listeners. N)rmr.r]r&r)r.r,rr r/rKs r&#publish_connection_check_out_failed3_EventListeners.publish_connection_check_out_failedNsJ .gxH//J $66u=0 $!# $r]c[XU5nURHnURU5 M g![a [ 5 M1f=f)zJPublish a :class:`ConnectionCheckedOutEvent` to all connection listeners. N)rnr.r`r&rrs r&publish_connection_checked_out._EventListeners.publish_connection_checked_out[sJ *'(K//J $11%80 $!# $r]c[X5nURHnURU5 M g![a [ 5 M1f=f)zIPublish a :class:`ConnectionCheckedInEvent` to all connection listeners. N)ror.rcr&rrs r&publish_connection_checked_in-_EventListeners.publish_connection_checked_inhsH)@//J $0070 $!# $rX) __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_listeners)rz"Optional[Sequence[_EventListener]]rY)r:zlist[_EventListeners]r)rrrrrrrrrrrJrrrr:r;)NNFr)r rr rrrrrrrrrrJrrrrOrXrrr:r;)NNr)r rrrrrrrrrrrrJrrrrrr:r;r) rrr rr r rrXr:r;) rrr rr r&rrXr:r;r) rrrrrrrr r:r;r)rrrrrr r:r;rEr8rrWr)r,rrrr rr:r;)r,rrrrrr:r;)r,rrrr rr:r;)%rr r!r"r#rrr7r;r>rArDrGrLrPrSrVr[r_rcrfrirmrqrtrwr{r~rrrrrrrrr$rr%r&r(r(sY>2++))33++'' " $)-$$$$$$ $$  $$ , $$$$'$$ $$\ $)-"'/$/$/$ /$  /$  /$,/$/$'/$ /$/$ /$r $)-*$*$*$ *$  *$  *$,*$*$'*$*$ *$X $$%$16$?D$OS$ $&$%$16$?H$SW$ $& $ $$/$+$! $  $  $0 $ $$1$-$ $  $($$', $ $' $ $ $  $$ $ $ $03 $?D $  $ $ $ $ $), $8= $  $ $ $03 $?D $  $ $r%r()rrr:r)rrrSequence[_EventListeners]r:r)rrr:r;)rrrzMapping[str, Any]r:rX)Kr# __future__rdatetime collectionsrrtypingrrrr r bson.objectidr pymongo.hellor r pymongo.helpers_sharedrrpymongo.typingsrrrpymongo.server_descriptionrpymongo.topology_descriptionrrrrr(r@rqr|rrrrrrr9r<r=r%rerfrgrhr\rfrlrvrrirjrkrlrmrnrorrrrrrrrrrxryrzr(rr%r&rsl\#'BB",I2"<@  BB + 77"n":u"^u"p"n">"~"<"^"<+  5$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"7, $9, ^- !6- `U$U$r%