IiTi %SrSSKJr SSKJr SSKJrJrJrJ r J r J r J r J r SSKJr SSKJr SSKJr SSKJr SS KJrJrJr SS KJr SS KJr SS KJr SS K J!r! "SS\ 5r"\""\#"S56r$\$RJ\$RL4r'S\(S'\\\/\\4r)"SS5r*\RV\$RL\RX\$RZ\R\\$R^\R`\$R^\Rb\$R^0r2SSjr3SSjr4SSjr5SSjr6S Sjr7S!Sjr8g)"zRepresent a deployment of MongoDB servers. .. seealso:: This module is compatible with both the synchronous and asynchronous PyMongo APIs. ) annotations)sample)AnyCallableListMappingMutableMapping NamedTupleOptionalcastMinKey)ObjectId)common)ConfigurationError)ReadPreference _AggWritePref _ServerMode)ServerDescription) Selection) SERVER_TYPE)_AddresscR\rSrSr%S\S'S\S'S\S'S\S'S\S'S\S'S rg ) _TopologyType-intSingleReplicaSetNoPrimaryReplicaSetWithPrimaryShardedUnknown LoadBalancedN)__name__ __module__ __qualname____firstlineno____annotations____static_attributes__r#B/venv/lib/python3.13/site-packages/pymongo/topology_description.pyrr-s# K L Lr*rztuple[int, int]SRV_POLLING_TOPOLOGIESc\rSrSrSSjrSSjrSSjrSSjrSSjrS Sjr S!Sjr \ S"S j5r \ S#S j5r \ S$S j5r\ S%S j5r\ S&S j5r\ S%Sj5r\ S'Sj5r\ S(Sj5r\ S'Sj5r\ S%Sj5r\ S"Sj5r\ S"Sj5rS)SjrS*S+Sjjr\R64S,SjjrS(SjrS#SjrSrg)-TopologyDescription?cXXlX0lX lX@lXPlX`lSUlUR[R:waUR5 URnU(dSUl g[SU55(aSUl g[SU55Ul g)aRepresentation of a deployment of MongoDB servers. :param topology_type: initial type :param server_descriptions: dict of (address, ServerDescription) for all seeds :param replica_set_name: replica set name or None :param max_set_version: greatest setVersion seen from a primary, or None :param max_election_id: greatest electionId seen from a primary, or None :param topology_settings: a TopologySettings Nc3<# UHoRSLv M g7fNlogical_session_timeout_minutes.0ss r+ /TopologyDescription.__init__..ksUDTq22d:DTsc38# UHoRv M g7fr3r4r6s r+r9r:ns+;Ka11;K)_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_settingsrFs r+__init__TopologyDescription.__init__@s&,!1$7! / /#4"&   -"<"< <  ' ' ) 00'+D $ UDTU U U'+D $'*+;K+(D $r*cURR5GH-nUR(dMURSL=(a UR[R :nUR SL=(a UR [R:nU(aKSURSURS=(d SUR[R 4-Ul MU(dMSURSURS=(d SUR [R[R4-Ul g g)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_VERSIONaddressrCMIN_SUPPORTED_SERVER_VERSION)rJr8server_too_newserver_too_olds r+rE*TopologyDescription._init_incompatible_errrs.**113A)) ""$.K&&)J)JJ ""$.K&&)J)JJ  A !  ! )**99 & L !  ! )**99;; &W4r*cPUR(a[UR5eg)zRaise ConfigurationError if any server is incompatible. A server is incompatible if its wire protocol version range does not overlap with PyMongo's. N)rCrrJs r+check_compatible$TopologyDescription.check_compatibles#  ! !$T%;%;< < "r*cXR;$r3)r?)rJr[s r+ has_serverTopologyDescription.has_servers3333r*cRURUR5n[X5$)z;A copy of this description, with one server marked Unknown.)r? to_unknownupdated_topology_description)rJr[ unknown_sds r+ reset_server TopologyDescription.reset_servers&..w7BBD +D==r*c<UR[R:Xa[RnO URnURVs0sHo"[ U5_M nn[ UUURURURUR5$s snf)zr@rArB)rJrKr[sdss r+resetTopologyDescription.resets   -"E"E E)==M //MCGB[B[\B[w)'22B[\"    " "  ! !  ! !  # #   ]s Bc6URR5$)zKdict of (address, :class:`~pymongo.server_description.ServerDescription`). )r?copyras r+rL'TopologyDescription.server_descriptionss((--//r*cUR$)zThe type of this topology.)r=ras r+rK!TopologyDescription.topology_types"""r*c<[RUR$)zEThe topology type as a human readable string. .. versionadded:: 3.4 )rD_fieldsr=ras r+topology_type_name&TopologyDescription.topology_type_names $$T%8%899r*cUR$)zThe replica set name.)r>ras r+rM$TopologyDescription.replica_set_names%%%r*cUR$)z1Greatest setVersion seen from a primary, or None.)r@ras r+rN#TopologyDescription.max_set_version$$$r*cUR$)z1Greatest electionId seen from a primary, or None.)rAras r+rO#TopologyDescription.max_election_idr~r*cUR$)z)Minimum logical session timeout, or None.)rGras r+r53TopologyDescription.logical_session_timeout_minutess'''r*cURR5Vs/sHoR(dMUPM sn$s snf)z)List of Servers of types besides Unknown.)r?rUrVrJr8s r+ known_servers!TopologyDescription.known_serverss3 44;;=X=aAWAW=XXX>>cV[SURR555$)z7Whether there are any Servers of types besides Unknown.c3J# UHoR(dMUv M g7fr3)rVr6s r+r98TopologyDescription.has_known_servers..s[@DZDZ11@s# #)rHr?rUras r+has_known_servers%TopologyDescription.has_known_serverss$[d77>>@[[[r*cURR5Vs/sHoR(dMUPM sn$s snf)zList of readable Servers.)r?rU is_readablers r+rF$TopologyDescription.readable_serverss1 44;;=O=a=OOOrcbURnU(a[SUR55$g)z3Minimum of all servers' max wire versions, or None.c38# UHoRv M g7fr3)rYr6s r+r9:TopologyDescription.common_wire_version..sF3Ea))3Er<N)rrIrJserverss r+common_wire_version'TopologyDescription.common_wire_versions,$$ F43E3EFF Fr*c.URR$r3)rBheartbeat_frequencyras r+r'TopologyDescription.heartbeat_frequencys&&:::r*c.URR$r3)rB_srv_max_hostsras r+ srv_max_hosts!TopologyDescription.srv_max_hostss&&555r*cU(d/$/nURHUnURc*SURSUSUR3n[U5eUR UR5 MW [ U5nUR RS- nURVs/sH(n[[UR5U- U::dM&UPM* sn$s snf)Nzround_trip_time for server z is unexpectedly None: z , servers: g@@) rLround_trip_timer[rappendrIrBlocal_threshold_msr float)rJ selectionround_trip_timesserverconfig_err_msgfastest thresholdr8s r+_apply_local_threshold*TopologyDescription._apply_local_threshold sI(*33F%%-#>v~~>NNefjekkvxAxUxUwV"W(88  # #F$:$: ; 4 &'++>>G 22 2UA--.8YF 2   s #%C CNc[USS5(a<URnU(a)XAR:a[SXRU4-5e[ U[ 5(aUR U5 UR[R:Xa/$UR[R[R4;a UR$U(a+UR5RU5nU(aU/$/$[R "U5nUR[R":waU"U5nUb(U(a!UR%U"UR55nUR'U5$)aDList of servers matching the provided selector(s). :param selector: a callable that takes a Selection as input and returns a Selection as output. For example, an instance of a read preference from :mod:`~pymongo.read_preferences`. :param address: A server address to select. :param custom_selector: A callable that augments server selection rules. Accepts a list of :class:`~pymongo.server_description.ServerDescription` objects and return a list of server descriptions that should be considered suitable for the desired operation. .. versionadded:: 3.4 rWrzF%s requires min wire version %d, but topology's min wire version is %d)getattrrrWr isinstancerselection_hookrKrDr!rr"rrLgetrfrom_topology_descriptionr with_server_descriptionsr)rJselectorr[custom_selector common_wv descriptionrs r+apply_selector"TopologyDescription.apply_selectorsI( 8/ 3 300IY)B)BB(*-57P7PR[,\] h . .  # #D )   !6!6 6I   M$8$8-:T:T#U U%% % 22488AK$/K= 7R 777=   !6!6 6 +I  &9!:: = =>I**955r*cd[R"SU5 [URU55$)a~Does this topology have any readable servers available matching the given read preference? :param 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_preference)rvalidate_read_preferencerHr)rJrs r+has_readable_server'TopologyDescription.has_readable_serverSs+ ''(9?K4&&788r*c@UR[R5$)zDoes this topology have a writable server available? .. note:: When connected directly to a single server this method always returns ``True``. .. versionadded:: 3.4 )rrPRIMARYras r+has_writable_server'TopologyDescription.has_writable_servercs''(>(>??r*c[URR5SS9nSRURR UR RURU5$)NcUR$r3)r[)sds r+.TopologyDescription.__repr__..osBJJr*)keyz-<{} id: {}, topology_type: {}, servers: {!r}>) sortedr?rUformat __class__r$rB _topology_idrxrs r+__repr__TopologyDescription.__repr__msY2299;AVW>EE NN # #  # # 0 0  # #    r*)rCrGrAr@r>r?rBr=)rKrrL!dict[_Address, ServerDescription]rM Optional[str]rN Optional[int]rOOptional[ObjectId]rPrreturnNone)rr)r[rrbool)r[rrr/)rr/)rr)rr)rstr)rr)rr)rr)rlist[ServerDescription])rr)rzOptional[Selection]rr)NN)rrr[zOptional[_Address]rzOptional[_ServerSelector]rr)rrrr) r$r%r&r'rQrErbrerkrorLpropertyrKrxrMrNrOr5rrrFrrrrrrrrrrr)r#r*r+r/r/?s00?0( 0 ' 0 , 00 0d-^=4>  &0 ##::&&%%%%((YY\\PP;;66 *'+59 3636$363 36 ! 36jBPAWAW9 @ r*r/cURnURnURnURnURnUR nUR 5nXU'U[R:XaoUbDXAR:wa5[SRXAR55n URU S9X'[[RUUUUUR5$U[R:XaU[R [R"4;aF[%URR&5S:Xa[RnO?UR)U5 O-U[R[R*4;a [,UnU[R.:Xa7U[R0[R4;aUR)U5 GOxU[R2:XaU[R [R04;aUR)U5 GO-U[R4:Xa[7XXU5up4pVGOU[R8[R:[R<4;a[?XU5up4OU[R@:XaU[R [R04;aUR)U5 [CU5nOpU[R4:Xa[7XXU5up4pVOKU[R8[R:[R<4;a [EXU5nO [CU5n[UUUUUUR5$)aVReturn an updated copy of a TopologyDescription. :param topology_description: the current TopologyDescription :param 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. zeclient is configured to connect to a replica set named '{}' but this node belongs to a set named '{}')errorrT)#r[rKrMrNrO server_typerLrDrrrrhr/rBr!r Standalone LoadBalancerlenseedspopRSGhost_SERVER_TYPE_TO_TOPOLOGY_TYPEr Mongosr 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[rKset_namerNrOrrnrs r+riris!((G)66M#44H*::O*::O$00K  2 2 4C&L ,,,  H0S0S$S&AAGAABE .88u8ECL"      3 3    --- ;11;3K3KL L'::@@AQF - 4 4  !4!4k6I6I J J9+FM --- {11;3F3FG G GGG  -;; ; ;11;3E3EF F GGG  K11 1Ja1OK G]o[44k6K6K[M`M`a a&G1' #M -== = ;11;3E3EF F GGG .s3M K11 1Ja1OK G]o[44k6K6K[M`M`a a?OabM/s3M  //  r*c UR[;deUR5n[UR 55[U5:XaU$[ UR 55HnX1;dM UR U5 M URS:wan[U5[UR 55- nUR[U5- nUS:a)[[U5[U[U555nO/nUHnX2;dM [U5X#'M [URUURURUR UR"5$)zReturn an updated copy of a TopologyDescription. :param topology_description: the current TopologyDescription :param seedlist: a list of new seeds new ServerDescription that resulted from a hello call r)rKr-rLsetkeyslistrrrrrrIrr/rMrNrOrB)rseedlistrnr[ new_hostsn_to_adds r+)_updated_topology_description_srv_pollingrs- - -1G GG G  2 2 4C 388:#h-'## #  " GGG $))Q.MC O3 '55C@ a<fY/Xs9~1NOHH  ,W5CL ** --,,,,//  r*cUc URnO8XR:wa)URUR5 [U5XU4$URbURS:aUR UR 4nX44nSU;aASU;a/XV:a*UR5XR'[U5XU4$UR nUR bUbUR U:a UR nOUR UR 4nXC4n[SU55n[SU55nXx:a*UR5XR'[U5XU4$UR nUR nUR5HZn U R[RLdM"U RUR:wdM>U R5X R' O URHn X;dM [U 5X 'M [U5UR- Hn URU 5 M [U5XU4$)aOUpdate 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). Nc3># UHoc [5OUv M g7fr3r r7is r+r9*_update_rs_from_primary..A![HZ1i&(Q">HZc3># UHoc [5OUv M g7fr3r rs r+r9rBrr)rMrr[rrY set_version election_idrhtuplerUrrr all_hostsrr) rnrMrrNrOnew_election_tuplemax_election_tuplenew_election_safemax_election_safer new_addressaddrs r+rrsA ->> @@ @ "**+!#&(8?ZZ**26H6Y6Y\^6^%7%C%CEWEcEc$d%4$F ) )--2D2Y2D2O2O2Q../)#.0@Sbbb0<>> "**+   #5#=#=ASAVAV#V "**+ c ""r*c|[RnUc URnO-XR:waURUR5 X14$UR HnX@;dM [ U5X'M UR(a5URUR:waURUR5 X14$)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). )rDrrMrr[rrr )rnrMrrKr[s r+rr|s"55M->> @@ @ "**+..&//  ,W5CL0!3!;!;?Q?T?T!T "**+  **r*cUR5H3nUR[R:XdM#[R s $ [R $)zCurrent topology type is ReplicaSetWithPrimary. Is primary still known? Pass in a dict of ServerDescriptions. Returns new topology type. )rUrrrrDrr)rnr8s r+rrs@ZZ\ ==K11 1 66 6000r*N)rr/rrrr/)rr/rzlist[tuple[str, Any]]rr/) rn+MutableMapping[_Address, ServerDescription]rMrrrrNrrOrrzrs#    "-OO8.+$JuQx( ,9+@+@-BWBW*XXD!234d;L6MMNv v x  --=>>]>>=<<:: !e-eCTeeP(-(9N((VKY 4KY#KY*KY# KY ( KY B KY\# 4###*# #.+ 4+#+*+ +@ 1r*