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. Candidate endpoints are tried in order; a standby transactor rejects the subscription and the next candidate is tried.

Errors

Returns PeerError when no endpoint accepts the subscription.

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.

Failures that are provably pre-commit — a standby or deposed transactor rejecting the request, or a connection that could not be established — are retried until ConnectConfig::failover_timeout, riding out an HA takeover. A connection that dies with the request in flight is ambiguous (the transaction may or may not have committed) and surfaces as an error, exactly like a transactor crash between durability and reply; callers decide whether to check and resubmit.

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.