o ?8\@stdZddlmZGdddeZddZddZd d Zd d Zd dZ ddZ ddZ ddZ ddZ ddZdS)zFCriteria to select some ServerDescriptions from a TopologyDescription.) SERVER_TYPEc@sleZdZdZeddZddZddZdd Ze d d Z e d d Z e ddZ ddZ e ZddZdS) Selectionz.Input or output of a server selector function.cCs:|j}d}|D] }|jtjkr|}nqt||j|j|SN) known_servers server_typer RSPrimaryrcommon_wire_version)clstopology_descriptionrprimarysdr J/var/www/html/env/lib/python3.10/site-packages/pymongo/server_selectors.pyfrom_topology_descriptions z#Selection.from_topology_descriptioncCs||_||_||_||_dSr)r server_descriptionsr r)selfr rrr r r r__init__%s zSelection.__init__cCst|j||j|jSr)rr rr )rrr r rwith_server_descriptions/s z"Selection.with_server_descriptionscCs$t|}|jrt|jdddSdS)NcSs|jSr)last_write_date)r r r r9sz>Selection.secondary_with_max_last_write_date..)key)secondary_server_selectorrmax)r secondariesr r r"secondary_with_max_last_write_date5s z,Selection.secondary_with_max_last_write_datecCs|jr|jgng}||Sr)r r)r primariesr r rprimary_selection;s zSelection.primary_selectioncC|jjSr)r heartbeat_frequencyrr r rr@zSelection.heartbeat_frequencycCrr)r topology_typerr r rr!Dr zSelection.topology_typecCs t|jSr)boolrrr r r__bool__H zSelection.__bool__cCs |j|Sr)r)ritemr r r __getitem__Mr$zSelection.__getitem__N)__name__ __module__ __qualname____doc__ classmethodrrrrpropertyrrr!r# __nonzero__r&r r r rrs        rcCs|Srr  selectionr r rany_server_selectorQsr0cC|dd|jDS)NcSg|]}|jr|qSr ) is_readable.0sr r r Wz,readable_server_selector..rrr.r r rreadable_server_selectorUr:cCr1)NcSr2r ) is_writabler4r r rr7\r8z,writable_server_selector..r9r.r r rwritable_server_selectorZr;r=cCr1)NcSg|] }|jtjkr|qSr )rr RSSecondaryr4r r rr7a z-secondary_server_selector..r9r.r r rr_r;rcCr1)NcSr>r )rr RSArbiterr4r r rr7gr@z+arbiter_server_selector..r9r.r r rarbiter_server_selectorer;rBcCst|pt|S)z6Like PrimaryPreferred but doesn't use tags or latency.)r=rr.r r r"writable_preferred_server_selectorksrCcs&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. cs0D]\}}||vs|||krdSqdS)NFT)items) server_tagsrvalue)tag_setr r tags_matchys z(apply_single_tag_set..tags_matchcsg|] }|jr|qSr )tagsr4)rHr rr7sz(apply_single_tag_set..r9)rGr/r )rGrHrapply_single_tag_setqs rJcCs*|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. )rJr)tag_setsr/rG with_tag_setr r rapply_tag_setss   rMcCt|t|S)z2All near-enough secondaries matching the tag sets.)rMrrKr/r r r#secondary_with_tags_server_selectorrPcCrN)z.All near-enough members matching the tag sets.)rMr:rOr r r member_with_tags_server_selectorrQrRN)r*pymongo.server_typerobjectrr0r:r=rrBrCrJrMrPrRr r r rs =