Struct SqlMerkleStore 

pub struct SqlMerkleStore { /* private fields */ }

SQL-backed Merkle tree storage (ground truth).

Implementations

impl SqlMerkleStore

pub async fn new(connection_string: &str) -> Result<Self, StorageError>

Create a new SQL merkle store, initializing schema if needed.

pub fn from_pool(pool: AnyPool, is_sqlite: bool) -> Self

Create from existing pool (e.g., share with SqlStore).

pub async fn init_schema(&self) -> Result<(), StorageError>

Initialize the schema (creates tables if not exist). Called automatically by new(), but must be called manually after from_pool().

pub async fn root_hash(&self) -> Result<Option<[u8; 32]>, StorageError>

Get the root hash (ground truth).

pub async fn get_hash( &self, path: &str, ) -> Result<Option<[u8; 32]>, StorageError>

Get hash for a specific path.

pub async fn get_children( &self, path: &str, ) -> Result<BTreeMap<String, [u8; 32]>, StorageError>

Get children of an interior node.

pub async fn get_node( &self, path: &str, ) -> Result<Option<MerkleNode>, StorageError>

Get a full node (hash + children).

pub async fn apply_batch(&self, batch: &MerkleBatch) -> Result<(), StorageError>

Apply a batch of merkle updates atomically.

This stores leaf hashes and recomputes affected interior nodes.

pub async fn diff_children( &self, path: &str, their_children: &BTreeMap<String, [u8; 32]>, ) -> Result<Vec<String>, StorageError>

Compare with another merkle store and find differing branches.

Returns prefixes where hashes differ (for sync).

pub async fn get_leaves_under( &self, prefix: &str, ) -> Result<Vec<String>, StorageError>

Get all leaf paths under a prefix (for sync).

pub async fn count_leaves(&self) -> Result<u64, StorageError>

Count total objects (leaves) in the tree.

Trait Implementations

impl Clone for SqlMerkleStore

fn clone(&self) -> SqlMerkleStore

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.