Struct mz_postgres_util::tunnel::Config

pub struct Config {
    inner: Config,
    tunnel: TunnelConfig,
    in_task: InTask,
    ssh_timeout_config: SshTimeoutConfig,
}

Configuration for PostgreSQL connections.

This wraps tokio_postgres::Config to allow the configuration of a tunnel via a TunnelConfig.

Fields

inner: Config

tunnel: TunnelConfig

in_task: InTask

ssh_timeout_config: SshTimeoutConfig

Implementations

impl Config

pub fn new( inner: Config, tunnel: TunnelConfig, ssh_timeout_config: SshTimeoutConfig, in_task: InTask, ) -> Result<Self, PostgresError>

pub async fn connect( &self, task_name: &str, ssh_tunnel_manager: &SshTunnelManager, ) -> Result<Client, PostgresError>

Connects to the configured PostgreSQL database.

pub async fn connect_replication( &self, ssh_tunnel_manager: &SshTunnelManager, ) -> Result<Client, PostgresError>

Starts a replication connection to the configured PostgreSQL database.

fn address(&self) -> Result<(&str, u16), PostgresError>

async fn connect_traced<F>( &self, task_name: &str, configure: F, ssh_tunnel_manager: &SshTunnelManager, ) -> Result<Client, PostgresError>

where F: FnOnce(&mut Config),

async fn connect_internal<F>( &self, task_name: &str, configure: F, ssh_tunnel_manager: &SshTunnelManager, ) -> Result<Client, PostgresError>

where F: FnOnce(&mut Config),

pub fn get_user(&self) -> Option<&str>

pub fn get_dbname(&self) -> Option<&str>

Trait Implementations

impl Clone for Config

fn clone(&self) -> Config

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Config

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.