Struct Connection 

pub struct Connection { /* private fields */ }

A live peer connection to a transactor-hosted database.

Implementations

impl Connection

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

Connects, subscribes from basis 0, and waits until the handshake and its backfill have been applied locally.

Errors

Returns PeerError when the endpoint is unreachable or the subscription cannot be established.

pub fn db_name(&self) -> &str

The connected database name.

pub fn db(&self) -> Db

Returns the current local database value without blocking on the transactor.

Panics

Panics if called before the initial handshake (impossible through Connection::connect).

pub fn basis_t(&self) -> u64

Basis of the newest locally applied transaction.

pub fn index_basis_t(&self) -> u64

Basis of the newest published durable index announced by the transactor.

pub fn tx_reports(&self) -> Receiver<PeerReport>

Subscribes to reports applied after this call.

pub fn tx_range(&self, start: u64, end: Option<u64>) -> Vec<TxRecord>

Transaction instants recorded locally for [start, end), paired with their datoms (the peer-side tx-range).

pub async fn transact(&self, forms: Vec<Edn>) -> Result<TxResult, PeerError>

Submits a transaction (EDN transaction forms) and waits until it is applied locally, so a following Connection::db observes it.

Errors

Returns PeerError for rejected transactions or transport failure.

pub async fn transact_raw( &self, tx_data: Vec<u8>, ) -> Result<TransactResponse, PeerError>

Submits already-encoded transaction data, returning the raw wire response (used by the peer server’s transact proxy).

Errors

Returns PeerError for rejected transactions or transport failure.

pub async fn sync(&self) -> Result<Db, PeerError>

Waits until the local basis reaches the transactor’s current basis.

Errors

Returns PeerError on transport failure.

pub async fn sync_to(&self, t: u64) -> Result<Db, PeerError>

Waits until the local basis reaches t, returning the database value.

Errors

Returns PeerError::Closed if the connection task stops.

pub async fn status(&self) -> Result<StatusResponse, PeerError>

Transactor-side status for the connected database.

Errors

Returns PeerError on transport failure.

pub async fn subscribe_raw( &self, from_basis_t: u64, ) -> Result<Streaming<SubscribeItem>, PeerError>

Opens an independent upstream subscription (used by the peer server to relay tx-report streams to thin clients).

Errors

Returns PeerError on transport failure.

Trait Implementations

impl Drop for Connection

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.