Struct CorrosionClient 

pub struct CorrosionClient { /* private fields */ }

Implementations

impl CorrosionClient

pub fn new<P: AsRef<Path>>(api_addr: SocketAddr, db_path: P) -> Self

pub fn with_sqlite_pool(api_addr: SocketAddr, pool: RusqlitePool) -> Self

pub fn pool(&self) -> &RusqlitePool

Methods from Deref<Target = CorrosionApiClient>

pub async fn query_typed<T: DeserializeOwned + Unpin>( &self, statement: &Statement, timeout: Option<u64>, ) -> Result<QueryStream<T>, Error>

pub async fn query( &self, statement: &Statement, timeout: Option<u64>, ) -> Result<QueryStream<Vec<SqliteValue>>, Error>

pub async fn subscribe_typed<T: DeserializeOwned + Unpin>( &self, statement: &Statement, skip_rows: bool, from: Option<ChangeId>, ) -> Result<SubscriptionStream<T>, Error>

pub async fn subscribe( &self, statement: &Statement, skip_rows: bool, from: Option<ChangeId>, ) -> Result<SubscriptionStream<Vec<SqliteValue>>, Error>

pub async fn subscription_typed<T: DeserializeOwned + Unpin>( &self, id: Uuid, skip_rows: bool, from: Option<ChangeId>, ) -> Result<SubscriptionStream<T>, Error>

pub async fn subscription( &self, id: Uuid, skip_rows: bool, from: Option<ChangeId>, ) -> Result<SubscriptionStream<Vec<SqliteValue>>, Error>

pub async fn updates_typed<T: DeserializeOwned + Unpin>( &self, table: &str, ) -> Result<UpdatesStream<T>, Error>

pub async fn updates( &self, table: &str, ) -> Result<UpdatesStream<Vec<SqliteValue>>, Error>

pub async fn execute( &self, statements: &[Statement], timeout: Option<u64>, ) -> Result<ExecResponse, Error>

pub async fn schema( &self, statements: &[Statement], ) -> Result<ExecResponse, Error>

pub async fn schema_from_paths<P: AsRef<Path>>( &self, schema_paths: &[P], ) -> Result<Option<ExecResponse>, Error>

Trait Implementations

impl Clone for CorrosionClient

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Deref for CorrosionClient

type Target = CorrosionApiClient

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.