Struct TransactorNode 

pub struct TransactorNode { /* private fields */ }

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

Implementations

impl TransactorNode

pub 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 fn db_state(&self, name: &str) -> Result<Arc<DbState>, NodeError>

Looks up a hosted database.

Errors

Returns NodeError::UnknownDb when absent.

pub 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 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 fn status(&self, name: &str) -> Result<StatusResponse, NodeError>

Current status for a database.

Errors

Returns NodeError::UnknownDb when absent.

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.