pub async fn connect_replication(conn: &str) -> Result<Client, anyhow::Error> {
    let mut config: Config = conn.parse()?;
    let tls = make_tls(&config)?;
    let (client, conn) = config
        .replication_mode(ReplicationMode::Logical)
        .connect(tls)
        .await?;
    tokio::spawn(conn);
    Ok(client)
}
/// Starts a replication connection to the upstream database
Starts a replication connection to the upstream database
Starts a replication connection to the upstream database
pub async fn connect_replication(conn: &str) -> Result<Client, anyhow::Error> {
    let mut config: Config = conn.parse()?;
    let tls = make_tls(&config)?;
    let (client, conn) = config
        .replication_mode(ReplicationMode::Logical)
        .connect(tls)
        .await?;
    tokio::spawn(conn);
    Ok(client)
}
pub async fn connect_replication ( conn : & str ) -> Result < Client , anyhow :: Error > { let mut config : Config = conn . parse ( ) ? ; let tls = make_tls ( & config ) ? ; let ( client , conn ) = config . replication_mode ( ReplicationMode :: Logical ) . connect ( tls ) . await ? ; tokio :: spawn ( conn ) ; Ok ( client ) }
Starts a replication connection to the upstream database
Starts a replication connection to the upstream database
conn
&str
conn
&str