Struct Ledger 

pub struct Ledger { /* private fields */ }

The transaction ledger for a single frame.

Implementations

impl Ledger

pub async fn create( storage: Arc<dyn StorageBackend>, frame_path: &str, schema: FrameSchema, partition_by: Vec<String>, node_id: &NodeId, ) -> Result<Self>

Create a new ledger for a frame, writing version 0 (CreateFrame entry).

pub async fn open( storage: Arc<dyn StorageBackend>, frame_path: &str, ) -> Result<Self>

Open an existing ledger by loading the latest checkpoint and replaying entries.

pub async fn commit( &mut self, action: LedgerAction, node_id: &NodeId, ) -> Result<u64>

Commit an action to the ledger with optimistic concurrency. Returns the committed version number.

pub fn active_cells(&self) -> &[CellMetadata]

Get the currently active cells.

pub fn current_version(&self) -> u64

Get the current version.

pub fn schema(&self) -> &FrameSchema

Get the frame schema.

pub fn partition_by(&self) -> &[String]

Get the partition columns.

pub fn frame_path(&self) -> &str

Get the frame path.

pub fn prune_cells( &self, partition_filters: &HashMap<String, String>, stat_filters: &HashMap<String, (Option<Value>, Option<Value>)>, ) -> Vec<&CellMetadata>

Prune cells based on partition filters and column stat filters. Returns references to cells that match the given filters.