+ 4O|j3w a0t$Rt^RIHt^RIHt^RIHtHtH t H t H t H t H t Ht^RIHt^RIHt^RIHt^RIHtHt^RIHtHtHtHt^R IHt^R IH t ^R I!H"t"^R I#H$t$!R R] 4t%]%!]&!^4!t']'PP]'PR3t*R]+R&]] ],.] ],3,t,!RR4t-]"P\]'PR]"P^]'P`]"Pb]'Pd]"Pf]'Pd]"Ph]'Pd/t5RRlt6RRlt7RRlt8RRlt9RRlt:RRlt;R#) 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)_AddresscT]tRt^-t$R]R&R]R&R]R&R]R&R]R&R]R&RtR #) _TopologyTypeintSingleReplicaSetNoPrimaryReplicaSetWithPrimaryShardedUnknown LoadBalancedN)__name__ __module__ __qualname____firstlineno____annotations____static_attributes__r#UC:\Users\alokc\chatbot\backend\venv\Lib\site-packages\pymongo/topology_description.pyrr-s# K L Lr*rztuple[int, int]SRV_POLLING_TOPOLOGIESc]tRt^?tRRltRRltRRltRRltR R ltR R lt R Rlt ] RRl4t ] RRl4t ] RRl4t] RRl4t] RRl4t] RRl4t] RRl4t] RRl4t] RR l4t] R!R"l4t] R#R$l4t] R%R&l4t] R'R(l4tR)R*ltR7R,R-lltR8R.R/llt]P:3R0R1lltR2R3ltR4R5lt R6t!R+#)9TopologyDescriptionc4V^8dQhRRRRRRRRR R R R R R/#) topology_typerserver_descriptions!dict[_Address, ServerDescription]replica_set_name Optional[str]max_set_version Optional[int]max_election_idOptional[ObjectId]topology_settingsrreturnNoner#)formats"r+ __annotate__ TopologyDescription.__annotate__@sP111?1( 1 ' 1 , 11 1r*c WnW0nW nW@nWPn\ VPP 44VnW`nRVn VP\P8wdVP4VPpV'g RVnR#\;QJdRV4F 'gK RM RM !RV44'd RVnR#\!RV44VnR#)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<"TFqPRJxK R#5iNlogical_session_timeout_minutes.0ss& r+ /TopologyDescription.__init__..lsUDTq22d:DTsTFc38"TFqPxK R#5irBrCrEs& r+rHrIos+;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)selfr1r2r4r6r8r:rXs&&&&&&& r+__init__TopologyDescription.__init__@s&,!1$7! / /"&t'@'@'G'G'I"J#4"&   -"<"< <  ' ' ) 00'+D $ SUDTUSSSUDTU U U'+D $'*+;K+(D $r*cV^8dQhRR/#r0r;r<r#)r=s"r+r>r?ss---r*c VPP4EFMpVP'gKVPRJ;'dVP\P 8pVP RJ;'dVP \P8pV'dYRVP^,VP^,;'g^VP\P 3,Vn KV'gKRVP^,VP^,;'g^VP \P\P3,Vn R# R#)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.zgServer at %s:%d reports wire version %d, but this version of PyMongo requires at least %d (MongoDB %s).) rNrRis_server_type_knownmin_wire_versionrMAX_SUPPORTED_WIRE_VERSIONmax_wire_versionMIN_SUPPORTED_WIRE_VERSIONaddressrUMIN_SUPPORTED_SERVER_VERSION)r\rGserver_too_newserver_too_olds& r+rW*TopologyDescription._init_incompatible_errssC**113A))) ""$.KK&&)J)JJ ""$.KK&&)J)JJ  A !  ! ))**99 & L !  ! ))**99;; &W4r*cV^8dQhRR/#r`r#)r=s"r+r>r?s==$=r*c TVP'd\VP4hR#)zRaise ConfigurationError if any server is incompatible. A server is incompatible if its wire protocol version range does not overlap with PyMongo's. N)rUrr\s&r+check_compatible$TopologyDescription.check_compatibles&  ! ! !$T%;%;< < "r*c V^8dQhRRRR/#)r0rgrr;boolr#)r=s"r+r>r?s44(4t4r*c WP9#rB)rN)r\rgs&&r+ has_serverTopologyDescription.has_servers3333r*c V^8dQhRRRR/#)r0rgrr;r.r#)r=s"r+r>r?s>>H>1D>r*c ZVPV,P4p\W4#)z;A copy of this description, with one server marked Unknown.)rN to_unknownupdated_topology_description)r\rg unknown_sds&& r+ reset_server TopologyDescription.reset_servers&..w7BBD +D==r*cV^8dQhRR/#)r0r;r.r#)r=s"r+r>r?s  * r*c <VP\P8Xd\PpM VPpVPUu/uFq"\ V4bK pp\ VVVPVPVPVP4#uupi)zr?s00%F0r*c 6VPP4#)zKdict of (address, :class:`~pymongo.server_description.ServerDescription`). )rNcopyrns&r+r2'TopologyDescription.server_descriptionss((--//r*cV^8dQhRR/#r0r;rr#)r=s"r+r>r?s##s#r*c VP#)zThe type of this topology.)rLrns&r+r1!TopologyDescription.topology_types"""r*cV^8dQhRR/#r0r;strr#)r=s"r+r>r?s::C:r*c D\PVP,#)zEThe topology type as a human readable string. .. versionadded:: 3.4 )rV_fieldsrLrns&r+topology_type_name&TopologyDescription.topology_type_names $$T%8%899r*cV^8dQhRR/#)r0r;r5r#)r=s"r+r>r?s&&-&r*c VP#)zThe replica set name.)rMrns&r+r4$TopologyDescription.replica_set_names%%%r*cV^8dQhRR/#r0r;r7r#)r=s"r+r>r?s%%%r*c VP#)z1Greatest setVersion seen from a primary, or None.)rOrns&r+r6#TopologyDescription.max_set_version$$$r*cV^8dQhRR/#)r0r;r9r#)r=s"r+r>r?s%%!3%r*c VP#)z1Greatest electionId seen from a primary, or None.)rPrns&r+r8#TopologyDescription.max_election_idrr*cV^8dQhRR/#rr#)r=s"r+r>r?s(((r*c VP#)z)Minimum logical session timeout, or None.)rYrns&r+rD3TopologyDescription.logical_session_timeout_minutess'''r*cV^8dQhRR/#r0r;list[ServerDescription]r#)r=s"r+r>r?sYY6Yr*c VPP4Uu.uFqP'gKVNK up#uupi)z)List of Servers of types besides Unknown.)rNrRrbr\rGs& r+ known_servers!TopologyDescription.known_serverss5 44;;=X=aAWAW=XXX>>cV^8dQhRR/#r0r;rrr#)r=s"r+r>r?s\\4\r*c \;QJd4RVPP44F 'gK R# R#!RVPP444#)z7Whether there are any Servers of types besides Unknown.c3L"TFqP'gKVxK R#5irB)rbrEs& r+rH8TopologyDescription.has_known_servers..s[@DZDZ11@s$ $TF)rZrNrRrns&r+has_known_servers%TopologyDescription.has_known_serverssKs[d77>>@[ss[s[s[d77>>@[[[r*cV^8dQhRR/#rr#)r=s"r+r>r?sPP"9Pr*c VPP4Uu.uFqP'gKVNK up#uupi)zList of readable Servers.)rNrR is_readablers& r+rX$TopologyDescription.readable_serverss3 44;;=O=a=OOOrcV^8dQhRR/#rr#)r=s"r+r>r?s''#:'r*c VP#)z0List of Servers excluding deprioritized servers.)rSrns&r+candidate_servers%TopologyDescription.candidate_serverss&&&r*cV^8dQhRR/#rr#)r=s"r+r>r?s]r*c fVPpV'd\RVP44#R#)z3Minimum of all servers' max wire versions, or None.c38"TFqPxK R#5irB)rerEs& r+rH:TopologyDescription.common_wire_version..sF3Ea))3ErKN)rr[r\serverss& r+common_wire_version'TopologyDescription.common_wire_versions,$$ F43E3EFF Fr*cV^8dQhRR/#rr#)r=s"r+r>r? s;;S;r*c .VPP#rB)rTheartbeat_frequencyrns&r+r'TopologyDescription.heartbeat_frequency s&&:::r*cV^8dQhRR/#rr#)r=s"r+r>r?s66s6r*c .VPP#rB)rT_srv_max_hostsrns&r+ srv_max_hosts!TopologyDescription.srv_max_hostss&&555r*c V^8dQhRRRR/#)r0 selectionzOptional[Selection]r;rr#)r=s"r+r>r?s  0C H_ r*c V'g.#.pVPFVpVPf+RVP RV RVP 2p\V4hVP VP4KX \ V4pVP PR, pVPUu.uF-p\\VP4V, V8:gK+VNK/ up#uupi)Nzround_trip_time for server z is unexpectedly None: z , servers: g@@) r2round_trip_timergrappendr[rTlocal_threshold_msr float)r\rround_trip_timesserverconfig_err_msgfastest thresholdrGs&& r+_apply_local_threshold*TopologyDescription._apply_local_thresholdsI(*33F%%-#>v~~>NNefjekkvxAxUxUwV"W(88  # #F$:$: ; 4 &'++>>G 22 2UA--.8YF A2   s )(CCNc V^8dQhRRRR/#)r0deprioritized_servers!Optional[list[ServerDescription]]r;r<r#)r=s"r+r>r?$s E E%F E  Er*c V'gVPVnR#VUu0uFq"PkK ppVPUu.uFpVPV9gKVNK ppT;'g VPVnR#uupiuupi)zBFilter out deprioritized servers from a list of server candidates.N)rrSrg)r\rsddeprioritized_addressesrfiltereds&& r+_filter_servers#TopologyDescription._filter_servers$s%&*&8&8D #>)@@0  '/&D&D$2D2DD # 'SsBBBc ,V^8dQhRRRRRRRRR R /#) r0selectorrrgzOptional[_Address]custom_selectorzOptional[_ServerSelector]rrr;rr#)r=s"r+r>r?3sDM6M6M6$M63 M6 A M6 ! M6r*c \\VR^4'dCVPpV'd/WQP8d\RWPV3,4h\ V\ 4'dVP V4VP\P8Xd.#VP\P\P39d VP#V'd?VP4PV4pV'dVP'dV.#.#VP!V4VP\P"8Xd\%V4\&JdVP(F9pVP*\,P.8XgK$V.pV'd V!V4pVu# V'd@VF9pVP*\,P.8XgK$V.pV'd V!V4pVu# .#\0P2!V4p VP\P48wdHV!V 4p V 'g8V'd0VP!R4\0P2!V4p V!V 4p Ve*V 'd"V P7V!V P44p VP9V 4#)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 rczF%s requires min wire version %d, but topology's min wire version is %dN)getattrrrcr isinstancerselection_hookr1rVr!rr"rr2getrbrrtyperrS server_typer RSPrimaryrfrom_topology_descriptionr with_server_descriptionsr) r\rrgrr common_wv descriptionrrrs &&&&& 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$/K4T4T4TK= \Z\ \ 23   !D!D Dh[bIb-->>[%:%::$C&-c2J .%/B~~)>)>>!d*"1#"6C" 0I77=   !6!6 6 +I!6$$T*%??E $Y/   &9!:: = =>I**955r*c V^8dQhRRRR/#)r0read_preferencerr;rrr#)r=s"r+r>r?s99;9\`9r*c d\P!RV4\VPV44#)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 r)rvalidate_read_preferencerZr)r\rs&&r+has_readable_server'TopologyDescription.has_readable_servers+ ''(9?K4&&788r*cV^8dQhRR/#rr#)r=s"r+r>r?s@@T@r*c @VP\P4#)zDoes this topology have a writable server available? .. note:: When connected directly to a single server this method always returns ``True``. .. versionadded:: 3.4 )rrPRIMARYrns&r+has_writable_server'TopologyDescription.has_writable_servers''(>(>??r*cV^8dQhRR/#rr#)r=s"r+r>r?s  # r*c \VPP4RR7pRPVPP VP PVPV4#)cVP#rB)rg)rs&r+.TopologyDescription.__repr__..sBJJr*)keyz-<{} id: {}, topology_type: {}, servers: {!r}>) sortedrNrRr= __class__r$rT _topology_idrrs& r+__repr__TopologyDescription.__repr__sY2299;AVW>EE NN # #  # # 0 0  # #    r*) rSrUrYrPrOrMrNrTrLrB)NNN)"r$r%r&r'r]rWrortr{rr2propertyr1rr4r6r8rDrrrXrrrrrrrrrrrrr)r#r*r+r.r.?se1f-^=4>  &0 ##::&&%%%%((YY\\PP'';;66 $ EM6^BPAWAW9 @  r*r.c$V^8dQhRRRRRR/#)r0topology_descriptionr.server_descriptionrr;r#)r=s"r+r>r>s)ee-eCTeer*cVPpVPpVPpVPpVPpVP pVP 4pWV&V\P8XduVeIWAP8wd9\RPWAP44p VPV R7W&\\PVVVVVP4#V\P8XdV\P \P"39dH\%VPP&4^8Xd\PpMDVP)V4M2V\P\P*39d\,V,pV\P.8Xd9V\P0\P39dVP)V4EMV\P28XdV\P \P039dVP)V4EM3V\P48Xd\7WWV4wr4rVEM V\P8\P:\P<39d\?WV4wr4MV\P@8XdV\P \P039dVP)V4\CV4pMrV\P48Xd\7WWV4wr4rVMLV\P8\P:\P<39d\EWV4pM \CV4p\VVVVVVP4#)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 '{}')error)#rgr1r4r6r8rr2rVrrr=rxr.rTr!r Standalone LoadBalancerlenseedspopRSGhost_SERVER_TYPE_TO_TOPOLOGY_TYPEr Mongosrr_update_rs_from_primary RSSecondary RSArbiterRSOther!_update_rs_no_primary_from_memberr_check_has_primary#_update_rs_with_primary_from_member) rrrgr1set_namer6r8rrr s && r+ryrys!((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$V^8dQhRRRRRR/#)r0rr.seedlistzlist[tuple[str, Any]]r;r#)r=s"r+r>r>s$((-(9N((r*c VP\9gQhVP4p\VP 44\V48XdV#\ VP 44FpW19gK VP V4K VP^8wdx\V4\VP 44, pVP\V4, pV^8d*\\V4\V\V444pM.pVFpW29gK \V4W#&K \VPVVPVPVP VP"4#)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 )r1r,r2setkeysrQrrr rrr[rr.r4r6r8rT)rrrrg new_hostsn_to_adds&& r+)_updated_topology_description_srv_pollingr"s- - -1G GG G  2 2 4C 388:#h-'## #  " GGG $))Q.MC O3 '55C@ a<fY/Xs9~1NOHH  ,W5CL ** --,,,,//  r*c 0V^8dQhRRRRRRRRR R R R /#) r0r+MutableMapping[_Address, ServerDescription]r4r5rrr6r7r8r9r;zr>FsUUYUY 4UY#UY*UY# UY ( UY B UYr*c|VfVPpM9WP8wd*VPVP4\V4WV3#VPeVP^8dVP VP 3pW43pRV9dTRV9dAWV8d;VP\RV RV 244WP&\V4WV3#VP pVP e"VeVP V8d VP pMVP VP 3pWC3p\;QJd.RV4FNK 5M !RV44p\;QJd.RV4FNK 5M !RV44pWx8d;VP\RV RV 244WP&\V4WV3#VP pVP pVP4Ffp V P\PJgK#V PVP8wgK@V P\R44W P&M VPFp W9gK \V 4W &K \!V4VP, Fp VPV 4K \V4WV3#)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.t![HZ1i&(Q">HZc3@"TFqf \4MTxK R#5irBr r's& r+rHr)ur*r+z6primary marked stale due to discovery of newer primary)r4rrgrre set_version election_idrxrtuplerRrrr all_hostsrr) rr4rr6r8new_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<r>s0## 4###*# #r*c VfQhWP8wdVPVP4MHVP'd7VPVP8wdVPVP4\ V4#)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. )r4rrgmer)rr4rs&&&r+rrsp  '' '>>> "**+    #5#=#=ASAVAV#V "**+ c ""r*c(V^8dQhRRRRRRRR/#) r0rr$r4r5rrr;ztuple[int, Optional[str]]r#)r=s"r+r>r>s0++ 4+#+*+ +r*c\PpVfVPpM.WP8wdVPVP4W13#VP FpW@9gK \ V4W&K VP'd7VPVP8wdVPVP4W13#)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). )rVrr4rrgr0rr9)rr4rr1rgs&&& r+rrs"55M->> @@ @ "**+..&//  ,W5CL0!3!;!;?Q?T?T!T "**+  **r*c V^8dQhRRRR/#)r0rz$Mapping[_Address, ServerDescription]r;rr#)r=s"r+r>r>s 1 1@ 1S 1r*cVP4F4pVP\P8XgK$\P u# \P #)zCurrent topology type is ReplicaSetWithPrimary. Is primary still known? Pass in a dict of ServerDescriptions. Returns new topology type. )rRrrrrVrr)rrGs& r+rrs@ZZ\ ==K11 1 66 6000r*N)<__conditional_annotations____doc__ __future__rrandomrtypingrrrrrr r r bson.min_keyr bson.objectidrpymongorpymongo.errorsrrpymongo.read_preferencesrrrrpymongo.server_descriptionrpymongo.server_selectorsrpymongo.server_typerpymongo.typingsrrrangerVr!r r,r(_ServerSelectorr.rrrrrrrrryr"rrrr)r>s@r+rNs-#    ";XX8.+$JuQx( ,9+@+@-BWBW*XXD!234d;L6MMNe e V  --=>>]>>=<<:: !eP(VUYp#.+@ 1r*