hX dZddlmZddlmZddlmZddlmZddl m Z ddl m Z ddl mZed gd ed Zej"ej$fZGd d eZej,ej$ej.ej0ej2ej4ej6ej4ej8ej4iZdZdZdZ dZ!dZ"dZ#y)z*Represent a deployment of MongoDB servers.) namedtuple)common)ConfigurationError)ReadPreferenceServerDescription) Selection) SERVER_TYPE TopologyType)SingleReplicaSetNoPrimaryReplicaSetWithPrimaryShardedUnknown LoadBalancedceZdZdZdZdZdZdZdZdZ e dZ e d Z e d Z e d Ze d Ze d Ze dZe dZe dZe dZe dZddZej0fdZdZdZy)TopologyDescriptioncN||_||_||_||_||_||_d|_|jtjk7r|j|j}|sd|_ ytd|Drd|_ ytd|D|_ y)aRepresentation of a deployment of MongoDB servers. :Parameters: - `topology_type`: initial type - `server_descriptions`: dict of (address, ServerDescription) for all seeds - `replica_set_name`: replica set name or None - `max_set_version`: greatest setVersion seen from a primary, or None - `max_election_id`: greatest electionId seen from a primary, or None - `topology_settings`: a TopologySettings Nc38K|]}|jduywNlogical_session_timeout_minutes.0ss Z/var/www/html/eduruby.in/venv/lib/python3.12/site-packages/pymongo/topology_description.py z/TopologyDescription.__init__..XsUq22d:Usc34K|]}|jywrrrs rrz/TopologyDescription.__init__..[s+6711+)_topology_type_replica_set_name_server_descriptions_max_set_version_max_election_id_topology_settings_incompatible_err TOPOLOGY_TYPEr_init_incompatible_errreadable_servers_ls_timeout_minutesanymin)self topology_typeserver_descriptionsreplica_set_namemax_set_versionmax_election_idtopology_settingsr*s r__init__zTopologyDescription.__init__,s(,!1$7! / /#4"&   -"<"< <  ' ' ) 00'+D $ UDTU U'+D $'*+;K+(D $c<|jjD]}|js|jduxr|jtj kD}|j duxr|j tjk}|rAd|jd|jd|jtj fz|_ |sd|jd|jd|j tjtjfz|_ yy)z>Internal compatibility check for non-load balanced topologies.Nz]Server at %s:%d requires wire version %d, but this version of PyMongo only supports up to %d.rzgServer at %s:%d reports wire version %d, but this version of PyMongo requires at least %d (MongoDB %s).) r#valuesis_server_type_knownmin_wire_versionrMAX_SUPPORTED_WIRE_VERSIONmax_wire_versionMIN_SUPPORTED_WIRE_VERSIONaddressr'MIN_SUPPORTED_SERVER_VERSION)r.rserver_too_newserver_too_olds rr)z*TopologyDescription._init_incompatible_err_s'**113+ A)) ""$.K&&)J)JJ ""$.K&&)J)JJ  A !  ! **99 & L !  ! **99;; &W+ r6cF|jrt|jy)zRaise ConfigurationError if any server is incompatible. A server is incompatible if its wire protocol version range does not overlap with PyMongo's. N)r'rr.s rcheck_compatiblez$TopologyDescription.check_compatibles#  ! !$T%;%;< < "r6c||jvSr)r#)r.r?s r has_serverzTopologyDescription.has_servers$3333r6cT|j|j}t||S)z;A copy of this description, with one server marked Unknown.)r# to_unknownupdated_topology_description)r.r? unknown_sds r reset_serverz TopologyDescription.reset_servers(..w7BBD +D*==r6c|jtjk(rtj}n |j}t d|j D}t |||j|j|j|jS)z.sbWG.w78bs) r!r(rr dictr#rr"r$r%r&)r.r/sdss rresetzTopologyDescription.resets{   -"E"E E)==M //MbHaHabb"    " "  ! !  ! !  # #   r6c6|jjS)zRDict of (address, :class:`~pymongo.server_description.ServerDescription`).)r#copyrDs rr0z'TopologyDescription.server_descriptionss((--//r6c|jS)zThe type of this topology.)r!rDs rr/z!TopologyDescription.topology_types"""r6c<tj|jS)zUThe topology type as a human readable string. .. versionadded:: 3.4 )r(_fieldsr!rDs rtopology_type_namez&TopologyDescription.topology_type_names $$T%8%899r6c|jS)zThe replica set name.)r"rDs rr1z$TopologyDescription.replica_set_names%%%r6c|jS)z1Greatest setVersion seen from a primary, or None.)r$rDs rr2z#TopologyDescription.max_set_version$$$r6c|jS)z1Greatest electionId seen from a primary, or None.)r%rDs rr3z#TopologyDescription.max_election_idrZr6c|jS)z)Minimum logical session timeout, or None.)r+rDs rrz3TopologyDescription.logical_session_timeout_minutess'''r6cv|jjDcgc]}|js|c}Scc}w)z)List of Servers of types besides Unknown.)r#r9r:r.rs r known_serversz!TopologyDescription.known_serverss/ 44;;=XaAWAWXXX66cVtd|jjDS)z7Whether there are any Servers of types besides Unknown.c3:K|]}|js|ywr)r:rs rrz8TopologyDescription.has_known_servers..s[ADZDZ1[s)r,r#r9rDs rhas_known_serversz%TopologyDescription.has_known_serverss$[d77>>@[[[r6cv|jjDcgc]}|js|c}Scc}w)zList of readable Servers.)r#r9 is_readabler^s rr*z$TopologyDescription.readable_serverss- 44;;=OaOOOr`cX|j}|rtd|jDSy)z3Minimum of all servers' max wire versions, or None.c34K|]}|jywr)r=rs rrz:TopologyDescription.common_wire_version..sFaq))Fr N)r_r-r.serverss rcommon_wire_versionz'TopologyDescription.common_wire_versions,$$ F43E3EFF Fr6c.|jjSr)r&heartbeat_frequencyrDs rrlz'TopologyDescription.heartbeat_frequencys&&:::r6NcNfd}t|ddr8j}|r*||jkrtd||j|fzjt j t jfvr jS|r&jj|}|r|gSgSjt jk(rtj}n|tj}|#|r!|j||j}||S)Nc|sgSj}td|jD}|jdz }|jDcgc]}|j|z |kr|c}Scc}w)Nc34K|]}|jywr)round_trip_timers rrzTTopologyDescription.apply_selector..apply_local_threshold..sS!++Sr g@@)r&r-r0local_threshold_msrp) selectionsettingsfastest thresholdrr.s rapply_local_thresholdzATopologyDescription.apply_selector..apply_local_thresholdsy ..HSY5R5RSSG 33fI%Y//r6cdtjd|t|j|dS)aDoes this topology have any readable servers available matching the given read preference? :Parameters: - `read_preference`: an instance of a read preference from :mod:`~pymongo.read_preferences`. Defaults to :attr:`~pymongo.read_preferences.ReadPreference.PRIMARY`. .. note:: When connected directly to a single server this method always returns ``True``. .. versionadded:: 3.4 read_preferenceN)rvalidate_read_preferencer,r)r.rs rhas_readable_serverz'TopologyDescription.has_readable_server s- ''(9?K4&&=>>r6c@|jtjS)zDoes this topology have a writable server available? .. note:: When connected directly to a single server this method always returns ``True``. .. versionadded:: 3.4 )rrPRIMARYrDs rhas_writable_serverz'TopologyDescription.has_writable_server1s''(>(>??r6c t|jjd}d|jjd|j j d|jd|d S)Nc|jSr)r?)sds rz.TopologyDescription.__repr__..=s BJJr6)key)sortedr#r9 __class____name__r& _topology_idrWrhs r__repr__zTopologyDescription.__repr__;sP2299;AVW NN # #  # # 0 0  # #    r6r)r __module__ __qualname__r5r)rErGrLrQr0propertyr/rWr1r2r3rr_rcr*rjrlrrrrrrr6rrr+s+1f-^=4>  &0 ##::&&%%%%((YY\\PP;;*0X3A2H2H?"@ r6rc|j}|j}|j}|j}|j}|j }|j }|||<|tjk(rj|@||jk7r1td|d|jd} |j| ||<ttj|||||jS|tjk(r|tjtj fvrEt#|jj$dk(rtj}n=|j'|n+|tjtj(fvr t*|}|tj,k(r6|tj.tjfvr|j'|nw|tj0k(r|tjtj.fvr|j'|n/|tj2k(rt5|||||\}}}}n|tj6tj8tj:fvrt=|||\}}n|tj>k(r|tjtj.fvr|j'|tA|}nr|tj2k(rt5|||||\}}}}nJ|tj6tj8tj:fvrtC|||}n tA|}t||||||jS)a}Return an updated copy of a TopologyDescription. :Parameters: - `topology_description`: the current TopologyDescription - `server_description`: a new ServerDescription that resulted from a hello call Called after attempting (successfully or not) to call hello on the server at server_description.address. Does not modify topology_description. z8client is configured to connect to a replica set named 'z(' but this node belongs to a set named '')errorr8)"r?r/r1r2r3 server_typer0r(r rrIrr&rr Standalone LoadBalancerlenseedspopRSGhost_SERVER_TYPE_TO_TOPOLOGY_TYPErMongosr RSPrimary_update_rs_from_primary RSSecondary RSArbiterRSOther!_update_rs_no_primary_from_memberr_check_has_primary#_update_rs_with_primary_from_member) topology_descriptionserver_descriptionr?r/set_namer2r3rrPrs rrJrJRs!((G)66M#44H*::O*::O$00K  2 2 4C&CL ,,,  H0B0S0S$S&/@@BE .88u8ECL"      3 3    --- ;11;3K3KL L'::@@AQF - 4 4  !4!4k6I6I J J9+FM --- {11;3F3FG G GGG  -;; ; ;11;3E3EF F GGG  K11 1JaX1?OK G]Ho[44k6K6K[M`M`a a&GX1' #M8 -== = ;11;3E3EF F GGG .s3M K11 1JaX1?OK G]Ho[44k6K6K[M`M`a a?XOabM/s3M  //  r6c|jtvsJ|j}t|j t|k(r|S|D]}||vst |||<t |j D]}||vs|j|t|j||j|j|j|jS)zReturn an updated copy of a TopologyDescription. :Parameters: - `topology_description`: the current TopologyDescription - `seedlist`: a list of new seeds new ServerDescription that resulted from a hello call ) r/SRV_POLLING_TOPOLOGIESr0setkeysrlistrrr1r2r3r&)rseedlistrPr?s r)_updated_topology_description_srv_pollingrs - -1G GG G  2 2 4C 388:#h-'##6 # ,W5CL6  # ( " GGG  ** --,,,,//  r6c4| |j}n9||jk7r*|j|jt||||fS||f}d|jvrKd|vr;||jkDr,|j ||j<t||||fS|j }|j||j|kDr |j}|jD]W}|jtjus |j|jk7s:|j ||j<n|jD]}||vst|||<t||jz D]}|j|t||||fS)agUpdate topology description from a primary's hello response. Pass in a dict of ServerDescriptions, current replica set name, the ServerDescription we are processing, and the TopologyDescription's max_set_version and max_election_id if any. Returns (new topology type, new replica_set_name, new max_set_version, new max_election_id). N)r1rr?relection_tuplerI election_id set_versionr9rr r all_hostsrr) rPr1rr2r3max_election_tupleserver new_addressaddrs rrrs->> /@@ @ "**+"3')9?O\\(/9 %444 * *"%7%F%FF/A.K.K.MC"** +&s+-=P_` `,88%%1#5#A#AO#S-88**,    +"7"7 7"4"<"<<#)"3"3"5C   *33> c !0=C > C-777   s #%5 XXr6c |J||jk7r&|j|jt |S|jr4|j|jk7r|j|jt |S)zRS with known primary. Process a response from a non-primary. Pass in a dict of ServerDescriptions, current replica set name, and the ServerDescription we are processing. Returns new topology type. )r1rr?mer)rPr1rs rrrs  '' '->>> "**+ c ""   #5#=#=ASAVAV#V "**+ c ""r6cltj}| |j}n.||jk7r|j|j||fS|j D]}||vst |||<|jr4|j|jk7r|j|j||fS)zRS without known primary. Update from a non-primary's response. Pass in a dict of ServerDescriptions, current replica set name, and the ServerDescription we are processing. Returns (new topology type, new replica_set_name). )r(r r1rr?rrr)rPr1rr/r?s rrr2s"55M->> /@@ @ "**+...&//6 # ,W5CL6!3!;!;?Q?T?T!T "**+ * **r6c|jD]1}|jtjk(s!tj cStj S)zCurrent topology type is ReplicaSetWithPrimary. Is primary still known? Pass in a dict of ServerDescriptions. Returns new topology type. )r9rr rr(rr )rPrs rrrNsEZZ\1 ==K11 1 66 61000r6N)$__doc__ collectionsrpymongorpymongo.errorsrpymongo.read_preferencesrpymongo.server_descriptionrpymongo.server_selectorsr pymongo.server_typer ranger(rrrobjectrrrrrr rrrrJrrrrrrr6rrs1"-38.+    8  (//1F1FGX &X | --=>>]>>=<<:: !cL!H@YF#&+8 1r6