o 'hG @spUdZddlmZddlZddlZddlZddlZddlmZddl m Z m Z m Z m Z ddlZddlmZddlmZmZmZmZmZmZe rkddlmZdd lmZdd lmZdd lmZdd l m!Z!dd l"m#Z#ddediZ$de%d<ej&dre'Z(e(e(e)e*de$d<nejdkre'e'e)e+dde$d<noejdkre,Z-ddej./dpe)d0e1e2e-ddde-dpdde$d<nAej&dre3d\Z(Z-Z4e(e(e4e-de$d<n(e5e'e*e6Z7e'd 0d!d"e7dd#De)e7d#de$d<e8&d$r;d 0e8d0e1e2ej9d%d0e1e2ej:fe$d&<n8ej&drad 0e8d0e1e2ej:d'd 0e'e*ffe$d&<nd 0e8d0e1e2ej:fe$d&<d(Z;d)ZdLd.d/Z?dMd1d2Z@dMd3d4ZAdMd5d6ZBdMd7d8ZCdMd9d:ZDdNd>d?ZEdOd@dAZFdBZGdPdFdGZHdHIdIGdJdKdKZJdS)QzPool 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 cCsg|]}|r|qSr)).0partr)r)P/var/www/html/olx_land/venv/lib/python3.10/site-packages/pymongo/pool_options.py bsr-PyPyz (Python %s)platformz(%s)z /.dockerenvKUBERNETES_SERVICE_HOSTdocker kubernetesreturndict[str, str]cCs.i}ttr t|d<ttrt|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) containerr)r)r,get_container_env_infos   r?boolcCs*tdrdStd}|r|dSdS)NAWS_LAMBDA_RUNTIME_APITAWS_EXECUTION_ENV AWS_Lambda_F)rr; startswith)envr)r)r, _is_lambdas   rFcCttdS)NFUNCTIONS_WORKER_RUNTIMEr@rr;r)r)r)r,_is_azure_funcrJcCsttdp tdS)N K_SERVICE FUNCTION_NAMErIr)r)r)r, _is_gcp_funcrNcCrG)NVERCELrIr)r)r)r, _is_vercelrKrQcCstp tp tp tSN)rFrJrNrQr)r)r)r,_is_faasrOrSkeystr Optional[int]cCs2t|}|s dSzt|WStyYdSw)zMLike os.getenv but returns an int, or None if the value is missing/malformed.N)rr;int ValueError)rTvalr)r)r, _getenv_ints   rZcCs i}t}|r ||d<ttttfddkr|StrTz aws.lambdar AWS_REGIONregionAWS_LAMBDA_FUNCTION_MEMORY_SIZE memory_mbz azure.funczgcp.funcFUNCTION_REGIONFUNCTION_MEMORY_MBFUNCTION_TIMEOUT_SEC timeout_secvercel VERCEL_REGION) r?rFrJrNrQcountrr;rZ)rEr>r]r_rcr)r)r, _metadata_envsH   rgimetadataMutableMapping[str, Any]Nonec Cstt|tkr dS|did}|rd|i|d<tt|tkr'dS|did}|r8d|i|d<tt|tkrCdS|ddtt|}|tkrVdS|t}|dd}|ri|d| }|rp||d<n|ddtt|}|tkrdS|t}|di}|r|d d| }t|ttdd kr||dd <n tdd |dd <tt|}|tkrdS|t}|dd| }t|ttddkr||dd<dStdd|dd<dSdS) zPerform metadata truncation.NrErrrr0rr)lenbsonencode_MAX_METADATA_SIZEgetpopr) rhenv_nameos_type encoded_sizeoverflowplatrdriver_version driver_namer)r)r,_truncate_metadatasT       ryfooidnac@sNeZdZdZdZeeeddedddddde dddddfdOd$d%Z e dPd'd(Z e dQd*d+Z e dRd-d.Ze dSd/d0Ze dSd1d2Ze dTd3d4Ze dUd5d6Ze dVd7d8Ze dVd9d:Ze dUd;d<Ze dWd=d>Ze dTd?d@Ze dXdAdBZe dYdCdDZe dZdEdFZe d[dGdHZe dQdIdJZe d\dKdLZe d]dMdNZdS)^ 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_sizerW min_pool_sizemax_idle_time_secondsrVconnect_timeoutOptional[float]socket_timeoutwait_queue_timeout ssl_contextOptional[SSLContext]tls_allow_invalid_hostnamesr@event_listenersOptional[_EventListeners]appname Optional[str]rOptional[DriverInfo]compression_settingsOptional[CompressionSettings]max_connecting pause_enabled server_apiOptional[ServerApi] load_balancedOptional[bool] credentialsOptional[MongoCredential]is_synccCs`||_||_||_||_||_||_||_||_| |_| |_ | |_ | |_ | |_ ||_ ||_||_||_tt|_| rBd| i|jd<trUd|jddd|jdd<|sgd|jddd|jdd<| r| jr}d|jdd| j|jdd<| jrdtdd| j|jdd<| jrdtd| j|jd<t}|r||jd <t|jdS) Nr applicationz{}|{}rcasyncrr0rE)_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__metadatarformatrrr0rgry)selfrrrrrrrrrrrrrrrrrrrEr)r)r,__init__=s^       zPoolOptions.__init__r4cC|jS)z;A :class:`~pymongo.auth.MongoCredentials` instance or None.)rrr)r)r, _credentialszPoolOptions._credentialsrcCsi}|jtkr |j|d<|jtkr|j|d<|jtkr)|jdus"J|jd|d<|jtkr<|jdus5J|jd|d<|jt krF|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 rr rr )roptsr)r)r,non_default_optionss        zPoolOptions.non_default_optionsfloatcCr)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. )rrr)r)r,rs zPoolOptions.max_pool_sizecCr)zThe minimum required number of concurrent connections that the pool will maintain to each connected server. Default is 0. )rrr)r)r,rzPoolOptions.min_pool_sizecCr)zgThe maximum number of concurrent connection creation attempts per pool. Defaults to 2. )rrr)r)r,rrzPoolOptions.max_connectingcCrrR)rrr)r)r,rzPoolOptions.pause_enabledcCr)zThe maximum number of seconds that a connection can remain idle in the pool before being removed and replaced. Defaults to `None` (no limit). )rrr)r)r,rsz!PoolOptions.max_idle_time_secondscCr)z>How long a connection can take to be opened before timing out.)rrr)r)r,rrzPoolOptions.connect_timeoutcCr)zBHow long a send or receive on a socket can take before timing out.)rrr)r)r,rrzPoolOptions.socket_timeoutcCr)zhHow long a thread will wait for a socket from the pool if the pool has no free sockets. )rrr)r)r,rrzPoolOptions.wait_queue_timeoutcCr)zAn SSLContext instance or None.)rrr)r)r, _ssl_contextrzPoolOptions._ssl_contextcCr)z If True skip ssl.match_hostname.)rrr)r)r,rrz'PoolOptions.tls_allow_invalid_hostnamescCr)z2An instance of pymongo.monitoring._EventListeners.)rrr)r)r,_event_listenersrzPoolOptions._event_listenerscCr)zAThe application name, for sending with hello in server handshake.)rrr)r)r,rrzPoolOptions.appnamecCr)z=Driver name and version, for sending with hello in handshake.)rrr)r)r,rrzPoolOptions.drivercCrrR)rrr)r)r,_compression_settingsrz!PoolOptions._compression_settingscCs |jS)zCA dict of metadata about the application, driver, os, and platform.)rrrr)r)r,rhs zPoolOptions.metadatacCr)z'A pymongo.server_api.ServerApi or None.)rrr)r)r,rrzPoolOptions.server_apicCr)z6True if this Pool is configured in load balanced mode.)rrr)r)r,r rzPoolOptions.load_balanced)$rrWrrWrrVrrrrrrVrrrr@rrrrrrrrrrWrr@rrrrrrrr)r4rr4r)r4r)r4rWr4r@)r4rV)r4r)r4r)r4r)r4r)r4r)r4r)r4r)r4r)__name__ __module__ __qualname____doc__ __slots__r r r r r rpropertyrrrrrrrrrrrrrrrrrhrrr)r)r)r,r|sx  Q                  r|)r4r5r)rTrUr4rVr)rhrir4rj)Kr __future__rrrr0syspathlibrtypingrrrrrmpymongorpymongo.commonr r r r r rpymongo.auth_sharedrpymongo.compression_supportrpymongo.driver_inforpymongo.monitoringrpymongo.pyopenssl_contextrpymongo.server_apirr__annotations__rDsystem_namemachinereleasemac_vergetwindowsversion_verenvironrpjoinmaprUjava_ver_arch system_aliasr_aliasedpython_implementationpypy_version_info version_infor8r<r:r=r?rFrJrNrQrSrZrgroryrnr|r)r)r)r,s              (            %  ;