U ~fhF @sUdZddlmZddlZddlZddlZddlZddlmZddl m Z m Z m Z m Z ddlZddlmZddlmZmZmZmZmZmZe rddlmZdd lmZdd lmZdd lmZdd l m!Z!dd l"m#Z#ddediZ$de%d<ej&dr e'Z(e(e(e)e*de$d<nejdkrTe'e'e)e+dde$d<nejdkre'd,e'e*fe)d,e-ddde$d<nej&dre.d\Z(Z/Z0e(e(e0e/de$d<nPe1e'e*e2Z3e'd,dde3dd De)e3d de$d<e4&d!rnd,e4d",e5e6ej7d#d",e5e6ej8fe$d$<npej&drd,e4d",e5e6ej8d%d,e'e*ffe$d$<n$d,e4d",e5e6ej8fe$d$<d&Z9d'Z:d(Z;d)Zd.d+d1d2Z?d.d+d3d4Z@d.d+d5d6ZAd.d+d7d8ZBd9d:d;dd?ZDd@ZEdAdBdCdDdEZFdFGdGGdHdIdIZHdS)JzPool 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) ServerApidriverZPyMongo)nameversiondict[str, Any] _METADATAlinux)typer architecturerosdarwinwin32 -javacCsg|] }|r|qSr&).0partr&r&8/tmp/pip-unpacked-wheel-36gvocj8/pymongo/pool_options.py asr*PyPy.z (Python %s)platformz(%s)z /.dockerenvZKUBERNETES_SERVICE_HOSTZdockerZ kuberneteszdict[str, str]returncCs.i}ttrt|d<ttr*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.ZruntimeZ orchestrator)rDOCKER_ENV_PATHexistsRUNTIME_NAME_DOCKERrgetenv ENV_VAR_K8SORCHESTRATOR_NAME_K8S) containerr&r&r)get_container_env_infos   r8boolcCs*tdrdStd}|r&|dSdS)NZAWS_LAMBDA_RUNTIME_APITZAWS_EXECUTION_ENVZ AWS_Lambda_F)rr4 startswith)envr&r&r) _is_lambdas    r<cCsttdS)NZFUNCTIONS_WORKER_RUNTIMEr9rr4r&r&r&r)_is_azure_funcsr>cCsttdptdS)NZ K_SERVICEZ FUNCTION_NAMEr=r&r&r&r) _is_gcp_funcsr?cCsttdS)NZVERCELr=r&r&r&r) _is_vercelsr@cCstptptptSN)r<r>r?r@r&r&r&r)_is_faassrBstr Optional[int])keyr0cCs8t|}|sdSz t|WStk r2YdSXdS)zMLike os.getenv but returns an int, or None if the value is missing/malformed.N)rr4int ValueError)rEvalr&r&r) _getenv_ints  rIcCsi}t}|r||d<ttttfddkr8|Strvd|d<td}|r\||d<td}|dk rt||d <ntrd |d<n~trd |d<td }|r||d<td }|dk r||d <td}|dk r||d<n(trd|d<td}|r||d<|S)Nr7Tr"z aws.lambdarZ AWS_REGIONregionZAWS_LAMBDA_FUNCTION_MEMORY_SIZE memory_mbz azure.funczgcp.funcZFUNCTION_REGIONZFUNCTION_MEMORY_MBZFUNCTION_TIMEOUT_SEC timeout_secZvercelZ VERCEL_REGION) r8r<r>r?r@countrr4rI)r;r7rJrKrLr&r&r) _metadata_envsB      rNizMutableMapping[str, Any]None)metadatar0c Cstt|tkrdS|did}|r8d|i|d<tt|tkrNdS|did}|rpd|i|d<tt|tkrdS|ddtt|}|tkrdS|t}|dd}|r|d| }|r||d<n |ddtt|}|tkrdS|t}|di}|r|d d| }t|ttdd kr^||dd <ntdd |dd <tt|}|tkrdS|t}|dd| }t|ttddkr||dd<ntdd|dd<dS) zPerform metadata truncation.Nr;rrrr.rr)lenbsonencode_MAX_METADATA_SIZEgetpopr) rPenv_nameZos_typeZ encoded_sizeZoverflowplatrZdriver_versionZ driver_namer&r&r)_truncate_metadatasR         rZZfooidnac@seZdZdZdZeeeddedddddde dddddfddddddd d d d d ddd dddddddZ e ddddZ e ddddZ e ddddZe ddddZe ddd d!Ze d dd"d#Ze ddd$d%Ze ddd&d'Ze ddd(d)Ze ddd*d+Ze d dd,d-Ze d dd.d/Ze d dd0d1Ze d dd2d3Ze d dd4d5Ze ddd6d7Ze ddd8d9Ze ddd:d;Ze ddd 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 )Z__max_pool_sizeZ__min_pool_sizeZ__max_idle_time_secondsZ__connect_timeoutZ__socket_timeoutZ__wait_queue_timeoutZ __ssl_contextZ__tls_allow_invalid_hostnamesZ__event_listenersZ __appnameZ__driverZ __metadataZ__compression_settingsZ__max_connectingZ__pause_enabledZ __server_apiZ__load_balancedZ __credentialsNFTrFrDzOptional[float]zOptional[SSLContext]r9zOptional[_EventListeners]z Optional[str]zOptional[DriverInfo]zOptional[CompressionSettings]zOptional[ServerApi]zOptional[bool]zOptional[MongoCredential]) max_pool_size min_pool_sizemax_idle_time_secondsconnect_timeoutsocket_timeoutwait_queue_timeout ssl_contexttls_allow_invalid_hostnamesevent_listenersappnamercompression_settingsmax_connecting pause_enabled server_api load_balanced credentialsis_synccCsh||_||_||_||_||_||_||_||_| |_| |_ | |_ | |_ | |_ ||_ ||_||_||_tt|_| rd| i|jd<trd|jddd|jdd<|sd|jddd|jdd<| rD| jrd|jdd| j|jdd<| jr$dtdd| j|jdd<| jrDdtd| j|jd<t}|rZ||jd <t|jdS) NrZ applicationz{}|{}rcasyncrr.r;)_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__metadatarformatrrr.rNrZ)selfr]r^r_r`rarbrcrdrerfrrgrhrirjrkrlrmr;r&r&r)__init__<s^       zPoolOptions.__init__r/cCs|jS)z;A :class:`~pymongo.auth.MongoCredentials` instance or None.)rrr&r&r) _credentialsszPoolOptions._credentialsrcCsi}|jtkr|j|d<|jtkr,|j|d<|jtkrR|jdk sDt|jd|d<|jtkrx|jdk sjt|jd|d<|j t kr|j |d<|S)zqThe non-default options this pool was created with. Added for CMAP's :class:`PoolCreatedEvent`. Z maxPoolSizeZ minPoolSizeNiZ maxIdleTimeMSZwaitQueueTimeoutMSZ maxConnecting) rpr rqr rrr AssertionErrorrur r|r )roptsr&r&r)non_default_optionss        zPoolOptions.non_default_optionsfloatcCs|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. )rprr&r&r)r]s zPoolOptions.max_pool_sizecCs|jS)zThe minimum required number of concurrent connections that the pool will maintain to each connected server. Default is 0. )rqrr&r&r)r^szPoolOptions.min_pool_sizecCs|jS)zgThe maximum number of concurrent connection creation attempts per pool. Defaults to 2. )r|rr&r&r)rhszPoolOptions.max_connectingcCs|jSrA)r}rr&r&r)riszPoolOptions.pause_enabledcCs|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). )rrrr&r&r)r_sz!PoolOptions.max_idle_time_secondscCs|jS)z>How long a connection can take to be opened before timing out.)rsrr&r&r)r`szPoolOptions.connect_timeoutcCs|jS)zBHow long a send or receive on a socket can take before timing out.)rtrr&r&r)raszPoolOptions.socket_timeoutcCs|jS)zhHow long a thread will wait for a socket from the pool if the pool has no free sockets. )rurr&r&r)rbszPoolOptions.wait_queue_timeoutcCs|jS)zAn SSLContext instance or None.)rvrr&r&r) _ssl_contextszPoolOptions._ssl_contextcCs|jS)z If True skip ssl.match_hostname.)rwrr&r&r)rdsz'PoolOptions.tls_allow_invalid_hostnamescCs|jS)z2An instance of pymongo.monitoring._EventListeners.)rxrr&r&r)_event_listenersszPoolOptions._event_listenerscCs|jS)zAThe application name, for sending with hello in server handshake.)ryrr&r&r)rfszPoolOptions.appnamecCs|jS)z=Driver name and version, for sending with hello in handshake.)rzrr&r&r)rszPoolOptions.drivercCs|jSrA)r{rr&r&r)_compression_settingssz!PoolOptions._compression_settingscCs |jS)zCA dict of metadata about the application, driver, os, and platform.)rrrr&r&r)rPszPoolOptions.metadatacCs|jS)z'A pymongo.server_api.ServerApi or None.)r~rr&r&r)rjszPoolOptions.server_apicCs|jS)z6True if this Pool is configured in load balanced mode.)rrr&r&r)rkszPoolOptions.load_balanced)__name__ __module__ __qualname____doc__ __slots__r r r r r rpropertyrrr]r^rhrir_r`rarbrrdrrfrrrPrjrkr&r&r&r)r\sv 2Qr\)Ir __future__rrrr.syspathlibrtypingrrrrrSZpymongorZpymongo.commonr r r r r rZpymongo.auth_sharedrZpymongo.compression_supportrZpymongo.driver_inforZpymongo.monitoringrZpymongo.pyopenssl_contextrZpymongo.server_apirr__annotations__r:system_namemachinereleasemac_verjoin win32_verjava_ver_verZ_arch system_aliasrZ_aliasedpython_implementationmaprCpypy_version_info version_infor1r5r3r6r8r<r>r?r@rBrIrNrUrZrTr\r&r&r&r)s                     %;