Close Connector by stopping tasks and releasing resources.

A helper function to generate the private and public keys. backend - The value specified is default_backend(). This is because the cryptograp

Connect asynchronously to a Cloud SQL instance. Prepares and returns a database connection object connected to a Cloud SQL instance u

Helper function to cancel the cache's tasks and close aiohttp.ClientSession.

Connect to a Cloud SQL instance. Prepares and returns a database connection object connected to a Cloud SQL instance using SSL/TLS. S

Schedule task to sleep and then perform refresh to get ConnectionInfo. Args: delay (int): Time in seconds to sleep befor

Close CloudSQLClient gracefully.

Requests metadata from the Cloud SQL Instance and returns a dictionary containing the IP addresses and certificate authority of the Cloud SQL

Creates a connection pool for a Cloud SQL instance and returns the pool and the connector. Callers are responsible for closing the pool and the

Waits for a token to become available, if necessary, then subtracts token and allows request to go through.

Retrieves ConnectionInfo instance for establishing a secure connection to the Cloud SQL instance.

Returns the first IP address for the instance, according to the preference supplied by ip_type. If no IP addressess with the given preference

Retry any 50x HTTP response up to X number of times.

Asynchronously requests an ephemeral certificate from the Cloud SQL Instance. Args: project (str): A string representing the nam

Calculates the duration to wait before starting the next refresh. Usually the duration will be half of the time until certificate expira

Creates a connection pool for a Cloud SQL instance and returns the pool and the connector. Callers are responsible for closing the pool and the

Get the instance connection string for the Cloud SQL instance.

Convert IP type from a str into IPTypes.

Retrieves instance metadata and ephemeral certificate from the Cloud SQL Instance. Returns: A ConnectionInfo instance con

Remove closed sockets from monitored cache. If a socket is closed by the database driver we should remove it from list of sockets.

Helper function to create a pytds DB-API connection object. Args: ip_address (str): A string containing an IP address for the Cloud SQL

Creates a connection pool for a Cloud SQL instance and returns the pool and the connector. Callers are responsible for closing the pool and the

Creates a connection pool for a Cloud SQL instance and returns the pool and the connector. Callers are responsible for closing the pool and the

Constructs a SSL/TLS context for the given connection info. Cache the SSL context to ensure we don't read from disk repeatedly when c

Helper function to write the serverCaCert, ephemeral certificate and private key to .pem files in a given directory

Generate a down-scoped credential. Args: credentials (google.auth.credentials.Credentials): Credentials object used to genera

Calculates a duration to backoff in milliseconds based on the attempt i. The formula is: base * multi^(attempt + 1 + random) With base

Calculates how much time has passed since the last leak and removes the appropriate amount of events from the queue. Leaking

Create a PEM encoded certificate that is signed by given public key.

Close is a no-op and provided purely for a consistent interface with other cache types.

Creates a native asyncpg connection pool for a Cloud SQL instance and returns the pool and the connector. Callers are responsible for closing the

Creates a connection pool for a Cloud SQL instance and returns the pool and the connector. Callers are responsible for closing the pool and the

Creates a connection pool for a Cloud SQL instance and returns the pool and the connector. Callers are responsible for closing the pool and the

Creates a connection pool for a Cloud SQL instance and returns the pool and the connector. Callers are responsible for closing the pool and the

Invalidates the cache and configures the next call to connect_info() to retrieve a fresh ConnectionInfo instance.

Immediately performs a full refresh operation using the Cloud SQL Admin API. Args: conn_name (ConnectionName): The Cloud

Refreshes the access token.

Stops all background refreshes and deletes the connection info cache from the map of caches.

Wait until enough time has elapsed to add another token.

Cleanup function to make sure tasks have finished to have a graceful exit.

Helper function to create a pg8000 DB-API connection object. Args: ip_address (str): A string containing an IP address for the Cloud SQL

Helper function to create an asyncpg DB-API connection object. Args: ip_address (str): A string containing an IP address for the Cloud SQ

Initializes the connector and engine if necessary, then returns a connection.

Initializes the connector and IAM engine if necessary, then returns a connection.

Initializes the connector and IAM engine if necessary, then returns a connection.

Initializes the connector and password engine if necessary, then returns a connection.

Initializes the connector and password engine if necessary, then returns a connection.

Helper function to create Connector object for asyncio connections. Force use of Connector in an asyncio context. Auto-detect and use current

Helper method to build an ssl.SSLContext for tests

Format database `user` param for Cloud SQL automatic IAM authentication. Args: database_version (str): Cloud SQL database version.

Generate a private key and cert object to be used in testing.

Run local proxy server capable of performing mTLS

Ticker function to sleep for specified interval and then schedule call to given function.

Validate that the given driver is compatible with the given engine. Args: driver (str): Database driver being used. (i.e. "pg8000

Enter async context manager by returning Connector object

Exit async context manager by closing Connector

Enter context manager by returning Connector object

Exit context manager by closing Connector

Establishes the client to be used for Cloud SQL Admin API requests. Args: sqladmin_api_endpoint (str): Base URL to use when calli

Initializes a LazyRefreshCache instance. Args: conn_name (ConnectionName): The Cloud SQL instance's connection na

Initializes a Connector instance. Args: ip_type (str | IPTypes): The default IP address type used to connect to C

Initializes a RefreshAheadCache instance. Args: conn_name (ConnectionName): The Cloud SQL instance's connection n

Convert refresh strategy from a str into RefreshStrategy.

A coroutine that sleeps for the specified amount of time before running _perform_refresh.

Just run the default tools to install requirements.