1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

use super::*;
use rxqlite_client::RXQLiteClientBuilder;

impl RXQLiteConnection {
    pub async fn establish(
        options: &RXQLiteConnectOptions,
    ) -> Result<Self, sqlx_core::error::Error> {
        let builder = RXQLiteClientBuilder::new(
          options.node_id,
          format!("{}:{}",options.node_host,options.node_port),
          )
          .tls_config(options.tls_config.clone());

        Ok(Self { inner: builder.build() })
    }
}