Struct RedbStorage 

pub struct RedbStorage { /* private fields */ }

redb-backed persistent storage adapter for BEAM.

Stores the graph in a single redb database file. Each Put commits inline (ACID) inside spawn_blocking so the fsync does not block the async runtime. Reads are concurrent. Flush is an immediate ack (puts already fsync on commit).

Example

use beam::adapters::RedbStorage;
use beam::Config;

let storage = RedbStorage::new_with_config(Config::default(), "my-db.redb", None);

Implementations

impl RedbStorage

pub fn new() -> Self

Creates a new redb storage at the default path beam.redb.

Panics

Panics if the database cannot be created or opened.

pub fn new_with_config<P: AsRef<Path>>( config: Config, path: P, _max_size: Option<u64>, ) -> Self

Creates a new redb storage with explicit config and path.

Arguments

• config - Node configuration
• path - File path for the redb database
• _max_size - Optional maximum database size (currently unused)

Panics

Panics if the database cannot be created or opened at the given path.

Trait Implementations

impl Actor for RedbStorage

fn try_clone_storage(&self) -> Option<Box<dyn Actor>>

Returns a boxed clone for the storage read/write actor split.

Both the read and write actor share the same Arc<Database>, so reads see committed writes immediately via redb’s MVCC snapshots.

fn pre_start<'life0, 'life1, 'async_trait>( &'life0 mut self, _ctx: &'life1 ActorContext, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Called once before the actor starts processing messages.

fn stopping<'life0, 'life1, 'async_trait>( &'life0 mut self, _ctx: &'life1 ActorContext, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Called once after the actor’s message loop exits.

fn handle<'life0, 'life1, 'async_trait>( &'life0 mut self, message: Arc<Message>, ctx: &'life1 ActorContext, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Handle an incoming message.

fn handle_batch<'life0, 'life1, 'life2, 'async_trait>( &'life0 mut self, batch: &'life1 mut Vec<Arc<Message>>, context: &'life2 ActorContext, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Handle a batch of messages drained from the mailbox.

fn subscribe_to_everything(&self) -> bool

Whether this actor wants to receive all messages (not just addressed to it). Used by the Multicast adapter.

impl Clone for RedbStorage

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for RedbStorage

fn default() -> Self

Returns the “default value” for a type.