Struct CorrosionApiClient 

pub struct CorrosionApiClient { /* private fields */ }

Implementations

impl CorrosionApiClient

pub fn new(api_addr: SocketAddr) -> Self

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 CorrosionApiClient

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.