Struct CorrosionApiClient

pub struct CorrosionApiClient { /* private fields */ }

Implementations

impl CorrosionApiClient

pub fn new(api_addr: SocketAddr) -> Self

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 CorrosionApiClient

fn clone(&self) -> CorrosionApiClient

Returns a copy of the value.

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

Performs copy-assignment from source.