љi BSSKrSSKJr SSKrSSKJr "SS\5rg)N)Optional) PoolProviderc\rSrSrSrSS\S\S\S\S\S \S \S \4S jjr\S \4Sj5r S \ R4Sjr SSjr S \4SjrSrg)PostgreSQLPoolProvider a Centralized PostgreSQL connection pool provider. Use this to share a single connection pool across multiple components, enabling better control over total database connections. Example: pool_provider = PostgreSQLPoolProvider( connection_str="postgresql://user:pass@localhost:5432/db", min_size=5, max_size=30, ) context_manager = PostgreSQLContextManager(get_pool=pool_provider.get_pool) session_manager = PostgreSQLSessionStateManager(get_pool=pool_provider.get_pool) Nconnection_strhostportdbnameuserpasswordmin_sizemax_sizec XlX lX0lX@lXPlX`lXplXlSUl[R"5Ul g)N) r r r r r rrr_poolasyncioLock _pool_lock) selfr r r r r rrrs T/home/james-whalen/.local/lib/python3.13/site-packages/aiavatar/database/postgres.py__init__PostgreSQLPoolProvider.__init__sA-       -1 !,,.returncg)N postgresqlrs rdb_typePostgreSQLPoolProvider.db_type2src # URb UR$URIShvN URbURsSSS5IShvN $UR(aB[R"URUR UR S9IShvN UlOm[R"URURURURURUR UR S9IShvN UlURsSSS5IShvN $GN NNN-N!,IShvN (df  g=f7f)z Get the shared connection pool, creating it on first access. This method is thread-safe and will only create one pool even if called concurrently from multiple coroutines. N)dsnrr)r r databaser rrr) rrr asyncpg create_poolrrr r r r rrs rget_poolPostgreSQLPoolProvider.get_pool6s :: !:: ???zz%zz#??""#*#6#6++!]]!]]$ $+#6#6![[!]]!]]!]]$ ::+#??  #???s*ED8EE ED;EAE#D=$A-ED?E& E2E3E;E=E?EEE E EEc~# URb*URR5IShvN SUlggN 7f)z'Close the connection pool if it exists.N)rclosers rr*PostgreSQLPoolProvider.closeWs4 :: !**""$ $ $DJ " $s +=;=c\URcSS0$SURR5URR5URR5URR5- URR5URR 5S.$)ap Get current pool statistics. Returns: dict: Pool statistics including: - initialized: Whether the pool has been created - size: Total connections in the pool - idle: Idle (available) connections - in_use: Currently used connections - min_size: Configured minimum pool size - max_size: Configured maximum pool size initializedFT)r-sizeidlein_userr)rget_size get_idle_size get_min_size get_max_sizers r get_stats PostgreSQLPoolProvider.get_stats]s :: !5) ) JJ'')JJ,,.jj))+djj.F.F.HH //1 //1   r) rrr r r rrrr r )N localhosti8NNN)rN)__name__ __module__ __qualname____firstlineno____doc__strintrpropertyr r%Poolr'r*dictr5__static_attributes__rrrrr s&#))) )  )  )))). B  4 rr)rtypingrr%baserrrrrrGsk \k r