3 Oษ6bปใ@stdZddlmZGdd„deƒZdd„Zdd„Zd d „Zd d „Zd d„Z dd„Z dd„Z dd„Z dd„Z dd„ZdS)zFCriteria to select some ServerDescriptions from a TopologyDescription.้)ฺ SERVER_TYPEc@sleZdZdZedd„ƒZdd„Zdd„Zdd „Ze d d „ƒZ e d d „ƒZ e dd„ƒZ dd„Z e Zdd„ZdS)ฺ Selectionz.Input or output of a server selector function.cCs<|j}d}x|D]}|jtjkr|}PqWt||j|j|ƒS)N)ฺ known_serversฺ server_typerZ RSPrimaryrฺcommon_wire_version)ฺclsฺtopology_descriptionrฺprimaryฺsdฉr ๚W/var/www/html/sandeepIITI/myenv/lib/python3.6/site-packages/pymongo/server_selectors.pyฺfrom_topology_descriptions  z#Selection.from_topology_descriptioncCs||_||_||_||_dS)N)rฺserver_descriptionsr r)ฺselfrrrr r r r ฺ__init__%szSelection.__init__cCst|j||j|jƒS)N)rrrr )rrr r r ฺwith_server_descriptions/sz"Selection.with_server_descriptionscCs$t|ƒ}|jr t|jdd„dSdS)NcSs|jS)N)Zlast_write_date)r r r r ฺ9sz>Selection.secondary_with_max_last_write_date..)ฺkey)ฺsecondary_server_selectorrฺmax)rZ secondariesr r r ฺ"secondary_with_max_last_write_date5sz,Selection.secondary_with_max_last_write_datecCs|jr|jgng}|j|ƒS)N)r r)rZ primariesr r r ฺprimary_selection;szSelection.primary_selectioncCs|jjS)N)rฺheartbeat_frequency)rr r r r@szSelection.heartbeat_frequencycCs|jjS)N)rฺ topology_type)rr r r rDszSelection.topology_typecCs t|jƒS)N)ฺboolr)rr r r ฺ__bool__HszSelection.__bool__cCs |j|S)N)r)rฺitemr r r ฺ __getitem__MszSelection.__getitem__N)ฺ__name__ฺ __module__ฺ __qualname__ฺ__doc__ฺ classmethodr rrrฺpropertyrrrrฺ __nonzero__rr r r r rs     rcCs|S)Nr )ฺ selectionr r r ฺany_server_selectorQsr&cCs|jdd„|jDƒƒS)NcSsg|]}|jr|‘qSr )Z is_readable)ฺ.0ฺsr r r ๚ Wsz,readable_server_selector..)rr)r%r r r ฺreadable_server_selectorUsr*cCs|jdd„|jDƒƒS)NcSsg|]}|jr|‘qSr )ฺ is_writable)r'r(r r r r)\sz,writable_server_selector..)rr)r%r r r ฺwritable_server_selectorZsr,cCs|jdd„|jDƒƒS)NcSsg|]}|jtjkr|‘qSr )rrZ RSSecondary)r'r(r r r r)asz-secondary_server_selector..)rr)r%r r r r_srcCs|jdd„|jDƒƒS)NcSsg|]}|jtjkr|‘qSr )rrZ RSArbiter)r'r(r r r r)gsz+arbiter_server_selector..)rr)r%r r r ฺarbiter_server_selectoresr-cCst|ƒpt|ƒS)z6Like PrimaryPreferred but doesn't use tags or latency.)r,r)r%r r r ฺ"writable_preferred_server_selectorksr.cs&‡fdd„‰|j‡fdd„|jDƒƒS)zไAll 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. cs2x,ˆjƒD] \}}||ks&|||kr dSq WdS)NFT)ฺitems)Z server_tagsrฺvalue)ฺtag_setr r ฺ tags_matchysz(apply_single_tag_set..tags_matchcsg|]}ˆ|jƒr|‘qSr )ฺtags)r'r()r2r r r)sz(apply_single_tag_set..)rr)r1r%r )r1r2r ฺapply_single_tag_setqs r4cCs*x|D]}t||ƒ}|r|SqW|jgƒS)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. )r4r)ฺtag_setsr%r1Z with_tag_setr r r ฺapply_tag_sets„s  r6cCst|t|ƒƒS)z2All near-enough secondaries matching the tag sets.)r6r)r5r%r r r ฺ#secondary_with_tags_server_selector•sr7cCst|t|ƒƒS)z.All near-enough members matching the tag sets.)r6r*)r5r%r r r ฺ member_with_tags_server_selectoršsr8N)r!Zpymongo.server_typerฺobjectrr&r*r,rr-r.r4r6r7r8r r r r ฺs =