Struct RemotePeer 

pub struct RemotePeer { /* private fields */ }

A fluent client backed by a remote peer server over gRPC.

Implementations

impl RemotePeer

pub async fn connect( endpoint: impl Into<String>, db: impl Into<String>, token: Option<String>, tls: Option<ClientTlsConfig>, ) -> Result<Self, ClientError>

Connects to a peer server hosting db.

Errors

Returns ClientError when the endpoint is unreachable.

Trait Implementations

impl Peer for RemotePeer

fn db_name(&self) -> &str

The connected database name.

fn db<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Db, ClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

The current database value.

fn transact<'life0, 'async_trait>( &'life0 self, tx: TxData, ) -> Pin<Box<dyn Future<Output = Result<TxReport, ClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Submits a transaction and waits until it is applied, returning a report whose db_after observes it.

fn sync<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Db, ClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Waits until the local view reaches the transactor’s current basis and returns the resulting database value.