Struct IndexedJournalHandler 

pub struct IndexedJournalHandler { /* private fields */ }

Production indexed journal handler

Provides efficient O(log n) lookups using B-tree indexes, O(1) membership testing using Bloom filters, and cryptographic verification or integrity using Merkle trees.

Performance Guarantees

• facts_by_predicate: O(log n + k) where k is result size
• facts_by_authority: O(log n + k) where k is result size
• facts_in_range: O(log n + k) where k is result size
• might_contain: O(1) with <1% false positive rate
• merkle_root: O(n) on first call, O(1) cached
• verify_fact_inclusion: O(log n)

Concurrency Model

Uses parking_lot::RwLock for synchronous locking of the state bundle. Each operation acquires and releases the lock in sub-millisecond time. See module documentation for scale expectations and alternatives.

Implementations

impl IndexedJournalHandler

pub fn new() -> Self

Create a new indexed journal handler with default configuration

pub fn with_capacity(expected_elements: u64) -> Self

Create a new indexed journal handler with specified expected capacity

pub fn add_fact( &self, predicate: String, value: FactValue, authority: Option<AuthorityId>, timestamp: Option<TimeStamp>, ) -> FactId

Add a fact to the index

Trait Implementations

impl Debug for IndexedJournalHandler

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for IndexedJournalHandler

fn default() -> Self

Returns the “default value” for a type.

impl IndexedJournalEffects for IndexedJournalHandler

fn watch_facts(&self) -> Box<dyn FactStreamReceiver>

Subscribe to journal fact updates as they are added.

fn facts_by_predicate<'life0, 'life1, 'async_trait>( &'life0 self, predicate: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<IndexedFact>, AuraError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get all facts with the given predicate/key.

fn facts_by_authority<'life0, 'life1, 'async_trait>( &'life0 self, authority: &'life1 AuthorityId, ) -> Pin<Box<dyn Future<Output = Result<Vec<IndexedFact>, AuraError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get all facts created by the given authority.

fn facts_in_range<'life0, 'async_trait>( &'life0 self, start: TimeStamp, end: TimeStamp, ) -> Pin<Box<dyn Future<Output = Result<Vec<IndexedFact>, AuraError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get all facts within the given time range (inclusive).

fn all_facts<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<IndexedFact>, AuraError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Return all indexed facts (append-only view).

fn might_contain(&self, predicate: &str, value: &FactValue) -> bool

Fast membership test using Bloom filter.

fn merkle_root<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<[u8; 32], AuraError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get the Merkle root commitment for the current index state.

fn verify_fact_inclusion<'life0, 'life1, 'async_trait>( &'life0 self, fact: &'life1 IndexedFact, ) -> Pin<Box<dyn Future<Output = Result<bool, AuraError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Verify a fact against the Merkle tree.

fn get_bloom_filter<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<BloomFilter, AuraError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get the Bloom filter for fast membership tests.

fn index_stats<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<IndexStats, AuraError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get statistics about the index.