Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/MagicStack/asyncpg
/ functions
Functions
868 in github.com/MagicStack/asyncpg
⨍
Functions
868
◇
Types & classes
397
↳
Endpoints
6
↓ 3 callers
Method
_reset
(self)
asyncpg/connection.py:1527
↓ 3 callers
Method
_time_and_log
(self, query, args, timeout)
asyncpg/connection.py:1915
↓ 3 callers
Method
_unwrap
(self)
asyncpg/connection.py:1721
↓ 3 callers
Function
_validate_port_spec
(hosts, port)
asyncpg/connect_utils.py:174
↓ 3 callers
Method
add_termination_listener
Add a listener that will be called when the connection is closed. :param callable callback: A callable or a coroutine function re
asyncpg/connection.py:204
↓ 3 callers
Function
connect
r"""A coroutine to establish a connection to a PostgreSQL server. The connection parameters may be specified either as a connection URI in *d
asyncpg/connection.py:2083
↓ 3 callers
Method
copy_from_table
Copy table contents to a file or file-like object. Pool performs this operation using one of its connections. Other than that, it be
asyncpg/pool.py:683
↓ 3 callers
Method
environ
(self, **kwargs)
tests/test_connect.py:1109
↓ 3 callers
Method
expire_connections
Expire all currently open connections. Cause all currently open connections to get replaced on the next :meth:`~asyncpg.pool.Pool.acq
asyncpg/pool.py:999
↓ 3 callers
Method
explain
Return the execution plan of the statement. :param args: Query arguments. :param analyze: If ``True``, the statement will be executed
asyncpg/prepared_stmt.py:126
↓ 3 callers
Method
get_parameters
Return a description of statement parameters types. :return: A tuple of :class:`asyncpg.types.Type`. Example:: stmt = a
asyncpg/prepared_stmt.py:62
↓ 3 callers
Method
get_statusmsg
Return the status of the executed command. Example:: stmt = await connection.prepare('CREATE TABLE mytab (a int)') a
asyncpg/prepared_stmt.py:48
↓ 3 callers
Method
is_connected
(self)
asyncpg/pool.py:141
↓ 3 callers
Function
platform_exe
(name)
asyncpg/cluster.py:30
↓ 3 callers
Method
query_logger
Context manager that adds `callback` to the list of query loggers, and removes it upon exit. :param callable callback: A
asyncpg/connection.py:1885
↓ 3 callers
Method
reload_schema_state
Indicate that the database schema information must be reloaded. For performance reasons, asyncpg caches certain aspects of the databa
asyncpg/connection.py:1816
↓ 3 callers
Method
remove_log_listener
Remove a listening callback for log messages. .. versionadded:: 0.12.0
asyncpg/connection.py:197
↓ 3 callers
Method
start
(self)
asyncpg/_testbase/fuzzer.py:57
↓ 3 callers
Method
stop
(self)
asyncpg/_testbase/fuzzer.py:65
↓ 3 callers
Method
tearDown
(self)
asyncpg/_testbase/__init__.py:119
↓ 2 callers
Method
__aiter__
(self)
tests/test_copy.py:472
↓ 2 callers
Method
__check_state
(self, opname)
asyncpg/transaction.py:167
↓ 2 callers
Method
__check_state_base
(self, opname)
asyncpg/transaction.py:153
↓ 2 callers
Method
__commit
(self)
asyncpg/transaction.py:175
↓ 2 callers
Method
__init__
(self, data_dir, *, pg_config_path=None)
asyncpg/cluster.py:78
↓ 2 callers
Method
__init__
(self, connection, query, state, args, record_class)
asyncpg/cursor.py:94
↓ 2 callers
Method
__rollback
(self)
asyncpg/transaction.py:194
↓ 2 callers
Method
_abort
(self)
asyncpg/connection.py:1573
↓ 2 callers
Function
_accept_read_only
Verify the server has not set default_transaction_read_only=True
asyncpg/connect_utils.py:1171
↓ 2 callers
Method
_acquire
(self, timeout)
asyncpg/pool.py:877
↓ 2 callers
Function
_add_class
(clsname, base, sqlstate, docstring)
tools/generate_exceptions.py:95
↓ 2 callers
Method
_add_custom_codec
(self, conn)
tests/test_introspection.py:56
↓ 2 callers
Method
_async__init__
(self)
asyncpg/pool.py:429
↓ 2 callers
Method
_check_listeners
(self, listeners, listener_type)
asyncpg/connection.py:1769
↓ 2 callers
Function
_check_record_class
(record_class)
asyncpg/connection.py:2746
↓ 2 callers
Method
_cleanup
(self)
asyncpg/connection.py:1579
↓ 2 callers
Method
_copy_out
(self, copy_stmt, output, timeout)
asyncpg/connection.py:1171
↓ 2 callers
Function
_create_ssl_connection
( # TODO: The return type is a specific combination of subclasses of # asyncio.protocols.Protocol that
asyncpg/connect_utils.py:956
↓ 2 callers
Method
_drop_global_statement_cache
(self)
asyncpg/connection.py:1795
↓ 2 callers
Method
_drop_local_type_cache
(self)
asyncpg/connection.py:1804
↓ 2 callers
Method
_executemany
( self, query, args, timeout, return_rows=False, record_class=
asyncpg/connection.py:1979
↓ 2 callers
Method
_fix_version
(self, filename)
setup.py:78
↓ 2 callers
Method
_format_copy_where
(self, where)
asyncpg/connection.py:1130
↓ 2 callers
Method
_get_connection_spec
(self)
asyncpg/cluster.py:309
↓ 2 callers
Function
_get_initdb_options
(initdb_options=None)
asyncpg/_testbase/__init__.py:229
↓ 2 callers
Function
_get_socket
(transport)
asyncpg/connect_utils.py:1293
↓ 2 callers
Method
_init
(self, timeout)
asyncpg/cursor.py:255
↓ 2 callers
Function
_init_cluster
(ClusterCls, cluster_kwargs, initdb_options=None)
asyncpg/_testbase/__init__.py:221
↓ 2 callers
Method
_init_env
(self)
asyncpg/cluster.py:448
↓ 2 callers
Method
_introspect_types
(self, typeoids, timeout)
asyncpg/connection.py:505
↓ 2 callers
Method
_make_constructor
(cls, fields, query=None)
asyncpg/exceptions/_base.py:100
↓ 2 callers
Method
_maybe_cleanup
(self)
asyncpg/connection.py:2610
↓ 2 callers
Function
_new_cert
(issuer=None, is_issuer=False, serial_number=None, **subject)
tests/certs/gen.py:12
↓ 2 callers
Function
_quote_ident
(ident)
asyncpg/utils.py:11
↓ 2 callers
Method
_read
(self, sock, n)
asyncpg/_testbase/fuzzer.py:212
↓ 2 callers
Method
_release
Release this connection holder.
asyncpg/pool.py:309
↓ 2 callers
Method
_release_on_close
(self)
asyncpg/pool.py:304
↓ 2 callers
Method
_run_connection_test
( self, connect, target_attribute, expected_port )
tests/test_connect.py:2296
↓ 2 callers
Method
_run_no_explicit_close_test
(self)
tests/test_connect.py:2245
↓ 2 callers
Method
_set_entry_timeout
(self, entry)
asyncpg/connection.py:2585
↓ 2 callers
Function
_set_nodelay
(sock)
asyncpg/connect_utils.py:1302
↓ 2 callers
Method
_set_proxy
(self, proxy)
asyncpg/connection.py:1761
↓ 2 callers
Method
_setup_inactive_callback
(self)
asyncpg/pool.py:276
↓ 2 callers
Method
_test_connection
(self, timeout=60)
asyncpg/cluster.py:508
↓ 2 callers
Method
_wait
(self, work)
asyncpg/_testbase/fuzzer.py:38
↓ 2 callers
Method
_write
(self, sock, data)
asyncpg/_testbase/fuzzer.py:234
↓ 2 callers
Function
_write_cert
(path, cert_key_pair, password=None)
tests/certs/gen.py:132
↓ 2 callers
Method
as_dict
(self)
asyncpg/exceptions/_base.py:156
↓ 2 callers
Method
destroy
(self)
asyncpg/cluster.py:302
↓ 2 callers
Method
execute
Execute an SQL command (or commands). This method can execute many SQL commands at once, when no arguments are provided. Exa
asyncpg/connection.py:314
↓ 2 callers
Method
fetch
Run a query and return the results as a list of :class:`Record`. :param str query: Query text. :param args: Q
asyncpg/connection.py:666
↓ 2 callers
Method
fetchval
Execute the statement and return a value in the first row. :param args: Query arguments. :param int column: Numeric index within the
asyncpg/prepared_stmt.py:181
↓ 2 callers
Method
fetchval
Run a query and return a value in the first row. Pool performs this operation using one of its connections. Other than that, it beha
asyncpg/pool.py:636
↓ 2 callers
Function
find_root
()
tests/test__sourcecode.py:13
↓ 2 callers
Method
get_message_class_for_sqlstate
(mcls, code)
asyncpg/exceptions/_base.py:74
↓ 2 callers
Method
get_server_settings
(cls)
asyncpg/_testbase/__init__.py:300
↓ 2 callers
Method
get_size
Return the current number of connections in this pool. .. versionadded:: 0.25.0
asyncpg/pool.py:485
↓ 2 callers
Method
is_managed
(self)
asyncpg/cluster.py:94
↓ 2 callers
Method
issubset
(self, other: Self)
asyncpg/types.py:156
↓ 2 callers
Method
listen
(self)
asyncpg/_testbase/fuzzer.py:108
↓ 2 callers
Function
mock_dev_null_home_dir
()
tests/test_connect.py:94
↓ 2 callers
Function
mock_no_home_dir
()
tests/test_connect.py:86
↓ 2 callers
Method
parse
(cls, sslmode)
asyncpg/connect_utils.py:45
↓ 2 callers
Method
setUp
(self)
asyncpg/_testbase/__init__.py:115
↓ 2 callers
Method
setUpClass
(cls)
asyncpg/_testbase/__init__.py:101
↓ 2 callers
Method
set_connect_args
r"""Set the new connection arguments for this pool. The new connection arguments will be used for all subsequent new connection attem
asyncpg/pool.py:513
↓ 2 callers
Method
set_max_lifetime
(self, new_lifetime)
asyncpg/connection.py:2524
↓ 2 callers
Method
set_max_size
(self, new_size)
asyncpg/connection.py:2516
↓ 2 callers
Method
tearDownClass
(cls)
asyncpg/_testbase/__init__.py:111
↓ 1 callers
Method
__anext__
(self)
tests/test_copy.py:475
↓ 1 callers
Method
__await__
(self)
asyncpg/pool.py:1032
↓ 1 callers
Method
__contains__
(self, item)
tests/test_codecs.py:856
↓ 1 callers
Method
_add_hba_entry
(self)
tests/test_connect.py:1847
↓ 1 callers
Method
_bind
(self, timeout)
asyncpg/cursor.py:133
↓ 1 callers
Method
_bind_exec
(self, n, timeout)
asyncpg/cursor.py:118
↓ 1 callers
Method
_call_termination_listeners
(self)
asyncpg/connection.py:1697
↓ 1 callers
Function
_can_use_connection
(connection, attr: SessionAttribute)
asyncpg/connect_utils.py:1200
↓ 1 callers
Method
_cancel
(self, waiter)
asyncpg/connection.py:1652
↓ 1 callers
Function
_cancel_and_wait
Cancel the *fut* future or task and wait until it completes.
asyncpg/_asyncio_compat.py:75
↓ 1 callers
Method
_cancel_current_command
(self, waiter)
asyncpg/connection.py:1681
← previous
next →
101–200 of 868, ranked by callers