Storage layer for Moloch.

Provides persistent storage for:

• Audit events
• Blocks
• MMR nodes
• Indexes for efficient queries

Batch Operations

For efficient bulk writes, use the batch API:

use moloch_storage::{RocksStorage, StorageBatch, BatchWriter};

let storage = RocksStorage::open("./data")?;
let mut batch = StorageBatch::new();

batch.put_block(block1);
batch.put_block(block2);
batch.put_mmr_node(0, hash);

storage.commit(batch)?; // Atomic write

Iterators

For efficient traversal, use the iterator API:

use moloch_storage::{RocksStorage, BlockIterator, EventIterator};

let storage = RocksStorage::open("./data")?;

// Iterate over all blocks
for block in BlockIterator::all(&storage)? {
    println!("Block {}", block?.header.height);
}

// Iterate over events in specific block range
for event in EventIterator::in_blocks(&storage, 0, 100) {
    let (height, event) = event?;
    println!("Event {} in block {}", event.id(), height);
}