Struct DbState 

pub struct DbState { /* private fields */ }

Per-database state hosted by a node.

Implementations

impl DbState

pub fn name(&self) -> &str

Database name.

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

The store this database’s blobs are read and written through: encrypting for an encrypted database, the bare backend otherwise.

pub fn is_encrypted(&self) -> bool

Whether this database’s durable artifacts are encrypted.

pub fn keys_unavailable(&self) -> bool

Whether a key-manifest change could not be loaded. The keys in hand still serve; see Self::keys_fenced for the case that does not.

pub fn keys_fenced(&self) -> bool

Whether this node is writing under a storage-key epoch the manifest has closed. Writes refuse while this holds.

pub fn db(&self) -> Db

Current database value.

pub fn basis_watch(&self) -> Receiver<u64>

Watch channel following the commit basis.

pub fn stream_items(&self) -> Receiver<Item>

Subscribes to live stream items (reports, index announcements, heartbeats).

pub fn index_basis(&self) -> u64

Basis of the newest published index root.

pub fn index_policy(&self) -> IndexPolicy

The indexing pacing policy currently in effect for this database.

pub fn lease(&self) -> Lease

Currently held lease record.

pub fn handshake_snapshot(&self) -> (Vec<u8>, KeywordInterner)

Encoded schema/ident handshake payload plus a consistent basis and interner snapshot for backfill encoding.

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

Reads committed records in [start, end) from the durable log.

Errors

Returns an error when the log cannot be read.