o 'h@sdZddlmZddlmZmZmZmZmZm Z m Z ddl m Z er.ddl mZddlmZe dZeeefZeeZGdd d Zd%d d Zd&ddZd&ddZd&ddZd&ddZd&ddZd'ddZd(ddZd(d d!Zd(d"d#Zd$S))zFCriteria to select some ServerDescriptions from a TopologyDescription.) annotations) TYPE_CHECKINGAnyMappingOptionalSequenceTypeVarcast) SERVER_TYPE)ServerDescription)TopologyDescriptionTc@szeZdZdZed"ddZd#d dZd$ddZd%ddZe d&ddZ e d'ddZ e d'ddZ d(ddZ d)dd Zd!S)* Selectionz.Input or output of a server selector function.topology_descriptionr returncCs:|j}d}|D] }|jtjkr|}nqt||j|j|SN) known_servers server_typer RSPrimaryrcommon_wire_version)clsrrprimarysdrT/var/www/html/olx_land/venv/lib/python3.10/site-packages/pymongo/server_selectors.pyfrom_topology_description#s z#Selection.from_topology_descriptionserver_descriptionslist[ServerDescription]r Optional[int]rOptional[ServerDescription]cCs||_||_||_||_dSr)rrrr)selfrrrrrrr__init__3s zSelection.__init__cCst|j||j|jSr)rrrr)r rrrrwith_server_descriptions?sz"Selection.with_server_descriptionscCs$t|}|jrt|jdddSdS)NcSs tt|jSr)r floatlast_write_date)rrrrHs z>Selection.secondary_with_max_last_write_date..)key)secondary_server_selectorrmax)r secondariesrrr"secondary_with_max_last_write_dateDs  z,Selection.secondary_with_max_last_write_datecCs|jr|jgng}||Sr)rr")r primariesrrrprimary_selectionLs zSelection.primary_selectionintcC|jjSr)rheartbeat_frequencyr rrrr/QzSelection.heartbeat_frequencycCr.r)r topology_typer0rrrr2Ur1zSelection.topology_typeboolcCs t|jSr)r3rr0rrr__bool__Y zSelection.__bool__itemr cCs |j|Sr)r)r r6rrr __getitem__\r5zSelection.__getitem__N)rr rr)rr rrrrrr)rrrr)rr)rr)rr-)rr3)r6r-rr )__name__ __module__ __qualname____doc__ classmethodrr!r"r*propertyr,r/r2r4r7rrrrr s       r selectionrcCs|Srrr>rrrany_server_selector`sr@cC|dd|jDS)NcSg|]}|jr|qSr) is_readable.0srrr fz,readable_server_selector..r"rr?rrrreadable_server_selectordrJcCrA)NcSrBr) is_writablerDrrrrGlrHz,writable_server_selector..rIr?rrrwritable_server_selectorjrKrMcCrA)NcSg|] }|jtjkr|qSr)rr RSSecondaryrDrrrrGrz-secondary_server_selector..rIr?rrrr'prKr'cCrA)NcSrNr)rr RSArbiterrDrrrrGxrPz+arbiter_server_selector..rIr?rrrarbiter_server_selectorvrKrRcCst|pt|S)z6Like PrimaryPreferred but doesn't use tags or latency.)rMr'r?rrr"writable_preferred_server_selector|srStag_setTagSetcs(d fdd |fdd|jDS) zAll servers matching one tag set. A tag set is a dict. A server matches if its tags are a superset: A server tagged {'a': '1', 'b': '2'} matches the tag set {'a': '1'}. The empty tag set {} matches any server. server_tagsMapping[str, Any]rr3cs0D]\}}||vs|||krdSqdS)NFT)items)rVr&value)rTrr tags_matchs z(apply_single_tag_set..tags_matchcsg|] }|jr|qSr)tagsrD)rZrrrGsz(apply_single_tag_set..N)rVrWrr3rI)rTr>r)rTrZrapply_single_tag_sets r\tag_setsTagSetscCs*|D] }t||}|r|Sq|gS)aNAll servers match a list of tag sets. tag_sets is a list of dicts. The empty tag set {} matches any server, and may be provided at the end of the list as a fallback. So [{'a': 'value'}, {}] expresses a preference for servers tagged {'a': 'value'}, but accepts any server if none matches the first preference. )r\r")r]r>rT with_tag_setrrrapply_tag_setss   r`cCt|t|S)z2All near-enough secondaries matching the tag sets.)r`r'r]r>rrr#secondary_with_tags_server_selectorrccCra)z.All near-enough members matching the tag sets.)r`rJrbrrr member_with_tags_server_selectorrdreN)r>r rr )r>rrr)rTrUr>rrr)r]r^r>rrr) r; __future__rtypingrrrrrrr pymongo.server_typer pymongo.server_descriptionr pymongo.topology_descriptionr r strrUr^rr@rJrMr'rRrSr\r`rcrerrrrs* $     @