Struct StorageBatch 

pub struct StorageBatch { /* private fields */ }

A batch of operations to commit atomically.

Example

use moloch_storage::{RocksStorage, StorageBatch};

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

batch.put_event(&event1);
batch.put_event(&event2);
batch.put_block(&block);

batch.commit()?; // Atomic write

Implementations

impl StorageBatch

pub fn new() -> Self

Create a new empty batch.

pub fn with_capacity(capacity: usize) -> Self

Create a batch with pre-allocated capacity.

pub fn put_event(&mut self, event: AuditEvent) -> &mut Self

Add an event to the batch.

pub fn put_block(&mut self, block: Block) -> &mut Self

Add a block to the batch.

pub fn put_mmr_node(&mut self, pos: u64, hash: Hash) -> &mut Self

Add an MMR node to the batch.

pub fn set_mmr_meta(&mut self, size: u64, leaf_count: u64) -> &mut Self

Set MMR metadata in the batch.

pub fn len(&self) -> usize

Get the number of operations in the batch.

pub fn is_empty(&self) -> bool

Check if the batch is empty.

pub fn clear(&mut self)

Clear all operations from the batch.

pub fn ops(&self) -> &[BatchOp]

Get the operations in this batch.

pub fn into_ops(self) -> Vec<BatchOp>

Take ownership of the operations.

Trait Implementations

impl Debug for StorageBatch

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

Formats the value using the given formatter.

impl Default for StorageBatch

fn default() -> StorageBatch

Returns the “default value” for a type.