Struct LocalPeer 

pub struct LocalPeer { /* private fields */ }

A fluent client backed by the in-process peer library.

Implementations

impl LocalPeer

pub async fn connect(config: ConnectConfig) -> Result<Self, ClientError>

Connects a peer to a transactor and wraps it in the fluent API.

Errors

Returns ClientError when no endpoint accepts the subscription.

pub fn from_connection(connection: Arc<Connection>) -> Self

Wraps an already-established peer connection.

pub fn connection(&self) -> &Arc<Connection>

The underlying peer connection, for peer-library operations the fluent API does not surface (tx-report streaming, index policy, and so on).

Trait Implementations

impl Peer for LocalPeer

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.