_i_J BUdZddlmZddlZddlZddlZddlZddlmZddl m Z m Z m Z m Z ddlZddlmZddlmZmZmZmZmZmZe r$ddlmZdd lmZdd lmZdd lmZdd l m!Z!dd l"m#Z#ddediZ$de%d<ej&dr5ej'Z(e(e(ej)ej*de$d<nejdkrFej'ej'ej)ej+dde$d<nEejdkrtej,Z-ddej./dpej)d0e1e2e-ddde-dpdzde$d<nej&dr$ej3d\Z(Z-Z4e(e(e4e-de$d<nej5ej'ej*ej6Z7ej'd 0d!e7dd"Dej)e7d"de$d<ej8&d#rpd 0ej8d0e1e2ej9d$d0e1e2ej:zfe$d%<nej&dr}d 0ej8d0e1e2ej:d&d 0ej'ej*fzfe$d%<nId 0ej8d0e1e2ej:fe$d%<d'Z;d(ZdBd-Z?dCd/Z@dCd0ZAdCd1ZBdCd2ZCdCd3ZDdDd7ZEdEd8ZFd9ZGdFd=ZHd>Id?Gd@dAZJdS)GzPool options for AsyncMongoClient/MongoClient. .. seealso:: This module is compatible with both the synchronous and asynchronous PyMongo APIs. ) annotationsN)Path) TYPE_CHECKINGAnyMutableMappingOptional) __version__)MAX_CONNECTINGMAX_IDLE_TIME_SEC MAX_POOL_SIZE MIN_POOL_SIZEWAIT_QUEUE_TIMEOUThas_c)MongoCredential)CompressionSettings) DriverInfo)_EventListeners) SSLContext) ServerApidriverPyMongo)nameversiondict[str, Any] _METADATAlinux)typer architecturerosdarwinwin32WindowsPROCESSOR_ARCHITECTURE.z-SP0java cg|]}||Sr+).0parts 7D:\Nbitz\venv\Lib\site-packages\pymongo/pool_options.py r/bs@@@44@$@@@PyPyz (Python %s)platformz(%s)z /.dockerenvKUBERNETES_SERVICE_HOSTdocker kubernetesreturndict[str, str]ci}ttr t|d<t jt r t|d<|S)zReturns the runtime and orchestrator of a container. If neither value is present, the metadata client.env.container field will be omitted.runtime orchestrator)rDOCKER_ENV_PATHexistsRUNTIME_NAME_DOCKERrgetenv ENV_VAR_K8SORCHESTRATOR_NAME_K8S) containers r.get_container_env_inforCsQI O##%%32 ) y:$9 .! r0boolctjdrdStjd}|r|dSdS)NAWS_LAMBDA_RUNTIME_APITAWS_EXECUTION_ENV AWS_Lambda_F)rr? startswith)envs r. _is_lambdarKsI y)**t )' ( (C -~~m,,, 5r0cDttjdS)NFUNCTIONS_WORKER_RUNTIMErDrr?r+r0r._is_azure_funcrOs  455 6 66r0clttjdptjdS)N K_SERVICE FUNCTION_NAMErNr+r0r. _is_gcp_funcrSs)  +&&D")O*D*D E EEr0cDttjdS)NVERCELrNr+r0r. _is_vercelrVs  (## $ $$r0crtp)tptp tSN)rKrOrSrVr+r0r._is_faasrYs) << M>++ M|~~ MMr0keystr Optional[int]cttj|}|sdS t|S#t$rYdSwxYw)zMLike os.getenv but returns an int, or None if the value is missing/malformed.N)rr?int ValueError)rZvals r. _getenv_intrasN )C..C t3xx tts ) 77ci}t}|r||d<tttt fddkr|Str7d|d<t jd}|r||d<td}|||d <ntrd |d<ntrMd |d<t jd }|r||d<td }|||d <td}|||d<n.t r d|d<t jd}|r||d<|S)NrBTz aws.lambdar AWS_REGIONregionAWS_LAMBDA_FUNCTION_MEMORY_SIZE memory_mbz azure.funczgcp.funcFUNCTION_REGIONFUNCTION_MEMORY_MBFUNCTION_TIMEOUT_SEC timeout_secvercel VERCEL_REGION) rCrKrOrSrVcountrr?ra)rJrBrergrks r. _metadata_envrosxC&((I%$K n&&  EKKDQQUVVV ||#"F <((  #"CM ABB  (C    #"F # F ,--  #"CM 455  (C !"899  "!,C  #F ?++  #"CM Jr0imetadataMutableMapping[str, Any]Nonecttj|tkrdS|did}|rd|i|d<ttj|tkrdS|did}|rd|i|d<ttj|tkrdS|ddttj|}|tkrdS|tz }|dd}|r |d| }|r||d<n|ddttj|}|tkrdS|tz }|di}|r)|d d| }t|tt dd kr ||dd <nt dd |dd <ttj|}|tkrdS|tz }|dd| }t|tt ddkr ||dd<dSt dd|dd<dSdS) zPerform metadata truncation.NrJrrrr3rr)lenbsonencode_MAX_METADATA_SIZEgetpopr) rpenv_nameos_type encoded_sizeoverflowplatrdriver_version driver_names r._truncate_metadatars 4;x !!%777||E2&&**622H-!8, 4;x !!%777ll4$$((00G+ '* 4;x !!%777 LLt{8,,--L)))00H << B ' 'D  JhYJ '# Z&&&t{8,,--L)))00H \\(B ' 'F EI..z z: ~  #i&9)&D"E"E E E,:HX y ) ),5h,? ,JHX y )4;x0011 - - - F"44jj((8)4 {  s9X#6v#>?? ? ?)4HX v & & &)28)d$Z d?d(Z e d@d)Z e dAd+Ze dBd-Ze dCd.Ze dCd/Ze dDd0Ze dEd1Ze dFd2Ze dFd3Ze dEd4Ze dGd5Ze dDd6Ze dHd7Ze dId8Ze dJd9Ze dKd:Ze dAd;Ze dLd<Ze dMd=ZdS)N PoolOptionsakRead only connection pool options for an AsyncMongoClient/MongoClient. Should not be instantiated directly by application developers. Access a client's pool options via :attr:`~pymongo.client_options.ClientOptions.pool_options` instead:: pool_opts = client.options.pool_options pool_opts.max_pool_size pool_opts.min_pool_size )__max_pool_size__min_pool_size__max_idle_time_seconds__connect_timeout__socket_timeout__wait_queue_timeout __ssl_context__tls_allow_invalid_hostnames__event_listeners __appname__driver __metadata__compression_settings__max_connecting__pause_enabled __server_api__load_balanced __credentialsNFT max_pool_sizer^ min_pool_sizemax_idle_time_secondsr\connect_timeoutOptional[float]socket_timeoutwait_queue_timeout ssl_contextOptional[SSLContext]tls_allow_invalid_hostnamesrDevent_listenersOptional[_EventListeners]appname Optional[str]rOptional[DriverInfo]compression_settingsOptional[CompressionSettings]max_connecting pause_enabled server_apiOptional[ServerApi] load_balancedOptional[bool] credentialsOptional[MongoCredential]is_syncc||_||_||_||_||_||_||_||_| |_| |_ | |_ | |_ | |_ ||_ ||_||_||_t#jt&|_| r d| i|jd<t+r5d|jddd|jdd<|s5d|jddd|jdd<| r|| t1}|r ||jd<t3|jdS)Nr application{}|{}rcasyncrJ)_PoolOptions__max_pool_size_PoolOptions__min_pool_size#_PoolOptions__max_idle_time_seconds_PoolOptions__connect_timeout_PoolOptions__socket_timeout _PoolOptions__wait_queue_timeout_PoolOptions__ssl_context)_PoolOptions__tls_allow_invalid_hostnames_PoolOptions__event_listeners_PoolOptions__appname_PoolOptions__driver"_PoolOptions__compression_settings_PoolOptions__max_connecting_PoolOptions__pause_enabled_PoolOptions__server_api_PoolOptions__load_balanced_PoolOptions__credentialscopydeepcopyr_PoolOptions__metadatarformat_update_metadataror)selfrrrrrrrrrrrrrrrrrrrJs r.__init__zPoolOptions.__init__=s* -,'<$!0 .$6!(-H*!0  &:# .,&,(- 22  ?.4g->DOM * 77 07)&111DOH %f - 07)&111DOH %f -  *  ! !& ) ) )oo  )%(DOE "4?+++++r0rr7rrc,|jrS|j|jdddvrdSt j|j}|jr0d|dd|j|dd<|jr0d|dd|j|dd<|jr$d|d|j|d<||_dS)zUpdates the client's metadatarr|Nrrr3) rlowerrsplitrrrrr3)rrrps r.rzPoolOptions._update_metadatas ; 6;,,..$/(2KF2S2Y2Y2[2[2a2a 3 3    F=11 ; )0"6* **HX v & > ,3NN"9---HX y ) ? Y#*>>(:2F#X#XHZ "r0c|jS)z;A :class:`~pymongo.auth.MongoCredentials` instance or None.)rrs r. _credentialszPoolOptions._credentials !!r0rc>i}|jtkr |j|d<|jtkr |j|d<|jt kr|jJ|jdz|d<|jtkr|jJ|jdz|d<|jtkr |j|d<|S)zqThe non-default options this pool was created with. Added for CMAP's :class:`PoolCreatedEvent`. maxPoolSize minPoolSizeNi maxIdleTimeMSwaitQueueTimeoutMS maxConnecting) rr rr rr rrrr )roptss r.non_default_optionszPoolOptions.non_default_optionss   = 0 0"&"6D   = 0 0"&"6D   '+< < </;;;$($@4$GD !  $(: : :,888)-)BT)ID% &  N 2 2$($9D ! r0floatc|jS)aQThe maximum allowable number of concurrent connections to each connected server. Requests to a server will block if there are `maxPoolSize` outstanding connections to the requested server. Defaults to 100. Cannot be 0. When a server's pool has reached `max_pool_size`, operations for that server block waiting for a socket to be returned to the pool. If ``waitQueueTimeoutMS`` is set, a blocked operation will raise :exc:`~pymongo.errors.ConnectionFailure` after a timeout. By default ``waitQueueTimeoutMS`` is not set. )rrs r.rzPoolOptions.max_pool_sizes ##r0c|jS)zThe minimum required number of concurrent connections that the pool will maintain to each connected server. Default is 0. )rrs r.rzPoolOptions.min_pool_sizes ##r0c|jS)zgThe maximum number of concurrent connection creation attempts per pool. Defaults to 2. )rrs r.rzPoolOptions.max_connectings $$r0c|jSrX)rrs r.rzPoolOptions.pause_enableds ##r0c|jS)zThe maximum number of seconds that a connection can remain idle in the pool before being removed and replaced. Defaults to `None` (no limit). )rrs r.rz!PoolOptions.max_idle_time_secondss ++r0c|jS)z>How long a connection can take to be opened before timing out.)rrs r.rzPoolOptions.connect_timeout %%r0c|jS)zBHow long a send or receive on a socket can take before timing out.)rrs r.rzPoolOptions.socket_timeouts $$r0c|jS)zhHow long a thread will wait for a socket from the pool if the pool has no free sockets. )rrs r.rzPoolOptions.wait_queue_timeouts ((r0c|jS)zAn SSLContext instance or None.)rrs r. _ssl_contextzPoolOptions._ssl_contextrr0c|jS)z If True skip ssl.match_hostname.)rrs r.rz'PoolOptions.tls_allow_invalid_hostnamess 11r0c|jS)z2An instance of pymongo.monitoring._EventListeners.)rrs r._event_listenerszPoolOptions._event_listenersrr0c|jS)zAThe application name, for sending with hello in server handshake.)rrs r.rzPoolOptions.appnames ~r0c|jS)z=Driver name and version, for sending with hello in handshake.)rrs r.rzPoolOptions.drivers }r0c|jSrX)rrs r._compression_settingsz!PoolOptions._compression_settingss **r0c4|jS)zCA dict of metadata about the application, driver, os, and platform.)rrrs r.rpzPoolOptions.metadata s##%%%r0c|jS)z'A pymongo.server_api.ServerApi or None.)rrs r.rzPoolOptions.server_apis   r0c|jS)z6True if this Pool is configured in load balanced mode.)rrs r.rzPoolOptions.load_balanceds ##r0)$rr^rr^rr\rrrrrr\rrrrDrrrrrrrrrr^rrDrrrrrrrr)rrr7rr)r7rr7r)r7r)r7r^r7rD)r7r\)r7r)r7r)r7r)r7r)r7r)r7r)r7r)r7r) __name__ __module__ __qualname____doc__ __slots__r r r rr rrpropertyrrrrrrrrrrrrrrrrrprrr+r0r.rrs  I.+*/@+/*.,>,0,159!%'+>B,"*.(,15"&'D,D,D,D,D,L####0"""X"X( $ $ $X $$$$X$ %%%X% $$$X$,,,X,&&&X&%%%X%)))X) """X"222X2&&&X&XX+++X+&&&X&!!!X!$$$X$$$r0r)r7r8r)rZr[r7r\r)rprqr7rr)Kr __future__rrrr3syspathlibrtypingrrrrrvpymongor pymongo.commonr r r r rrpymongo.auth_sharedrpymongo.compression_supportrpymongo.driver_inforpymongo.monitoringrpymongo.pyopenssl_contextrpymongo.server_apirr__annotations__rIsystem_namemachinereleasemac_vergetwindowsversion_verenvironryjoinmapr[java_ver_arch system_aliasr_aliasedpython_implementationpypy_version_info version_infor<r@r>rArCrKrOrSrVrYrarorxrrwrr+r0r.rsZ#"""""  ???????????? -333333??????......222222444444,,,,,,& k'R'RS SSSS<7##3 HO  E((**#8#%% IdOO \X!!!!((**$8#%%a( IdOO \W 3 " "D '?@@VDTHDTDVDV88CCT"1"X..//2IRC2I2II IdOO \V$$**,,R0E4IdOO%x$_X_%6%68H8H8J8JL\HL\L^L^__H!!@@8BQB<@@@AA((**A; IdO"8!##..v66HH *H * , , HHSSc344 5 5 CHHSSc.>%?%?@@ @ Ij \V$$ HH *H * , , HHSSc.// 0 0 SXXx002B(2B2D2DEFF F Ij HH ' ' ) )388CCS=M4N4N+O+OPIj ' $    7777FFFF%%%%NNNN""""J4E4E4E4Ev V~$~$~$~$~$~$~$~$~$~$r0