o šhGã @spUdZddlmZddlZddlZddlZddlZddlmZddl m Z m Z m Z m Z ddlZddlmZddlmZmZmZmZmZmZe rkddlmZdd lmZdd lmZdd lmZdd l m!Z!dd l"m#Z#ddedœiZ$de%d<ej &d¡rŽe '¡Z(e(e(e )¡e *¡dœe$d<nˆejdkr§e '¡e '¡e )¡e +¡ddœe$d<noejdkrÕe ,¡Z-ddej. /d¡p»e )¡d 0e1e2e-dd…ƒ¡de-dpÌd›dœe$d<nAej &d¡rîe 3¡d\Z(Z-Z4e(e(e4e-dœe$d<n(e 5e '¡e *¡e 6¡¡Z7e '¡d  0d!d"„e7dd#…Dƒ¡e )¡e7d#dœe$d<e 8¡ &d$¡r;d  0e 8¡d 0e1e2ej9ƒ¡d%d 0e1e2ej:ƒ¡f¡e$d&<n8ej &d¡rad  0e 8¡d 0e1e2ej:ƒ¡d'd  0e '¡e *¡f¡f¡e$d&<nd  0e 8¡d 0e1e2ej:ƒ¡f¡e$d&<d(Z;d)ZdLd.d/„Z?dMd1d2„Z@dMd3d4„ZAdMd5d6„ZBdMd7d8„ZCdMd9d:„ZDdNd>d?„ZEdOd@dA„ZFdBZGdPdFdG„ZHdH IdI¡GdJdK„dKƒZJdS)QzPool options for AsyncMongoClient/MongoClient. .. seealso:: This module is compatible with both the synchronous and asynchronous PyMongo APIs. é)Ú annotationsN)ÚPath)Ú TYPE_CHECKINGÚAnyÚMutableMappingÚOptional)Ú __version__)ÚMAX_CONNECTINGÚMAX_IDLE_TIME_SECÚ MAX_POOL_SIZEÚ MIN_POOL_SIZEÚWAIT_QUEUE_TIMEOUTÚhas_c)ÚMongoCredential)ÚCompressionSettings)Ú DriverInfo)Ú_EventListeners)Ú SSLContext)Ú ServerApiÚdriverZPyMongo)ÚnameÚversionúdict[str, Any]Ú _METADATAÚlinux)ÚtyperÚ architecturerÚosÚdarwinÚwin32ÚWindowsÚPROCESSOR_ARCHITECTUREÚ.éz-SPéÿÿÿÿÚ0Újavaú cCsg|]}|r|‘qS©r()Ú.0Úpartr(r(úG/var/www/html/venv/lib/python3.10/site-packages/pymongo/pool_options.pyÚ bsr,éÚPyPyz (Python %s)Úplatformz(%s)z /.dockerenvZKUBERNETES_SERVICE_HOSTÚdockerZ kubernetesÚreturnúdict[str, str]cCs.i}ttƒ ¡r t|d<t t¡rt|d<|S)zŽReturns the runtime and orchestrator of a container. If neither value is present, the metadata client.env.container field will be omitted.ÚruntimeZ orchestrator)rÚDOCKER_ENV_PATHÚexistsÚRUNTIME_NAME_DOCKERrÚgetenvÚ ENV_VAR_K8SÚORCHESTRATOR_NAME_K8S)Ú containerr(r(r+Úget_container_env_infoƒs   r;ÚboolcCs*t d¡rdSt d¡}|r| d¡SdS)NZAWS_LAMBDA_RUNTIME_APITZAWS_EXECUTION_ENVZ AWS_Lambda_F)rr7Ú startswith)Úenvr(r(r+Ú _is_lambdas   r?cCótt d¡ƒS)NZFUNCTIONS_WORKER_RUNTIME©r<rr7r(r(r(r+Ú_is_azure_func™órBcCstt d¡p t d¡ƒS)NZ K_SERVICEZ FUNCTION_NAMErAr(r(r(r+Ú _is_gcp_funcórDcCr@)NZVERCELrAr(r(r(r+Ú _is_vercel¡rCrFcCstƒp tƒp tƒp tƒS©N)r?rBrDrFr(r(r(r+Ú_is_faas¥rErHÚkeyÚstrú Optional[int]cCs2t |¡}|s dSzt|ƒWStyYdSw)zMLike os.getenv but returns an int, or None if the value is missing/malformed.N)rr7ÚintÚ ValueError)rIÚvalr(r(r+Ú _getenv_int©s   ÿrOcCs i}tƒ}|r ||d<tƒtƒtƒtƒf d¡dkr|Stƒrr:rQrRrSr(r(r+Ú _metadata_env´sH îð û rUiÚmetadataúMutableMapping[str, Any]ÚNonec Csætt |¡ƒtkr dS| di¡ d¡}|rd|i|d<tt |¡ƒtkr'dS| di¡ d¡}|r8d|i|d<tt |¡ƒtkrCdS| dd¡tt |¡ƒ}|tkrVdS|t}| dd¡}|ri|d| …}|rp||d<n| dd¡tt |¡ƒ}|tkrƒdS|t}| di¡}|rñ| d ¡d| …}t|ƒttdd ƒkr¬||dd <n tdd |dd <tt |¡ƒ}|tkrÃdS|t}| d¡d| …}t|ƒttddƒkrå||dd<dStdd|dd<dSdS) zPerform metadata truncation.Nr>rrrr/Úrr)ÚlenÚbsonÚencodeÚ_MAX_METADATA_SIZEÚgetÚpopr) rVÚenv_nameZos_typeZ encoded_sizeÚoverflowÚplatrZdriver_versionZ driver_namer(r(r+Ú_truncate_metadataÝsT       ðrcZfooÚidnac@sNeZdZdZdZeeeddedddddde dddddfdOd$d%„Z e dPd'd(„ƒZ e dQd*d+„ƒZ e dRd-d.„ƒZe dSd/d0„ƒZe dSd1d2„ƒZe dTd3d4„ƒZe dUd5d6„ƒZe dVd7d8„ƒZe dVd9d:„ƒZe dUd;d<„ƒZe dWd=d>„ƒZe dTd?d@„ƒZe dXdAdB„ƒZe dYdCdD„ƒZe dZdEdF„ƒZe d[dGdH„ƒZe dQdIdJ„ƒZe d\dKdL„ƒZe d]dMdN„ƒZdS)^Ú 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 __credentialsNFTÚ max_pool_sizerLÚ min_pool_sizeÚmax_idle_time_secondsrKÚconnect_timeoutúOptional[float]Úsocket_timeoutÚwait_queue_timeoutÚ ssl_contextúOptional[SSLContext]Útls_allow_invalid_hostnamesr<Úevent_listenersúOptional[_EventListeners]Úappnameú Optional[str]rúOptional[DriverInfo]Úcompression_settingsúOptional[CompressionSettings]Úmax_connectingÚ pause_enabledÚ server_apiúOptional[ServerApi]Ú load_balancedúOptional[bool]Ú credentialsúOptional[MongoCredential]Úis_synccCs`||_||_||_||_||_||_||_||_| |_| |_ | |_ | |_ | |_ ||_ ||_||_||_t t¡|_| rBd| i|jd<tƒrUd |jddd¡|jdd<|sgd |jddd¡|jdd<| rŸ| jr}d |jdd| j¡|jdd<| jrd tdd| j¡|jdd<| jrŸd td| j¡|jd<tƒ}|r©||jd <t|jƒdS) NrZ applicationz{}|{}rÚcÚasyncrr/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__credentialsÚcopyÚdeepcopyrÚ_PoolOptions__metadatarÚformatrrr/rUrc)Úselfrfrgrhrirkrlrmrorprrrrurwrxryr{r}rr>r(r(r+Ú__init__=s^   þ þ þ þ zPoolOptions.__init__r1cCó|jS)z;A :class:`~pymongo.auth.MongoCredentials` instance or None.)r’©r—r(r(r+Ú _credentialsŽózPoolOptions._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`. Z maxPoolSizeZ minPoolSizeNièZ maxIdleTimeMSZwaitQueueTimeoutMSZ maxConnecting) r‚r rƒr r„r r‡r rŽr )r—Úoptsr(r(r+Únon_default_options“s        zPoolOptions.non_default_optionsÚfloatcCr™)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. )r‚ršr(r(r+rf¨s zPoolOptions.max_pool_sizecCr™)zŠThe minimum required number of concurrent connections that the pool will maintain to each connected server. Default is 0. )rƒršr(r(r+rg·ózPoolOptions.min_pool_sizecCr™)zgThe maximum number of concurrent connection creation attempts per pool. Defaults to 2. )rŽršr(r(r+rw¾r zPoolOptions.max_connectingcCr™rG)rršr(r(r+rxÅózPoolOptions.pause_enabledcCr™)z¦The maximum number of seconds that a connection can remain idle in the pool before being removed and replaced. Defaults to `None` (no limit). )r„ršr(r(r+rhÉsz!PoolOptions.max_idle_time_secondscCr™)z>How long a connection can take to be opened before timing out.)r…ršr(r(r+riÑrœzPoolOptions.connect_timeoutcCr™)zBHow long a send or receive on a socket can take before timing out.)r†ršr(r(r+rkÖrœzPoolOptions.socket_timeoutcCr™)zhHow long a thread will wait for a socket from the pool if the pool has no free sockets. )r‡ršr(r(r+rlÛr zPoolOptions.wait_queue_timeoutcCr™)zAn SSLContext instance or None.)rˆršr(r(r+Ú _ssl_contextârœzPoolOptions._ssl_contextcCr™)z If True skip ssl.match_hostname.)r‰ršr(r(r+roçrœz'PoolOptions.tls_allow_invalid_hostnamescCr™)z2An instance of pymongo.monitoring._EventListeners.)rŠršr(r(r+Ú_event_listenersìrœzPoolOptions._event_listenerscCr™)zAThe application name, for sending with hello in server handshake.)r‹ršr(r(r+rrñrœzPoolOptions.appnamecCr™)z=Driver name and version, for sending with hello in handshake.)rŒršr(r(r+rörœzPoolOptions.drivercCr™rG)rršr(r(r+Ú_compression_settingsûr¡z!PoolOptions._compression_settingscCs |j ¡S)zCA dict of metadata about the application, driver, os, and platform.)r•r“ršr(r(r+rVÿs zPoolOptions.metadatacCr™)z'A pymongo.server_api.ServerApi or None.)rršr(r(r+ryrœzPoolOptions.server_apicCr™)z6True if this Pool is configured in load balanced mode.)r‘ršr(r(r+r{ rœzPoolOptions.load_balanced)$rfrLrgrLrhrKrirjrkrjrlrKrmrnror<rprqrrrsrrtrurvrwrLrxr<ryrzr{r|r}r~rr|)r1r~©r1r)r1rŸ)r1rL©r1r<)r1rK)r1rj)r1rn)r1rq)r1rs)r1rt)r1rv)r1rz)r1r|)Ú__name__Ú __module__Ú __qualname__Ú__doc__Ú __slots__r r r r r r˜Úpropertyr›ržrfrgrwrxrhrirkrlr¢ror£rrrr¤rVryr{r(r(r(r+resx  íQ                  re)r1r2r¦)rIrJr1rKr¥)rVrWr1rX)KrªÚ __future__rr“rr/ÚsysÚpathlibrÚtypingrrrrr[ZpymongorZpymongo.commonr r r r r rZpymongo.auth_sharedrZpymongo.compression_supportrZpymongo.driver_inforZpymongo.monitoringrZpymongo.pyopenssl_contextrZpymongo.server_apirrÚ__annotations__r=ÚsystemÚ_nameÚmachineÚreleaseÚmac_verÚgetwindowsversionÚ_verÚenvironr^ÚjoinÚmaprJÚjava_verZ_archÚ system_aliasrZ_aliasedÚpython_implementationÚpypy_version_infoÚ version_infor4r8r6r9r;r?rBrDrFrHrOrUr]rcr\rer(r(r(r+Úsª            û   ú ( ú  ù  üý ÿý ÿÿ      %  ;