o sDiE @sUdZddlmZddlZddlZddlZddlZddlmZddl 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<noejdkre'e'e)e+dde$d<nVejdkre,Z-ddej./dpe)d0e1e2e-ddde-dpdde$d<n(e3e'e*e4Z5e'd0d d!e5dd"De)e5d"de$d<e6&d#r"d0e6d0e1e2ej7d$d0e1e2ej8fe$d%<nd0e6d0e1e2ej8fe$d%<d&Z9d'Z:d(Z;d)ZdKd1d2Z?dKd3d4Z@dKd5d6ZAdKd7d8ZBdLdd?ZDd@ZEdNdDdEZFdFGdGGdHdIdIZHdS)OzPool 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-SP0 cCsg|]}|r|qSr().0partr(r(R/home/alumno/antzosa8961/venv/lib/python3.10/site-packages/pymongo/pool_options.py Wsr,PyPyz (Python %s)platformz /.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_infops   r>boolcCs*tdrdStd}|r|dSdS)NAWS_LAMBDA_RUNTIME_APITAWS_EXECUTION_ENV AWS_Lambda_F)rr: startswith)envr(r(r+ _is_lambda}s   rEcCttdS)NFUNCTIONS_WORKER_RUNTIMEr?rr:r(r(r(r+_is_azure_funcrIcCsttdp tdS)N K_SERVICE FUNCTION_NAMErHr(r(r(r+ _is_gcp_funcrMcCrF)NVERCELrHr(r(r(r+ _is_vercelrJrPcCstp tp tp tSN)rErIrMrPr(r(r(r+_is_faasrNrRkeystr 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)rSvalr(r(r+ _getenv_ints   rYcCs i}t}|r ||d<ttttfddkr|StrrErIrMrPcountrr:rY)rDr=r\r^rbr(r(r+ _metadata_envsH   rfimetadataMutableMapping[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.NrDrrrr/rr)lenbsonencode_MAX_METADATA_SIZEgetpopr) rgenv_nameos_type encoded_sizeoverflowplatrdriver_version driver_namer(r(r+_truncate_metadatasT       rxfooidnac@sXeZdZdZdZeeeddedddddde dddddfdSd$d%Z dTd)d*Z e dUd+d,Z e dVd.d/Ze dWd1d2Ze dXd3d4Ze dXd5d6Ze dYd7d8Ze dZd9d:Ze d[d;d<Ze d[d=d>Ze dZd?d@Ze d\dAdBZe dYdCdDZe d]dEdFZe d^dGdHZe d_dIdJZe d`dKdLZe dVdMdNZe dadOdPZe dbdQdRZdS)c 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_sizerV min_pool_sizemax_idle_time_secondsrUconnect_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<| rn|| t}|rx||jd<t|jdS)Nr application{}|{}rcasyncrD)_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_metadatarfrx)selfrrrrrrrrrrrrrrrrrrrDr(r(r+__init__*sH      zPoolOptions.__init__rr3ricCs|jr|j|jdddvrdSt|j}|jr.d|dd|j|dd<|jr@d|dd|j|dd<|jrNd|d|j|d<||_dS)zUpdates the client's metadatarr|Nrrr/) rlowerrsplitrrrrr/)rrrgr(r(r+rps$       zPoolOptions._update_metadatacC|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_connectingcCrrQ)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.drivercCrrQ)rrr(r(r+_compression_settingsrz!PoolOptions._compression_settingscCs |jS)zCA dict of metadata about the application, driver, os, and platform.)rrrr(r(r+rgs 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+rrzPoolOptions.load_balanced)$rrVrrVrrUrrrrrrUrrrr?rrrrrrrrrrVrr?rrrrrrrr)rrr3ri)r3rr3r)r3r)r3rVr3r?)r3rU)r3r)r3r)r3r)r3r)r3r)r3r)r3r)r3r) __name__ __module__ __qualname____doc__ __slots__r r r r r rrpropertyrrrrrrrrrrrrrrrrrgrrr(r(r(r+r{sz  F                  r{)r3r4r)rSrTr3rUr)rgrhr3ri)Ir __future__rrrr/syspathlibrtypingrrrrrlpymongorpymongo.commonr r r r r rpymongo.auth_sharedrpymongo.compression_supportrpymongo.driver_inforpymongo.monitoringrpymongo.pyopenssl_contextrpymongo.server_apirr__annotations__rCsystem_namemachinereleasemac_vergetwindowsversion_verenvironrojoinmaprT system_aliasr_aliasedpython_implementationpypy_version_info version_infor7r;r9r<r>rErIrMrPrRrYrfrnrxrmr{r(r(r(r+s              (          %  ;