&g&n %SrSSKJr SSKJr SSKJrJrJrJ r J r J r J r J r SSKJr SSKJr SSKJr SSKJrJr SS KJrJrJr SS KJr SS KJr SS KJ r SS K!J"r" "SS\ 5r#\#"\$"S56r%\%RL\%RN4r(S\)S'\\\/\\4r*"SS5r+\ RX\%RN\ RZ\%R\\ R^\%R`\ Rb\%R`\ Rd\%R`0r3SSjr4SSjr5SSjr6SSjr7S Sjr8S!Sjr9g)"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)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$aC:\Suresh\moveshuttle\MDcreated\moveengine\venv\Lib\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 g7fr4r5r7s r,r:r;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_settingsrGs 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_VERSIONaddressrDMIN_SUPPORTED_SERVER_VERSION)rKr9server_too_newserver_too_olds r,rF*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)rDrrKs r,check_compatible$TopologyDescription.check_compatibles#  ! !$T%;%;< < "r+cXR;$r4)r@)rKr\s r, has_serverTopologyDescription.has_servers3333r+cRURUR5n[X5$)z;A copy of this description, with one server marked Unknown.)r@ to_unknownupdated_topology_description)rKr\ unknown_sds r, reset_server TopologyDescription.reset_servers&..w7BBD +D==r+c<UR[R:Xa[RnO URnURVs0sHo"[ U5_M nn[ UUURURURUR5$s snf)zrEr rr@rr0r?rArBrC)rKrLr\sdss r,resetTopologyDescription.resets   -"E"E E)==M //MCGB[B[\B[w)'22B[\"    " "  ! !  ! !  # #   ]s Bc6URR5$)zKdict of (address, :class:`~pymongo.server_description.ServerDescription`). )r@copyrbs r,rM'TopologyDescription.server_descriptionss((--//r+cUR$)zThe type of this topology.)r>rbs r,rL!TopologyDescription.topology_types"""r+c<[RUR$)zEThe topology type as a human readable string. .. versionadded:: 3.4 )rE_fieldsr>rbs r,topology_type_name&TopologyDescription.topology_type_names $$T%8%899r+cUR$)zThe replica set name.)r?rbs r,rN$TopologyDescription.replica_set_names%%%r+cUR$)z1Greatest setVersion seen from a primary, or None.)rArbs r,rO#TopologyDescription.max_set_version$$$r+cUR$)z1Greatest electionId seen from a primary, or None.)rBrbs r,rP#TopologyDescription.max_election_idrr+cUR$)z)Minimum logical session timeout, or None.)rHrbs r,r63TopologyDescription.logical_session_timeout_minutess'''r+cURR5Vs/sHoR(dMUPM sn$s snf)z)List of Servers of types besides Unknown.)r@rVrWrKr9s 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 g7fr4)rWr7s r,r:8TopologyDescription.has_known_servers..s[@DZDZ11@s# #)rIr@rVrbs r,has_known_servers%TopologyDescription.has_known_serverss$[d77>>@[[[r+cURR5Vs/sHoR(dMUPM sn$s snf)zList of readable Servers.)r@rV is_readablers r,rG$TopologyDescription.readable_serverss1 44;;=O=a=OOOrcbURnU(a[SUR55$g)z3Minimum of all servers' max wire versions, or None.c38# UHoRv M g7fr4)rZr7s r,r::TopologyDescription.common_wire_version..sF3Ea))3Er=N)rrJrKserverss r,common_wire_version'TopologyDescription.common_wire_versions,$$ F43E3EFF Fr+c.URR$r4)rCheartbeat_frequencyrbs r,r'TopologyDescription.heartbeat_frequencys&&:::r+c.URR$r4)rC_srv_max_hostsrbs 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@@) rMround_trip_timer\rappendrJrClocal_threshold_msr float)rK selectionround_trip_timesserverconfig_err_msgfastest thresholdr9s 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 rXrzF%s requires min wire version %d, but topology's min wire version is %d)getattrrrXr isinstancerselection_hookrLrEr"rr#rrMgetrfrom_topology_descriptionr!with_server_descriptionsr)rKselectorr\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_preferencerIr)rKrs 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 )rrPRIMARYrbs r,has_writable_server'TopologyDescription.has_writable_servercs''(>(>??r+c[URR5SS9nSRURR UR RURU5$)NcUR$r4)r\)sds r,.TopologyDescription.__repr__..osBJJr+)keyz-<{} id: {}, topology_type: {}, servers: {!r}>) sortedr@rVformat __class__r%rC _topology_idryrs r,__repr__TopologyDescription.__repr__msY2299;AVW>EE NN # #  # # 0 0  # #    r+)rDrHrBrAr?r@rCr>)rLrrM!dict[_Address, ServerDescription]rN Optional[str]rO Optional[int]rPOptional[ObjectId]rQrreturnNone)rr)r\rrbool)r\rrr0)rr0)rr)rr)rstr)rr)rr)rr)rlist[ServerDescription])rr)rzOptional[Selection]rr)NN)rrr\zOptional[_Address]rzOptional[_ServerSelector]rr)rrrr) r%r&r'r(rRrFrcrfrlrprMpropertyrLryrNrOrPr6rrrGrrrrrrrrrrr*r$r+r,r0r0?s00?0( 0 ' 0 , 00 0d-^=4>  &0 ##::&&%%%%((YY\\PP;;66 *'+59 3636$363 36 ! 36jBPAWAW9 @ r+r0cURnURnURnURnURnUR 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 '{}')errorrU)#r\rLrNrOrP server_typerMrErrrrir0rCr"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\rLset_namerOrPrrors r,rjrjs!((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)rLr.rMsetkeyslistrrrrrrJrr0rNrOrPrC)rseedlistror\ 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 g7fr4r r8is r,r:*_update_rs_from_primary..E![HZ1i&(Q">HZc3># UHoc [5OUv M g7fr4r rs r,r:rFrrz6primary marked stale due to discovery of newer primary)rNrr\rrZ set_version election_idrirtuplerVrrr all_hostsrr) rorNrrOrPnew_election_tuplemax_election_tuplenew_election_safemax_election_safer new_addressaddrs r,rrs ->> @@ @ "**+!#&(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). )rErrNrr\rrr )rorNrrLr\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. )rVrrrrEr r)ror9s r,rrs@ZZ\ ==K11 1 66 6000r+N)rr0rrrr0)rr0rzlist[tuple[str, Any]]rr0) ro+MutableMapping[_Address, ServerDescription]rNrrrrOrrPrrzrs#    ";OO8.+$JuQx( ,9+@+@-BWBW*XXD!234d;L6MMNv v x  --=>>]>>=<<:: !e-eCTeeP(-(9N((VUY 4UY#UY*UY# UY ( UY B UYp# 4###*# #.+ 4+#+*+ +@ 1r+