MCPcopy Create free account

hub / github.com/MagicStack/asyncpg / functions

Functions868 in github.com/MagicStack/asyncpg

Methodasync_notice_callb
(con, message)
tests/test_listeners.py:136
Methodbad_connect
(*args, **kwargs)
tests/test_pool.py:187
Methodbuild_module
(self, module, module_file, package)
setup.py:102
Methodcall_con_method
(self: Any, *args: Any, **kwargs: Any)
asyncpg/pool.py:61
Functioncan_be_used
(connection)
asyncpg/connect_utils.py:1157
Methodcheck
()
tests/test_connect.py:1667
Methodcheck_simple
()
tests/test_prepare.py:437
Methodclose
(self)
asyncpg/pool.py:264
Methodclose_cb
(con)
tests/test_listeners.py:325
Methodconnect_primary
(cls, **kwargs)
asyncpg/_testbase/__init__.py:533
Methodconnect_standby
(cls, **kwargs)
asyncpg/_testbase/__init__.py:538
Methodconnection_lost
(self, exc: typing.Optional[Exception])
asyncpg/connect_utils.py:944
Methodconnection_lost
(self, exc)
asyncpg/connect_utils.py:1264
Methodcopy_from_query
Copy the results of a query to a file or file-like object. :param str query: The query to copy the results of. :param ar
asyncpg/connection.py:878
Methodcopy_from_table
Copy table contents to a file or file-like object. :param str table_name: The name of the table to copy data from. :para
asyncpg/connection.py:806
Methodcopy_records_to_table
Copy a list of records to the specified table using binary COPY. :param str table_name: The name of the table to copy data to.
asyncpg/connection.py:1028
Methodcopy_to_table
Copy data to the specified table. :param str table_name: The name of the table to copy data to. :param source:
asyncpg/connection.py:940
Functioncreate_pool
r"""Create a connection pool. Can be used either with an ``async with`` block: .. code-block:: python async with asyncpg.create_poo
asyncpg/pool.py:1075
Methodcreate_pool
(self, pool_class=pg_pool.Pool, connection_class=pg_connection.Connection, **kwargs)
asyncpg/_testbase/__init__.py:374
Methodcursor
Return a *cursor factory* for the prepared statement. :param args: Query arguments. :param int prefetch: The number of rows the *curs
asyncpg/prepared_stmt.py:104
Methoddata_received
(self, data: bytes)
asyncpg/connect_utils.py:926
Methoddestroy
(self)
asyncpg/cluster.py:721
Methodexecutemany
Execute an SQL *command* for each sequence of arguments in *args*. Example: .. code-block:: pycon >>> await con.execute
asyncpg/connection.py:366
Methodexecutemany
Execute the statement for each sequence of arguments in *args*. :param args: An iterable containing sequences of arguments. :param fl
asyncpg/prepared_stmt.py:236
Methodfetch
r"""Execute the statement and return a list of :class:`Record` objects. :param str query: Query text :param args: Query arguments
asyncpg/prepared_stmt.py:168
Methodfetch
r"""Return the next *n* rows as a list of :class:`Record` objects. :param float timeout: Optional timeout value in seconds. :return:
asyncpg/cursor.py:269
Methodfetchmany
Run a query for each sequence of arguments in *args* and return the results as a list of :class:`Record`. :param query: Q
asyncpg/connection.py:763
Methodfetchmany
Execute the statement and return a list of :class:`Record` objects. :param args: Query arguments. :param float timeout: Optional time
asyncpg/prepared_stmt.py:215
Methodfetchrow
Run a query and return the first row. :param str query: Query text :param args: Query arguments :para
asyncpg/connection.py:723
Methodfetchrow
Execute the statement and return the first row. :param str query: Query text :param args: Query arguments :param float timeou
asyncpg/prepared_stmt.py:200
Methodfetchrow
r"""Return the next row. :param float timeout: Optional timeout value in seconds. :return: A :class:`Record` instance.
asyncpg/cursor.py:287
Methodfetchval
Run a query and return a value in the first row. :param str query: Query text. :param args: Query arguments. :param int colum
asyncpg/connection.py:702
Methodfinalize_options
(self)
setup.py:151
Functionflt
(log_record)
asyncpg/_testbase/__init__.py:32
Methodgen
()
tests/test_execute.py:239
Methodget_connection_spec
(self)
asyncpg/cluster.py:706
Methodget_connection_spec
(cls, kwargs)
asyncpg/_testbase/__init__.py:415
Methodget_connection_spec
(cls, kwargs={})
asyncpg/_testbase/__init__.py:517
Methodget_correctpassword
()
tests/test_connect.py:270
Methodget_data_dir
(self)
asyncpg/cluster.py:97
Methodget_max_size
(self)
asyncpg/connection.py:2513
Functionget_pg_home_directory
()
asyncpg/compat.py:26
Methodget_proxy_settings
(cls)
asyncpg/_testbase/__init__.py:391
Methodget_server_settings
(cls)
tests/test_connect.py:1798
Methodget_server_settings
(cls)
tests/test_introspection.py:47
Methodget_server_settings
(cls)
asyncpg/_testbase/__init__.py:385
Methodget_status
(self)
asyncpg/cluster.py:709
Methodget_wrongpassword
()
tests/test_connect.py:273
Methodget_xact_id
(con)
tests/test_pool.py:522
Functionguarded
A decorator to add a sanity check to ConnectionResource methods.
asyncpg/connresource.py:14
Methodhandler
(loop, ctx)
asyncpg/_testbase/__init__.py:159
Methodhstore_decoder
(data)
tests/test_codecs.py:1192
Methodhstore_encoder
(obj)
tests/test_codecs.py:1201
Methodinit
(con)
tests/test_pool.py:155
Methodinit
Initialize cluster.
asyncpg/cluster.py:650
Methodinit
(self, **settings)
asyncpg/cluster.py:712
Methodinitialize_options
(self)
setup.py:122
Functionis_composite_type
(typeinfo: protocol.Record)
asyncpg/introspection.py:295
Functionis_domain_type
(typeinfo: protocol.Record)
asyncpg/introspection.py:291
Methodis_managed
(self)
asyncpg/cluster.py:703
Functionis_scalar_type
(typeinfo: protocol.Record)
asyncpg/introspection.py:284
Methodisempty
(self)
asyncpg/types.py:131
Methodkill_connectivity
()
tests/test_adversity.py:73
Methodlistener1
(*args)
tests/test_listeners.py:27
Methodlistener1
(*args)
tests/test_listeners.py:308
Methodlistener2
(*args)
tests/test_listeners.py:30
Methodlocker
()
tests/test_execute.py:275
Methodloop_exception_handler
(self, loop, context)
asyncpg/_testbase/__init__.py:179
Methodlower_inc
(self)
asyncpg/types.py:111
Methodlower_inf
(self)
asyncpg/types.py:115
Methodmake_release_tree
(self, base_dir, files)
setup.py:95
Functionmarkcoroutinefunction
(c)
asyncpg/compat.py:57
Methodnew
(cls, fields, query=None)
asyncpg/exceptions/_base.py:282
Methodnotice_callb
(con, message)
tests/test_listeners.py:130
Methodquery_saver
(record)
tests/test_logging.py:20
Methodraise_message
(level, code)
tests/test_listeners.py:274
Methodraise_notice
()
tests/test_listeners.py:142
Methodraise_warning
()
tests/test_listeners.py:149
Methodrecord_generator
()
tests/test_copy.py:688
Methodrelease
(self, timeout: Optional[float])
asyncpg/pool.py:195
Methodremove_termination_listener
Remove a listening callback for connection termination. :param callable callback: The callable or coroutine function that was pas
asyncpg/connection.py:218
Methodreset
(self, *, timeout=None)
tests/test_pool.py:32
Methodreset_hba
(self)
asyncpg/cluster.py:724
Methodrun_in_subinterpreter
()
tests/test_subinterpreters.py:19
MethodsetUp
(self)
tests/test_connect.py:146
MethodsetUp
(self)
tests/test_execute.py:103
MethodsetUp
(self)
tests/test_introspection.py:52
MethodsetUp
(self)
asyncpg/_testbase/__init__.py:364
MethodsetUp
(self)
asyncpg/_testbase/__init__.py:439
MethodsetUpClass
(cls)
tests/test_connect.py:459
MethodsetUpClass
(cls)
tests/test_introspection.py:30
MethodsetUpClass
(cls)
asyncpg/_testbase/__init__.py:332
MethodsetUpClass
(cls)
asyncpg/_testbase/__init__.py:395
Methodsetup_cluster
(cls)
tests/test_codecs.py:1984
Methodsetup_cluster
(cls)
tests/test_pool.py:1012
Methodsetup_cluster
(cls)
tests/test_connect.py:430
Methodsetup_cluster
(cls)
tests/test_connect.py:1813
Methodsetup_cluster
(cls)
asyncpg/_testbase/__init__.py:459
Functionsilence_asyncio_long_exec_warning
()
asyncpg/_testbase/__init__.py:31
Methodsleep_and_release
()
tests/test_pool.py:479
← previousnext →401–500 of 868, ranked by callers