Struct FoldDB 

pub struct FoldDB { /* private fields */ }

The main database coordinator that manages schemas, permissions, and data storage.

Implementations

impl FoldDB

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

Retrieves or generates and persists the node identifier.

pub fn get_schema_permissions(&self, node_id: &str) -> Vec<String>

Retrieves the list of permitted schemas for the given node.

pub fn set_schema_permissions( &self, node_id: &str, schemas: &[String], ) -> Result<()>

Sets the permitted schemas for the given node.

pub fn close(&self) -> Result<(), Error>

Properly close and flush the database to release all file locks

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

Creates a new FoldDB instance with the specified storage path. All initializations happen here. This is the main entry point for the FoldDB system. Do not initialize anywhere else.

Now fully async to support DbOperationsV2 with storage abstraction!

pub async fn new_with_s3(config: S3Config) -> Result<Self, StorageError>

Creates a new FoldDB instance with S3-backed storage. The database is downloaded from S3 on initialization and can be synced back with flush_to_s3().

pub async fn new_with_db_ops( db_ops: Arc<DbOperationsV2>, db_path: &str, ) -> Result<Self, StorageError>

Creates a new FoldDB instance with a pre-created DbOperationsV2.

This allows you to use any storage backend implementation (DynamoDB, custom, etc.) by creating DbOperationsV2 yourself and passing it in.

Arguments

• db_ops - Pre-created DbOperationsV2 instance with your chosen storage backend
• db_path - Path identifier for logging/debugging (can be any string)

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

Flushes local Sled database and syncs to S3 (if S3 storage is configured)

pub fn has_s3_storage(&self) -> bool

Returns true if this FoldDB instance is configured with S3 storage

pub async fn get_indexing_status(&self) -> IndexingStatus

Get the current indexing status

pub async fn is_indexing(&self) -> bool

Check if indexing is currently in progress

pub async fn load_schema_from_json( &mut self, json_str: &str, ) -> Result<(), SchemaError>

Load schema from JSON string (creates Available schema)

pub async fn load_schema_from_file<P: AsRef<Path>>( &mut self, path: P, ) -> Result<(), SchemaError>

Load schema from file (creates Available schema)

pub fn get_db_ops(&self) -> Arc<DbOperationsV2>

Provides access to the underlying database operations

pub fn get_event_statistics(&self) -> EventStatistics

Get current event statistics from the event monitor

pub fn get_backfill_tracker(&self) -> Arc<BackfillTracker>

Get the backfill tracker

pub fn get_all_backfills(&self) -> Vec<BackfillInfo>

Get all backfill information

pub fn get_active_backfills(&self) -> Vec<BackfillInfo>

Get active (in-progress) backfills

pub fn get_backfill(&self, transform_id: &str) -> Option<BackfillInfo>

Get specific backfill info

pub fn message_bus(&self) -> Arc<MessageBus>

Get the message bus for publishing events (for testing)

pub fn transform_manager(&self) -> Arc<TransformManager>

Get the transform manager for testing transform functionality

pub fn schema_manager(&self) -> Arc<SchemaCore>

Get the schema manager for testing schema functionality

pub fn native_word_search( &self, term: &str, ) -> Result<Vec<IndexResult>, SchemaError>

Search the native word index for a specific term

pub async fn native_search_all_classifications( &self, term: &str, ) -> Result<Vec<IndexResult>, SchemaError>

Search native index across all classification types and aggregate results This now includes field name matches via search_word

pub fn transform_orchestrator(&self) -> Option<Arc<TransformOrchestrator>>

Get the transform orchestrator for managing transform execution Returns None if orchestrator is not available (e.g., with DynamoDB backend)