iSt %SrSSKJr SSKJr SSKJrJrJrJ r J r J r J r J r SSKJr SSKJr SSKJr SSKJrJr SS KJrJrJrJr SS KJr SS KJr SS K J!r! SS K"J#r# "SS\ 5r$\$"\%"S56r&\&RN\&RP4r)S\*S'\\\/\\4r+"SS5r,\!RZ\&RP\!R\\&R^\!R`\&Rb\!Rd\&Rb\!Rf\&Rb0r4SSjr5SSjr6SSjr7SSjr8S Sjr9S!Sjr:g)"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 PyMongoError)PrimaryReadPreference _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%I/app/mltbenv/lib/python3.13/site-packages/pymongo/topology_description.pyrr-s# K L Lr,rztuple[int, int]SRV_POLLING_TOPOLOGIESc\rSrSrSSjrSSjrSSjrS SjrS!SjrS"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$Sj5r\ S$Sj5rS+SjrS,S-SjjrS.S/Sjjr\R:4S0SjjrS*SjrS%Sjr Sr!g)1TopologyDescription?cXlX0lX lX@lXPl[ URR 55UlX`lSUl UR[R:waUR5 URnU(dSUlg[SU55(aSUlg[!SU55Ulg)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__..lsUDTq22d:DTsc38# UHoRv M g7fr5r6r8s r-r;r<os+;Ka11;K)_topology_type_replica_set_name_server_descriptions_max_set_version_max_election_idlistvalues_candidate_servers_topology_settings_incompatible_err TOPOLOGY_TYPEr$_init_incompatible_errreadable_servers_ls_timeout_minutesanymin)self topology_typeserver_descriptionsreplica_set_namemax_set_versionmax_election_idtopology_settingsrKs r-__init__TopologyDescription.__init__@s&,!1$7! / /"&t'@'@'G'G'I"J#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).) rArEis_server_type_knownmin_wire_versionrMAX_SUPPORTED_WIRE_VERSIONmax_wire_versionMIN_SUPPORTED_WIRE_VERSIONaddressrHMIN_SUPPORTED_SERVER_VERSION)rOr:server_too_newserver_too_olds r-rJ*TopologyDescription._init_incompatible_errss.**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)rHrrOs r-check_compatible$TopologyDescription.check_compatibles#  ! !$T%;%;< < "r,cXR;$r5)rA)rOr_s r- has_serverTopologyDescription.has_servers3333r,cRURUR5n[X5$)z;A copy of this description, with one server marked Unknown.)rA to_unknownupdated_topology_description)rOr_ unknown_sds r- reset_server TopologyDescription.reset_servers&..w7BBD +D==r,c<UR[R:Xa[RnO URnURVs0sHo"[ U5_M nn[ UUURURURUR5$s snf)z>cV[SURR555$)z7Whether there are any Servers of types besides Unknown.c3J# UHoR(dMUv M g7fr5)rZr8s r-r;8TopologyDescription.has_known_servers..s[@DZDZ11@s# #)rMrArEres r-has_known_servers%TopologyDescription.has_known_serverss$[d77>>@[[[r,cURR5Vs/sHoR(dMUPM sn$s snf)zList of readable Servers.)rArE is_readablers r-rK$TopologyDescription.readable_serverss1 44;;=O=a=OOOrcUR$)z0List of Servers excluding deprioritized servers.)rFres r-candidate_servers%TopologyDescription.candidate_serverss&&&r,cbURnU(a[SUR55$g)z3Minimum of all servers' max wire versions, or None.c38# UHoRv M g7fr5)r]r8s r-r;:TopologyDescription.common_wire_version..sF3Ea))3Er>N)rrNrOserverss r-common_wire_version'TopologyDescription.common_wire_versions,$$ F43E3EFF Fr,c.URR$r5)rGheartbeat_frequencyres r-r'TopologyDescription.heartbeat_frequency s&&:::r,c.URR$r5)rG_srv_max_hostsres 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@@) rQround_trip_timer_rappendrNrGlocal_threshold_msr float)rO selectionround_trip_timesserverconfig_err_msgfastest thresholdr:s r-_apply_local_threshold*TopologyDescription._apply_local_thresholdsI(*33F%%-#>v~~>NNefjekkvxAxUxUwV"W(88  # #F$:$: ; 4 &'++>>G 22 2UA--.8YF 2   s #%C CNcU(dURUlgUVs1sHo"RiM nnURVs/sHnURU;dMUPM nnU=(d URUlgs snfs snf)zBFilter out deprioritized servers from a list of server candidates.N)rrFr_)rOdeprioritized_serverssddeprioritized_addressesrfiltereds r-_filter_servers#TopologyDescription._filter_servers$s%&*&8&8D #>)@@0  '/&D$2D2DD # 'SsA>BBc*[USS5(a<URnU(a)XQR:a[SXRU4-5e[ U[ 5(aUR U5 UR[R:Xa/$UR[R[R4;a UR$U(a<UR5RU5nU(aUR(aU/$/$UR!U5 UR[R":Xa[%U5[&LaUR(H7nUR*[,R.:XdM#U/nU(aU"U5nUs $ U(a=UH7nUR*[,R.:XdM#U/nU(aU"U5nUs $ /$[0R2"U5n UR[R4:waEU"U 5n U (d6U(a/UR!S5 [0R2"U5n U"U 5n Ub(U (a!U R7U"U R55n UR9U 5$)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 r[rzF%s requires min wire version %d, but topology's min wire version is %dN)getattrrr[r isinstancerselection_hookrPrIr#rr$rrQgetrZrr!typerrF server_typer RSPrimaryrfrom_topology_descriptionr"with_server_descriptionsr) rOselectorr_custom_selectorr common_wv descriptionrrrrs r-apply_selector"TopologyDescription.apply_selector3s+* 8/ 3 300IY)B)BB(*-57P7PR[,\] h . .  # #D )   !6!6 6I   M$8$8-:T:T#U U%% % 22488AK$/K4T4TK= \Z\ \ 23   !D!D Dh[bIb-->>[%:%::$C&-c2J .%/B~~)>)>>!d*"1#"6C" 0I77=   !6!6 6 +I!6$$T*%??E $Y/   &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_preferencerMr)rOrs r-has_readable_server'TopologyDescription.has_readable_servers+ ''(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 )rrPRIMARYres r-has_writable_server'TopologyDescription.has_writable_servers''(>(>??r,c[URR5SS9nSRURR UR RURU5$)NcUR$r5)r_)rs r-.TopologyDescription.__repr__..sBJJr,)keyz-<{} id: {}, topology_type: {}, servers: {!r}>) sortedrArEformat __class__r&rG _topology_idr|rs r-__repr__TopologyDescription.__repr__sY2299;AVW>EE NN # #  # # 0 0  # #    r,) rFrHrLrCrBr@rArGr?)rPrrQ!dict[_Address, ServerDescription]rR Optional[str]rS Optional[int]rTOptional[ObjectId]rUrreturnNone)rr)r_rrbool)r_rrr1)rr1)rr)rr)rstr)rr)rr)rr)rlist[ServerDescription])rr)rzOptional[Selection]rrr5)r!Optional[list[ServerDescription]]rr)NNN) rrr_zOptional[_Address]rzOptional[_ServerSelector]rrrr)rrrr)"r&r'r(r)rVrJrfrirorsrQpropertyrPr|rRrSrTr7rrrKrrrrrrrrrrrrr+r%r,r-r1r1?s11?1( 1 ' 1 , 11 1f-^=4>  &0 ##::&&%%%%((YY\\PP'';;66 &JN E%F E  E$'+59CG M6M6$M63 M6 A M6 ! M6^BPAWAW9 @ r,r1cURnURnURnURnURnUR 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 '{}')errorrY)#r_rPrRrSrTrrQrIrrrrlr1rGr#r Standalone LoadBalancerlenseedspopRSGhost_SERVER_TYPE_TO_TOPOLOGY_TYPEr"Mongosr r_update_rs_from_primary RSSecondary RSArbiterRSOther!_update_rs_no_primary_from_memberr!_check_has_primary#_update_rs_with_primary_from_member) topology_descriptionserver_descriptionr_rPset_namerSrTrrrrs r-rmrms!((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)rPr/rQsetkeysrDrrrrrrNrr1rRrSrTrG)rseedlistrrr_ 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;aQSU;a?XV:a:UR[SUSU355XR'[U5XU4$UR nUR bUbUR U:a UR nOUR UR 4nXC4n[SU55n[SU55nXx:a:UR[SUSU355XR'[U5XU4$UR nUR nUR5Hdn U R[RLdM"U RUR:wdM>U R[S55X 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). Nz# UHoc [5OUv M g7fr5r r9is r-r;*_update_rs_from_primary..t![HZ1i&(Q">HZc3># UHoc [5OUv M g7fr5r rs r-r;rur r z6primary marked stale due to discovery of newer primary)rRrr_rr] set_version election_idrlrtuplerErrr all_hostsrr) rrrRrrSrTnew_election_tuplemax_election_tuplenew_election_safemax_election_safer new_addressaddrs r-rrFs ->> @@ @ "**+!#&(8?ZZ**26H6Y6Y\^6^%7%C%CEWEcEc$d%4$F ) )--2D2Y2D2O2O VWiVjkABTAUV3../ *#.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). )rIr rRrr_rrr)rrrRrrPr_s r-rrs"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. )rErrrrIr!r )rrr:s r-rrs@ZZ\ ==K11 1 66 6000r,N)rr1rrrr1)rr1rzlist[tuple[str, Any]]rr1) rr+MutableMapping[_Address, ServerDescription]rRrrrrSrrTrrzr*s#    ";XX8.+$JuQx( ,9+@+@-BWBW*XXD!234d;L6MMNe e V  --=>>]>>=<<:: !e-eCTeeP(-(9N((VUY 4UY#UY*UY# UY ( UY B UYp# 4###*# #.+ 4+#+*+ +@ 1r,