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 pool(&self) -> &Pool<RusqliteConnManager>

Methods from Deref<Target = CorrosionApiClient>

pub async fn query(&self, statement: &Statement) -> Result<Body, Error>

pub async fn watch( &self, statement: &Statement, ) -> Result<(Uuid, impl Stream<Item = Result<QueryEvent>>), Error>

pub async fn watched_query( &self, id: Uuid, ) -> Result<impl Stream<Item = Result<QueryEvent>>, Error>

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

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

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

Trait Implementations

impl Clone for CorrosionClient

fn clone(&self) -> CorrosionClient

Returns a copy 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.