MCPcopy Create free account

hub / github.com/MagicStack/asyncpg / functions

Functions868 in github.com/MagicStack/asyncpg

↓ 1 callersMethod_check_conn_validity
(self, meth_name)
asyncpg/prepared_stmt.py:280
↓ 1 callersMethod_check_conn_validity
(self, meth_name)
asyncpg/connresource.py:32
↓ 1 callersMethod_check_open
(self, meth_name)
asyncpg/prepared_stmt.py:274
↓ 1 callersMethod_clean_tasks
(self)
asyncpg/connection.py:1595
↓ 1 callersMethod_cleanup_stmts
(self)
asyncpg/connection.py:1641
↓ 1 callersFunction_close_candidates
(conns, chosen)
asyncpg/connect_utils.py:1237
↓ 1 callersMethod_close_connection
(self, connection)
asyncpg/_testbase/fuzzer.py:143
↓ 1 callersMethod_close_portal
(self, timeout)
asyncpg/cursor.py:161
↓ 1 callersFunction_connect_addr
( *, addr, loop, params, config, connection_class, record_class )
asyncpg/connect_utils.py:1022
↓ 1 callersMethod_connection_addr_from_pidfile
(self)
asyncpg/cluster.py:462
↓ 1 callersMethod_copy_in
(self, copy_stmt, source, timeout)
asyncpg/connection.py:1210
↓ 1 callersMethod_detach
(self)
asyncpg/pool.py:95
↓ 1 callersFunction_detect_server_capabilities
(server_version, connection_settings)
asyncpg/connection.py:2676
↓ 1 callersMethod_drop_global_type_cache
(self)
asyncpg/connection.py:1807
↓ 1 callersMethod_drop_statement_cache
(self)
asyncpg/pool.py:1020
↓ 1 callersMethod_drop_type_cache
(self)
asyncpg/pool.py:1026
↓ 1 callersFunction_extract_stack
Replacement for traceback.extract_stack() that only does the necessary work for asyncio debug mode.
asyncpg/connection.py:2725
↓ 1 callersMethod_find_pg_config
(self, pg_config_path)
asyncpg/cluster.py:563
↓ 1 callersMethod_format_loop_exception
(self, context, n)
asyncpg/_testbase/__init__.py:183
↓ 1 callersMethod_get_error_class
(cls, fields)
asyncpg/exceptions/_base.py:81
↓ 1 callersMethod_get_error_dict
(cls, fields, query)
asyncpg/exceptions/_base.py:86
↓ 1 callersFunction_get_error_name
(sqlstatename, msgtype, sqlstate)
tools/generate_exceptions.py:39
↓ 1 callersMethod_get_new_connection
(self)
asyncpg/pool.py:537
↓ 1 callersMethod_get_pg_version
(self)
asyncpg/cluster.py:601
↓ 1 callersFunction_init_default_cluster
(initdb_options=None)
asyncpg/_testbase/__init__.py:242
↓ 1 callersMethod_initialize
(self)
asyncpg/pool.py:445
↓ 1 callersMethod_issubset_lower
(self, other: Self)
asyncpg/types.py:134
↓ 1 callersMethod_issubset_upper
(self, other: Self)
asyncpg/types.py:145
↓ 1 callersMethod_iter_methods
(bases, ns)
asyncpg/_testbase/__init__.py:56
↓ 1 callersMethod_main
(self, started_event)
asyncpg/_testbase/fuzzer.py:94
↓ 1 callersMethod_mark_stmts_as_closed
(self)
asyncpg/connection.py:1612
↓ 1 callersFunction_mkdtemp
(suffix=None, prefix=None, dir=None)
asyncpg/cluster.py:63
↓ 1 callersMethod_new_entry
(self, query, statement)
asyncpg/connection.py:2594
↓ 1 callersMethod_on_release
(self, stacklevel=1)
asyncpg/connection.py:1781
↓ 1 callersFunction_parse_connect_arguments
(*, dsn, host, port, user, password, passfile, database, command_timeout,
asyncpg/connect_utils.py:862
↓ 1 callersFunction_parse_connect_dsn_and_args
(*, dsn, host, port, user, password, passfile, database, ssl,
asyncpg/connect_utils.py:276
↓ 1 callersFunction_read_password_file
(passfile: pathlib.Path)
asyncpg/connect_utils.py:94
↓ 1 callersFunction_read_password_from_pgpass
Parse the pgpass file and return the matching password. :return: Password string, if found, ``None`` otherwise.
asyncpg/connect_utils.py:137
↓ 1 callersMethod_run_pg_config
(self, pg_config_path)
asyncpg/cluster.py:545
↓ 1 callersFunction_system_timezone
()
tests/test_codecs.py:28
↓ 1 callersFunction_world_readable_mkdtemp
(suffix=None, prefix=None, dir=None)
asyncpg/cluster.py:50
↓ 1 callersMethod_wrap_connection_method
( meth_name: str, iscoroutine: bool )
asyncpg/pool.py:58
↓ 1 callersMethodadd_query_logger
Add a logger that will be called when queries are executed. :param callable callback: A callable or a coroutine function receivin
asyncpg/connection.py:229
↓ 1 callersMethodclose
Close the connection gracefully. :param float timeout: Optional timeout value in seconds. .. versionchanged:: 0.14.0
asyncpg/connection.py:1502
↓ 1 callersMethodclose_all_connections
(self)
asyncpg/_testbase/fuzzer.py:148
↓ 1 callersMethodcommit
Exit the transaction or savepoint block and commit changes.
asyncpg/transaction.py:214
↓ 1 callersMethodconnect
(self, loop=None, **kwargs)
asyncpg/cluster.py:127
↓ 1 callersFunctioncreate_pool
(dsn=None, *, min_size=10, max_size=10, max_queries=50000,
asyncpg/_testbase/__init__.py:269
↓ 1 callersFunctionfind_available_port
()
asyncpg/cluster.py:39
↓ 1 callersMethodfoo
(self)
tests/test_pool.py:494
↓ 1 callersMethodget_max_lifetime
(self)
asyncpg/connection.py:2521
↓ 1 callersMethodget_min_size
Return the minimum number of connections in this pool. .. versionadded:: 0.25.0
asyncpg/pool.py:492
↓ 1 callersMethodget_name
Return the name of this prepared statement. .. versionadded:: 0.25.0
asyncpg/prepared_stmt.py:29
↓ 1 callersMethodget_query
Return the text of the query for this prepared statement. Example:: stmt = await connection.prepare('SELECT $1::int')
asyncpg/prepared_stmt.py:37
↓ 1 callersMethodget_reset_query
Return the query sent to server on connection release. The query returned by this method is used by :meth:`Connection.reset`, which i
asyncpg/connection.py:1732
↓ 1 callersFunctiongit_commitish
()
setup.py:58
↓ 1 callersMethodhandle
(self)
asyncpg/_testbase/fuzzer.py:181
↓ 1 callersMethodhas
(self, query)
asyncpg/connection.py:2555
↓ 1 callersMethodinit
Initialize cluster.
asyncpg/cluster.py:132
↓ 1 callersMethodis_idle
(self)
asyncpg/pool.py:144
↓ 1 callersMethodissuperset
(self, other: Self)
asyncpg/types.py:164
↓ 1 callersFunctionmain
()
tools/generate_type_map.py:113
↓ 1 callersFunctionmain
()
tools/generate_exceptions.py:68
↓ 1 callersFunctionmain
()
tests/certs/gen.py:190
↓ 1 callersMethodnew
(cls, fields, query=None)
asyncpg/exceptions/_base.py:178
↓ 1 callersFunctionnew_ca
(path, **subject)
tests/certs/gen.py:154
↓ 1 callersFunctionnew_cert
( path, ca_cert_key_pair, password=None, is_issuer=False, **subject )
tests/certs/gen.py:160
↓ 1 callersFunctionnew_crl
(path, issuer, cert)
tests/certs/gen.py:170
↓ 1 callersMethodoverride_connection_spec
(self, **kwargs)
asyncpg/cluster.py:328
↓ 1 callersMethodproxy_from_backend
(self)
asyncpg/_testbase/fuzzer.py:282
↓ 1 callersMethodproxy_to_backend
(self)
asyncpg/_testbase/fuzzer.py:256
↓ 1 callersMethodput
(self, query, statement)
asyncpg/connection.py:2558
↓ 1 callersMethodremove_query_logger
Remove a query logger callback. :param callable callback: The callable or coroutine function that was passed to :meth
asyncpg/connection.py:241
↓ 1 callersMethodreset
Reset the connection state. Calling this will reset the connection session state to a state resembling that of a newly obtained conne
asyncpg/connection.py:1544
↓ 1 callersMethodreset
(self)
asyncpg/_testbase/fuzzer.py:140
↓ 1 callersMethodreset_wal
(self, *, oid=None, xid=None)
asyncpg/cluster.py:331
↓ 1 callersFunctionrunner
(args)
tools/generate_type_map.py:46
↓ 1 callersMethodsetUp
(self)
tests/test_connect.py:1818
↓ 1 callersMethodsetUpClass
(cls)
tests/test_connect.py:399
↓ 1 callersMethodsetup
(con)
tests/test_pool.py:126
↓ 1 callersMethodsetup_cluster
(cls)
asyncpg/_testbase/__init__.py:324
↓ 1 callersMethodsimulate_cluster_recovery_mode
(self)
tests/test_pool.py:1016
↓ 1 callersFunctionsplit_server_version_string
(version_string: str)
asyncpg/serverversion.py:32
↓ 1 callersMethodstart
Enter the transaction or savepoint block.
asyncpg/transaction.py:96
↓ 1 callersMethodstop
(self, wait=60)
asyncpg/cluster.py:282
↓ 1 callersFunctionsuite
()
tests/__init__.py:13
↓ 1 callersMethodtearDown
(self)
tests/test_connect.py:1835
↓ 1 callersMethodterminate
Terminate the connection without waiting for pending data.
asyncpg/connection.py:1521
↓ 1 callersMethodtrust_local_replication_by
(self, user)
asyncpg/cluster.py:434
↓ 1 callersMethodwait_until_released
(self)
asyncpg/pool.py:258
FunctionTypeRecord
( rec: typing.Tuple[int, typing.Optional[int], bytes], )
asyncpg/introspection.py:272
Method__aenter__
(self)
asyncpg/transaction.py:63
Method__aenter__
(self)
asyncpg/pool.py:1035
Method__aenter__
(self)
asyncpg/pool.py:1053
Method__aexit__
(self, extype, ex, tb)
asyncpg/transaction.py:70
Method__aexit__
(self, *exc)
asyncpg/pool.py:1039
Method__aexit__
( self, exc_type: Optional[Type[BaseException]] = None, exc_val: Optional[BaseExceptio
asyncpg/pool.py:1059
Method__aiter__
(self)
asyncpg/connection.py:1243
Method__aiter__
(self)
asyncpg/cursor.py:51
Method__aiter__
(self)
asyncpg/cursor.py:219
← previousnext →201–300 of 868, ranked by callers