sqlx_rxqlite/connection/
establish.rs

1use super::*;
2use rxqlite_client::RXQLiteClientBuilder;
3
4impl RXQLiteConnection {
5    pub async fn establish(
6        options: &RXQLiteConnectOptions,
7    ) -> Result<Self, sqlx_core::error::Error> {
8        let builder = RXQLiteClientBuilder::new(
9          options.node_id,
10          format!("{}:{}",options.node_host,options.node_port),
11          )
12          .tls_config(options.tls_config.clone());
13
14        Ok(Self { inner: builder.build() })
15    }
16}