IiF %SrSSKJr SSKrSSKrSSKrSSKrSSKJr SSK J r J r J r J r SSKrSSKJr SSKJrJrJrJrJrJr \ (a$SSKJr SS KJr SS KJr SS KJr SS K J!r! SS K"J#r# SS\S.0r$S\%S'\R RMS5(a;\RN"5r(\(\(\RR"5\RT"5S.\$S'GO\R S:XaK\RN"5\RN"5\RR"5\RV"5SS.\$S'GOc\R S:Xay\RN"5SRY\RN"5\RT"545\RR"5SRY\RZ"5SS5S.\$S'O\R RMS5(a#\R\"5Sur(r/r0\(\(\0\/S.\$S'O\Rb"\RN"5\RT"5\Rd"55r3\RN"5SRY\3SSVs/sH o(dM UPM sn5\RR"5\3SS.\$S'\Rh"5RMS5(ajSRY\Rh"5S RY\5"\6\Rn55S!S RY\5"\6\Rp55-45\$S"'O\R RMS5(aySRY\Rh"5S RY\5"\6\Rp55S#SRY\RN"5\RT"545-45\$S"'OESRY\Rh"5S RY\5"\6\Rp5545\$S"'S$r9S%r:S&r;S'rS7S*jr?S7S+jr@S7S,jrAS7S-jrBS8S.jrCS9S/jrDS0rES:S1jrFS2RS35 "S4S55rHgs snf);zPool 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 architecturerosdarwinwin32 -javaPyPy.z (Python %s)platformz(%s)z /.dockerenvKUBERNETES_SERVICE_HOSTdocker kubernetesc0n[[5R5(a [US'[R "[ 5(a [US'U$)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 :/venv/lib/python3.13/site-packages/pymongo/pool_options.pyget_container_env_infor:sFI O##%%2 ) yy$9 .! c[R"S5(ag[R"S5nU(aURS5$g)NAWS_LAMBDA_RUNTIME_APITAWS_EXECUTION_ENV AWS_Lambda_F)rr5 startswith)envs r9 _is_lambdarBs9 yy)** ))' (C ~~m,, r;c@[[R"S55$)NFUNCTIONS_WORKER_RUNTIMEboolrr5r;r9_is_azure_funcrHs  45 66r;cz[[R"S5=(d [R"S55$)N K_SERVICE FUNCTION_NAMErErGr;r9 _is_gcp_funcrLs$  +&D"))O*D EEr;c@[[R"S55$)NVERCELrErGr;r9 _is_vercelrOs  (# $$r;c|[5=(d, [5=(d [5=(d [5$N)rBrHrLrOrGr;r9_is_faasrRs < M>+ M|~ MMr;cv[R"U5nU(dg[U5$![a gf=f)zMLike os.getenv but returns an int, or None if the value is missing/malformed.N)rr5int ValueError)keyvals r9 _getenv_intrXs5 ))C.C 3x s + 88c0n[5nU(aXS'[5[5[5[ 54R S5S:waU$[5(a:SUS'[ R"S5nU(aX S'[S5nUbX0S 'U$[5(aS US'U$[5(aLS US'[ R"S 5nU(aX S'[S 5nUbX0S '[S5nUbX@S'U$[ 5(a&SUS'[ R"S5nU(aX S'U$)Nr8Tr$z aws.lambdar AWS_REGIONregionAWS_LAMBDA_FUNCTION_MEMORY_SIZE memory_mbz azure.funczgcp.funcFUNCTION_REGIONFUNCTION_MEMORY_MBFUNCTION_TIMEOUT_SEC timeout_secvercel VERCEL_REGION) r:rBrHrLrOcountrr5rX)rAr8r[r]ras r9 _metadata_envres;C&(I$K n&  EKKDQUVV ||"F <( "M AB  ( & J%   "F " J!  F ,- "M 45  ( !"89  "!,  J F ?+ "M Jr;ic[[R"U55[::agUR S05R S5nU(aSU0US'[[R"U55[::agUR S05R S5nU(aSU0US'[[R"U55[::agUR SS5 [[R"U55nU[::agU[- nUR SS5nU(aUSU*nU(aXPS'OUR SS5 [[R"U55nU[::agU[- nUR S05nU(aUR S 5SU*n[U5[[ SS 5:aXpSS 'O[ SS USS '[[R"U55nU[::agU[- nUR S5SU*n[U5[[ SS5:aXSS'g[ SSUSS'gg) zPerform metadata truncation.NrArrrr+rr)lenbsonencode_MAX_METADATA_SIZEgetpopr) metadataenv_nameos_type encoded_sizeoverflowplatrdriver_version driver_names r9_truncate_metadatarvs8 4;;x !%77||E2&**62H!8, 4;;x !%77ll4$((0G '* 4;;x !%77 LLt{{8,-L))00H << B 'D JhY # Z&t{{8,-L))00H \\(B 'F I.z : ~ #i&9)&D"E E,:X y ),5h,? ,JHX y )4;;x01 - - "44jj(8)4 { s9X#6v#>? ?)4X v &)28)DOOM * 7707)&11DOOH %f -07)&11DOOH %f - {{4;NNOOH-f5KK5)&1~~7>~~h' 2NN8))4.5nnYz=RTZTcTc.d +o %(DOOE "4??+r;cUR$)z;A :class:`~pymongo.auth.MongoCredentials` instance or None.)rrs r9 _credentialsPoolOptions._credentials!!!r;c0nUR[:waURUS'UR[:waURUS'UR[ :wa!URceURS-US'UR [:wa!UR ceUR S-US'UR[:waURUS'U$)zaThe non-default options this pool was created with. Added for CMAP's :class:`PoolCreatedEvent`. maxPoolSize minPoolSizei maxIdleTimeMSwaitQueueTimeoutMS maxConnecting) rr rr rr rrrr )roptss r9non_default_optionsPoolOptions.non_default_optionss    = 0"&"6"6D    = 0"&"6"6D   ' '+< <//; ;;$($@$@4$GD !  $ $(: :,,8 88)-)B)BT)ID% &  N 2$($9$9D ! r;cUR$)a The 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 r9rPoolOptions.max_pool_sizes###r;cUR$)zzThe minimum required number of concurrent connections that the pool will maintain to each connected server. Default is 0. )rrs r9rPoolOptions.min_pool_sizes ###r;cUR$)zWThe maximum number of concurrent connection creation attempts per pool. Defaults to 2. )rrs r9rPoolOptions.max_connectings $$$r;cUR$rQ)rrs r9rPoolOptions.pause_enableds###r;cUR$)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 r9r!PoolOptions.max_idle_time_secondss +++r;cUR$)z>How long a connection can take to be opened before timing out.)rrs r9rPoolOptions.connect_timeout%%%r;cUR$)zBHow long a send or receive on a socket can take before timing out.)rrs r9rPoolOptions.socket_timeouts$$$r;cUR$)zXHow long a thread will wait for a socket from the pool if the pool has no free sockets. )rrs r9rPoolOptions.wait_queue_timeouts (((r;cUR$)zAn SSLContext instance or None.)rrs r9 _ssl_contextPoolOptions._ssl_contextrr;cUR$)z If True skip ssl.match_hostname.)rrs r9r'PoolOptions.tls_allow_invalid_hostnamess111r;cUR$)z2An instance of pymongo.monitoring._EventListeners.)rrs r9_event_listenersPoolOptions._event_listenersrr;cUR$)zAThe application name, for sending with hello in server handshake.)rrs r9rPoolOptions.appnames~~r;cUR$)z=Driver name and version, for sending with hello in handshake.)rrs r9rPoolOptions.drivers}}r;cUR$rQ)rrs r9_compression_settings!PoolOptions._compression_settingss***r;c6URR5$)zCA dict of metadata about the application, driver, os, and platform.)rrrs r9rnPoolOptions.metadatas##%%r;cUR$)z'A pymongo.server_api.ServerApi or None.)rrs r9rPoolOptions.server_apis   r;cUR$)z6True if this Pool is configured in load balanced mode.)rrs r9rPoolOptions.load_balanceds###r;)rrr~rrrrrr}r{rr|rrrrrr)$rrTrrTr Optional[int]rOptional[float]rrrrrOptional[SSLContext]rrFrOptional[_EventListeners]r Optional[str]rOptional[DriverInfo]rOptional[CompressionSettings]rrTrrFrOptional[ServerApi]rOptional[bool]rOptional[MongoCredential]rr)returnrrr)rfloat)rrTrrF)rr)rr)rr)rr)rr)rr)rr)rr)rr)!__name__ __module__ __qualname____firstlineno____doc__ __slots__r r r rr rpropertyrrrrrrrrrrrrrrrrrnrr__static_attributes__rGr;r9rzrzs I.+*/@+/*.,>,0,159!%'+>B,"*.(,15"&'O,O,O, - O, ) O, ( O,*O,*O,&*O,3O,O,%O,<O,O,O, (!O,"&#O,$/%O,& 'O,b""( $ $$$ %% $$,,&&%%)) ""22&&++&&!!$$r;rz)rzdict[str, str]r)rVstrrrr)rnzMutableMapping[str, Any]rNone)Ir __future__rrrr+syspathlibrtypingrrrrripymongor pymongo.commonr r r r rrpymongo.auth_sharedrpymongo.compression_supportrpymongo.driver_inforpymongo.monitoringrpymongo.pyopenssl_contextrpymongo.server_apirr__annotations__r@system_namemachinereleasemac_verjoin win32_verjava_ver_ver_arch system_aliasr_aliasedpython_implementationmaprpypy_version_info version_infor2r6r4r7r:rBrHrLrOrRrXrerkrvrjrz)parts0r9r$s#  ?? 3?.24,& k'RS >S<<7## OO E ((*##% IdO \\X!! ((*##%a( IdO \\W!(//+X-=-=-?@A ((*88H..0156 IdO \\V$$!**,R0E4IdO$$X__%68H8H8JHL\L\L^_H!8BQ<@<44$<@A ((*A; IdO !!#..v66HH  * * , HHSc334 5 CHHSc.>.>%?@ @ Ij \\V$$HH  * * , HHSc../ 0 SXXx0(2B2B2DEF F Ij HH  ' ' )388CS=M=M4N+OPIj ' $ 7F%N"J4Ev Vq$q$sAs " Q 0Q