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
Method
__anext__
(self)
asyncpg/connection.py:1246
Method
__anext__
(self)
asyncpg/cursor.py:223
Method
__await__
(self)
asyncpg/cursor.py:64
Method
__await__
(self)
asyncpg/pool.py:1070
Method
__bool__
(self)
asyncpg/types.py:167
Method
__call__
(self, record)
tests/test_logging.py:11
Method
__del__
(self)
asyncpg/connection.py:123
Method
__del__
(self)
asyncpg/prepared_stmt.py:284
Method
__del__
(self)
asyncpg/cursor.py:77
Method
__del__
(self)
asyncpg/cursor.py:188
Method
__enter__
(self)
asyncpg/connection.py:2647
Method
__eq__
(self, __value: object)
asyncpg/types.py:63
Method
__eq__
(self, other: object)
asyncpg/types.py:170
Method
__exit__
(self, t, e, tb)
asyncpg/connection.py:2653
Method
__fspath__
(self)
tests/test_copy.py:201
Method
__getattr__
(self, attr: str)
asyncpg/pool.py:91
Method
__gt__
(self, __other: Self, /)
asyncpg/types.py:69
Method
__hash__
(self)
asyncpg/types.py:188
Method
__init__
(self, path)
tests/test_copy.py:198
Method
__init__
(self)
tests/test_copy.py:469
Method
__init__
(self)
tests/test_record.py:539
Method
__init__
(self)
tests/test_logging.py:8
Method
__init__
(self, protocol, transport, loop, addr, config: connect_utils._ClientConfigu
asyncpg/connection.py:59
Method
__init__
(self, cache, query, statement)
asyncpg/connection.py:2473
Method
__init__
(self, *, loop, max_size, on_remove, max_lifetime)
asyncpg/connection.py:2485
Method
__init__
(self)
asyncpg/connection.py:2644
Method
__init__
( self, lower: _RV | None = None, upper: _RV | None = None, *, lower_i
asyncpg/types.py:87
Method
__init__
(self, connection, query, state)
asyncpg/prepared_stmt.py:21
Method
__init__
(self, *, data_dir_suffix=None, data_dir_prefix=None, data_dir_parent=None,
asyncpg/cluster.py:624
Method
__init__
(self, *, master, replication_user, data_dir_suffix=None, data_dir_prefix=No
asyncpg/cluster.py:634
Method
__init__
(self, **kwargs)
asyncpg/cluster.py:700
Method
__init__
(self, connection, isolation, readonly, deferrable)
asyncpg/transaction.py:47
Method
__init__
( self, connection, query, state, args, prefetch, time
asyncpg/cursor.py:30
Method
__init__
( self, connection, query, state, args, record_class,
asyncpg/cursor.py:198
Method
__init__
( self, loop: asyncio.AbstractEventLoop, host: str, port: int, ssl_con
asyncpg/connect_utils.py:912
Method
__init__
(self)
asyncpg/connect_utils.py:1260
Method
__init__
( self, holder: PoolConnectionHolder, con: connection.Connection )
asyncpg/pool.py:84
Method
__init__
( self, pool: "Pool", *, max_queries: float, setup: Optional[Callable[
asyncpg/pool.py:120
Method
__init__
(self, *connect_args, min_size, max_size, max_queries,
asyncpg/pool.py:348
Method
__init__
(self, pool: Pool, timeout: Optional[float])
asyncpg/pool.py:1047
Method
__init__
(self, connection)
asyncpg/connresource.py:28
Method
__init__
(self, *, detail=None, hint=None)
asyncpg/exceptions/_base.py:194
Method
__init__
(self, msg, *, detail=None, hint=None)
asyncpg/exceptions/_base.py:244
Method
__init__
(self, msg, *, schema=None, data_type=None, position=None)
asyncpg/exceptions/_base.py:264
Method
__init__
(self, *, listening_addr: str='127.0.0.1', listening_port: typing.Optional[int]=None,
asyncpg/_testbase/fuzzer.py:21
Method
__init__
(self, client_sock, backend_sock, proxy)
asyncpg/_testbase/fuzzer.py:154
Method
__instancecheck__
(cls, instance)
asyncpg/connection.py:38
Method
__iter__
(self)
tests/test_codecs.py:845
Method
__len__
(self)
tests/test_codecs.py:848
Method
__len__
(self)
asyncpg/connection.py:2510
Method
__lt__
(self, __other: Self, /)
asyncpg/types.py:66
Method
__new__
(cls)
tests/test_record.py:543
Method
__new__
( mcls, name: str, bases: tuple[Type[Any], ...], dct: dict[str, Any],
asyncpg/pool.py:30
Method
__new__
(mcls, name, bases, dct)
asyncpg/exceptions/_base.py:50
Method
__new__
(mcls, name, bases, ns)
asyncpg/_testbase/__init__.py:77
Method
__repr__
(self)
tests/test_record.py:136
Method
__repr__
(self)
asyncpg/types.py:197
Method
__repr__
(self)
asyncpg/transaction.py:229
Method
__repr__
(self)
asyncpg/cursor.py:172
Method
__repr__
(self)
asyncpg/pool.py:103
Method
__setattr__
(self, name, val)
asyncpg/exceptions/_base.py:277
Method
__str__
(self)
tests/test_record.py:133
Method
__str__
(self)
asyncpg/exceptions/_base.py:168
Method
__str__
(self)
asyncpg/exceptions/_base.py:198
Method
__str__
(self)
asyncpg/exceptions/_base.py:274
Function
_accept_any
(_)
asyncpg/connect_utils.py:1186
Method
_acquire_impl
()
asyncpg/pool.py:878
Method
_add_hba_entry
(self)
tests/test_connect.py:1853
Method
_add_hba_entry
(self)
tests/test_connect.py:2059
Method
_add_hba_entry
(self)
tests/test_connect.py:2152
Function
_cancel
(*, loop, addr, params: _ConnectionParameters, backend_pid, backend_secret)
asyncpg/connect_utils.py:1255
Method
_cancel
(self, waiter)
tests/test_pool.py:39
Function
_check
(self, *args, **kwargs)
asyncpg/connresource.py:18
Function
_connect
(*, loop, connection_class, record_class, **kwargs)
asyncpg/connect_utils.py:1205
Method
_deactivate_inactive_connection
(self)
asyncpg/pool.py:290
Method
_decoder
(value)
tests/test_codecs.py:1425
Method
_decoder
(value)
tests/test_copy.py:712
Method
_encoder
(value)
tests/test_codecs.py:1422
Method
_encoder
(value)
tests/test_copy.py:709
Method
_get_statement
(self, query, timeout, **kwargs)
tests/test_timeout.py:141
Method
_init_env
(self)
asyncpg/cluster.py:646
Method
_introspect_types
(self, *args, **kwargs)
tests/test_introspection.py:22
Function
_mogrify
Safely inline arguments to query text.
asyncpg/utils.py:19
Method
_on_entry_expired
(self, entry)
asyncpg/connection.py:2599
Method
_process_log_message
(self, fields, last_query)
asyncpg/connection.py:1684
Method
_process_notification
(self, pid, channel, payload)
asyncpg/connection.py:1710
Function
_quote_literal
(string)
asyncpg/utils.py:15
Function
_release_waiter
(waiter: asyncio.Future[typing.Any], *args: object)
asyncpg/_asyncio_compat.py:92
Method
_restore_connectivity
(self)
asyncpg/_testbase/fuzzer.py:136
Function
_shutdown_cluster
(cluster)
asyncpg/_testbase/__init__.py:262
Method
_start_thread
(self, started_event)
asyncpg/_testbase/fuzzer.py:72
Method
_stop
(self)
asyncpg/_testbase/fuzzer.py:69
Method
_trigger_connectivity_loss
(self)
asyncpg/_testbase/fuzzer.py:129
Method
_warn_on_long_close
(self)
asyncpg/pool.py:984
Function
_weak_maybe_gc_stmt
(weak_ref, stmt)
asyncpg/connection.py:2767
Method
_writer
(data)
asyncpg/connection.py:1200
Method
acquire
(self)
asyncpg/pool.py:158
Method
add_hba_entry
(self, *, type='host', database, user, address=None, auth_method, auth_options=None)
asyncpg/cluster.py:727
Method
async_close_cb
(con)
tests/test_listeners.py:329
Method
async_listener3
(*args)
tests/test_listeners.py:33
← previous
next →
301–400 of 868, ranked by callers