Struct FoldDB 

pub struct FoldDB { /* private fields */ }

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

Implementations

impl FoldDB

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

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 fn new(path: &str) -> Result<Self>

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. updated by @tomtang2

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 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 fn get_indexing_status(&self) -> IndexingStatus

Get the current indexing status

pub fn is_indexing(&self) -> bool

Check if indexing is currently in progress

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

Load schema from JSON string (creates Available schema)

pub 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<DbOperations>

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 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) -> Arc<TransformOrchestrator>

Get the transform orchestrator for managing transform execution