MCPcopy Create free account

hub / github.com/MagicStack/asyncpg / functions

Functions868 in github.com/MagicStack/asyncpg

↓ 3 callersMethod_reset
(self)
asyncpg/connection.py:1527
↓ 3 callersMethod_time_and_log
(self, query, args, timeout)
asyncpg/connection.py:1915
↓ 3 callersMethod_unwrap
(self)
asyncpg/connection.py:1721
↓ 3 callersFunction_validate_port_spec
(hosts, port)
asyncpg/connect_utils.py:174
↓ 3 callersMethodadd_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 callersFunctionconnect
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 callersMethodcopy_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 callersMethodenviron
(self, **kwargs)
tests/test_connect.py:1109
↓ 3 callersMethodexpire_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 callersMethodexplain
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 callersMethodget_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 callersMethodget_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 callersMethodis_connected
(self)
asyncpg/pool.py:141
↓ 3 callersFunctionplatform_exe
(name)
asyncpg/cluster.py:30
↓ 3 callersMethodquery_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 callersMethodreload_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 callersMethodremove_log_listener
Remove a listening callback for log messages. .. versionadded:: 0.12.0
asyncpg/connection.py:197
↓ 3 callersMethodstart
(self)
asyncpg/_testbase/fuzzer.py:57
↓ 3 callersMethodstop
(self)
asyncpg/_testbase/fuzzer.py:65
↓ 3 callersMethodtearDown
(self)
asyncpg/_testbase/__init__.py:119
↓ 2 callersMethod__aiter__
(self)
tests/test_copy.py:472
↓ 2 callersMethod__check_state
(self, opname)
asyncpg/transaction.py:167
↓ 2 callersMethod__check_state_base
(self, opname)
asyncpg/transaction.py:153
↓ 2 callersMethod__commit
(self)
asyncpg/transaction.py:175
↓ 2 callersMethod__init__
(self, data_dir, *, pg_config_path=None)
asyncpg/cluster.py:78
↓ 2 callersMethod__init__
(self, connection, query, state, args, record_class)
asyncpg/cursor.py:94
↓ 2 callersMethod__rollback
(self)
asyncpg/transaction.py:194
↓ 2 callersMethod_abort
(self)
asyncpg/connection.py:1573
↓ 2 callersFunction_accept_read_only
Verify the server has not set default_transaction_read_only=True
asyncpg/connect_utils.py:1171
↓ 2 callersMethod_acquire
(self, timeout)
asyncpg/pool.py:877
↓ 2 callersFunction_add_class
(clsname, base, sqlstate, docstring)
tools/generate_exceptions.py:95
↓ 2 callersMethod_add_custom_codec
(self, conn)
tests/test_introspection.py:56
↓ 2 callersMethod_async__init__
(self)
asyncpg/pool.py:429
↓ 2 callersMethod_check_listeners
(self, listeners, listener_type)
asyncpg/connection.py:1769
↓ 2 callersFunction_check_record_class
(record_class)
asyncpg/connection.py:2746
↓ 2 callersMethod_cleanup
(self)
asyncpg/connection.py:1579
↓ 2 callersMethod_copy_out
(self, copy_stmt, output, timeout)
asyncpg/connection.py:1171
↓ 2 callersFunction_create_ssl_connection
( # TODO: The return type is a specific combination of subclasses of # asyncio.protocols.Protocol that
asyncpg/connect_utils.py:956
↓ 2 callersMethod_drop_global_statement_cache
(self)
asyncpg/connection.py:1795
↓ 2 callersMethod_drop_local_type_cache
(self)
asyncpg/connection.py:1804
↓ 2 callersMethod_executemany
( self, query, args, timeout, return_rows=False, record_class=
asyncpg/connection.py:1979
↓ 2 callersMethod_fix_version
(self, filename)
setup.py:78
↓ 2 callersMethod_format_copy_where
(self, where)
asyncpg/connection.py:1130
↓ 2 callersMethod_get_connection_spec
(self)
asyncpg/cluster.py:309
↓ 2 callersFunction_get_initdb_options
(initdb_options=None)
asyncpg/_testbase/__init__.py:229
↓ 2 callersFunction_get_socket
(transport)
asyncpg/connect_utils.py:1293
↓ 2 callersMethod_init
(self, timeout)
asyncpg/cursor.py:255
↓ 2 callersFunction_init_cluster
(ClusterCls, cluster_kwargs, initdb_options=None)
asyncpg/_testbase/__init__.py:221
↓ 2 callersMethod_init_env
(self)
asyncpg/cluster.py:448
↓ 2 callersMethod_introspect_types
(self, typeoids, timeout)
asyncpg/connection.py:505
↓ 2 callersMethod_make_constructor
(cls, fields, query=None)
asyncpg/exceptions/_base.py:100
↓ 2 callersMethod_maybe_cleanup
(self)
asyncpg/connection.py:2610
↓ 2 callersFunction_new_cert
(issuer=None, is_issuer=False, serial_number=None, **subject)
tests/certs/gen.py:12
↓ 2 callersFunction_quote_ident
(ident)
asyncpg/utils.py:11
↓ 2 callersMethod_read
(self, sock, n)
asyncpg/_testbase/fuzzer.py:212
↓ 2 callersMethod_release
Release this connection holder.
asyncpg/pool.py:309
↓ 2 callersMethod_release_on_close
(self)
asyncpg/pool.py:304
↓ 2 callersMethod_run_connection_test
( self, connect, target_attribute, expected_port )
tests/test_connect.py:2296
↓ 2 callersMethod_run_no_explicit_close_test
(self)
tests/test_connect.py:2245
↓ 2 callersMethod_set_entry_timeout
(self, entry)
asyncpg/connection.py:2585
↓ 2 callersFunction_set_nodelay
(sock)
asyncpg/connect_utils.py:1302
↓ 2 callersMethod_set_proxy
(self, proxy)
asyncpg/connection.py:1761
↓ 2 callersMethod_setup_inactive_callback
(self)
asyncpg/pool.py:276
↓ 2 callersMethod_test_connection
(self, timeout=60)
asyncpg/cluster.py:508
↓ 2 callersMethod_wait
(self, work)
asyncpg/_testbase/fuzzer.py:38
↓ 2 callersMethod_write
(self, sock, data)
asyncpg/_testbase/fuzzer.py:234
↓ 2 callersFunction_write_cert
(path, cert_key_pair, password=None)
tests/certs/gen.py:132
↓ 2 callersMethodas_dict
(self)
asyncpg/exceptions/_base.py:156
↓ 2 callersMethoddestroy
(self)
asyncpg/cluster.py:302
↓ 2 callersMethodexecute
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 callersMethodfetch
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 callersMethodfetchval
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 callersMethodfetchval
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 callersFunctionfind_root
()
tests/test__sourcecode.py:13
↓ 2 callersMethodget_message_class_for_sqlstate
(mcls, code)
asyncpg/exceptions/_base.py:74
↓ 2 callersMethodget_server_settings
(cls)
asyncpg/_testbase/__init__.py:300
↓ 2 callersMethodget_size
Return the current number of connections in this pool. .. versionadded:: 0.25.0
asyncpg/pool.py:485
↓ 2 callersMethodis_managed
(self)
asyncpg/cluster.py:94
↓ 2 callersMethodissubset
(self, other: Self)
asyncpg/types.py:156
↓ 2 callersMethodlisten
(self)
asyncpg/_testbase/fuzzer.py:108
↓ 2 callersFunctionmock_dev_null_home_dir
()
tests/test_connect.py:94
↓ 2 callersFunctionmock_no_home_dir
()
tests/test_connect.py:86
↓ 2 callersMethodparse
(cls, sslmode)
asyncpg/connect_utils.py:45
↓ 2 callersMethodsetUp
(self)
asyncpg/_testbase/__init__.py:115
↓ 2 callersMethodsetUpClass
(cls)
asyncpg/_testbase/__init__.py:101
↓ 2 callersMethodset_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 callersMethodset_max_lifetime
(self, new_lifetime)
asyncpg/connection.py:2524
↓ 2 callersMethodset_max_size
(self, new_size)
asyncpg/connection.py:2516
↓ 2 callersMethodtearDownClass
(cls)
asyncpg/_testbase/__init__.py:111
↓ 1 callersMethod__anext__
(self)
tests/test_copy.py:475
↓ 1 callersMethod__await__
(self)
asyncpg/pool.py:1032
↓ 1 callersMethod__contains__
(self, item)
tests/test_codecs.py:856
↓ 1 callersMethod_add_hba_entry
(self)
tests/test_connect.py:1847
↓ 1 callersMethod_bind
(self, timeout)
asyncpg/cursor.py:133
↓ 1 callersMethod_bind_exec
(self, n, timeout)
asyncpg/cursor.py:118
↓ 1 callersMethod_call_termination_listeners
(self)
asyncpg/connection.py:1697
↓ 1 callersFunction_can_use_connection
(connection, attr: SessionAttribute)
asyncpg/connect_utils.py:1200
↓ 1 callersMethod_cancel
(self, waiter)
asyncpg/connection.py:1652
↓ 1 callersFunction_cancel_and_wait
Cancel the *fut* future or task and wait until it completes.
asyncpg/_asyncio_compat.py:75
↓ 1 callersMethod_cancel_current_command
(self, waiter)
asyncpg/connection.py:1681
← previousnext →101–200 of 868, ranked by callers