Struct TransactorNode 

pub struct TransactorNode { /* private fields */ }

A running transactor node hosting every database under one data directory.

Implementations

impl TransactorNode

pub async fn open(config: NodeConfig) -> Result<Arc<Self>, NodeError>

Opens a node over config.data_dir, recovering every database found there (acquiring its lease, waiting out held leases up to the configured bound).

Errors

Returns an error when the store cannot be opened or a database cannot be recovered.

pub fn store(&self) -> &Arc<FsStore>

The node’s data-directory store.

pub fn config(&self) -> &NodeConfig

Node configuration.

pub const fn metrics(&self) -> &Metrics

Process observability counters.

pub fn shutdown_watch(&self) -> Receiver<Option<String>>

Watch channel that reports a shutdown reason when the node deposes.

pub async fn db_state(&self, name: &str) -> Result<Arc<DbState>, NodeError>

Looks up a hosted database.

Errors

Returns NodeError::Standby when this HA node is standing by for the database, NodeError::UnknownDb when absent.

pub fn standby_dbs(&self) -> Vec<String>

Databases this node currently stands by for (HA mode).

pub async fn create_db( self: &Arc<Self>, name: &str, schema_edn: &[u8], ) -> Result<bool, NodeError>

Creates a database with the supplied EDN schema forms; returns false when it already exists.

Errors

Returns an error for invalid names/schema or store failures.

pub async fn delete_db(&self, name: &str) -> Result<bool, NodeError>

Deletes a database: unhosts it, releases its lease, and removes its roots and log. Blobs remain until Self::gc_deleted.

Errors

Returns an error when roots or the log cannot be removed.

pub fn list_dbs(&self) -> Vec<String>

Lists hosted databases.

pub async fn gc_deleted(&self) -> Result<u64, NodeError>

Sweeps blobs unreachable from any live database root (including everything left behind by deleted databases and superseded indexes).

Errors

Returns an error when the store cannot be enumerated or swept.

pub async fn gc_deleted_with_retention( &self, retention: Duration, ) -> Result<u64, NodeError>

Sweeps unreachable blobs older than the caller-supplied retention.

Errors

Returns an error when the store cannot be enumerated or swept.

pub async fn transact( &self, name: &str, tx_data: &[u8], ) -> Result<TransactResponse, NodeError>

Validates, appends, applies, and reports one transaction supplied as composite-encoded EDN transaction forms.

Errors

Returns NodeError for decode/validation failures, lease loss, or storage failures.

pub async fn status(&self, name: &str) -> Result<StatusResponse, NodeError>

Current status for a database.

Errors

Returns NodeError::UnknownDb when absent.

pub async fn release_leases(&self)

Releases every held write lease (graceful shutdown): the record is expired in place so a standby’s next poll takes over immediately instead of waiting out the TTL. Hosted databases stop accepting work first, so nothing commits after its lease is gone.

pub async fn sync(&self, name: &str, t: u64) -> Result<u64, NodeError>

Waits until the database basis reaches t, returning the basis seen.

Errors

Returns NodeError::UnknownDb when absent.