Struct DataFoldNode 

pub struct DataFoldNode {
    pub config: NodeConfig,
    /* private fields */
}

A node in the DataFold distributed database system.

DataFoldNode combines database storage, schema management, and networking capabilities into a complete node implementation. It can operate independently or as part of a network of nodes, with trust relationships defining data access.

Features

• Schema loading and management
• Query and mutation execution
• Network communication with other nodes
• Permission management for schemas
• Request forwarding to trusted nodes

Fields

config: NodeConfig

Configuration settings for this node

Implementations

impl DataFoldNode

pub async fn new(config: NodeConfig) -> FoldDbResult<Self>

Creates a new DataFoldNode with the specified configuration.

Now fully async to support storage abstraction!

pub async fn new_with_db( config: NodeConfig, db: Arc<Mutex<FoldDB>>, ) -> FoldDbResult<Self>

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

This is useful when you need to control the storage backend (e.g., S3) before creating the node.

Arguments

• config - Node configuration
• db - Pre-created FoldDB instance

pub async fn get_fold_db(&self) -> FoldDbResult<OwnedMutexGuard<FoldDB>>

Get a reference to the underlying FoldDB instance

pub fn get_node_id(&self) -> &str

Gets the unique identifier for this node.

pub fn schema_service_url(&self) -> Option<String>

Gets the configured schema service URL, if present.

pub async fn fetch_available_schemas(&self) -> FoldDbResult<Vec<Schema>>

Fetch available schemas from the schema service. Returns an error if the schema service URL is not configured or if the fetch fails.

pub async fn add_schema_to_service( &self, schema: &Schema, ) -> FoldDbResult<Schema>

Add a new schema to the schema service. Returns an error if the schema service URL is not configured or if the operation fails.

pub async fn mutate_batch( &self, mutations: Vec<Mutation>, ) -> FoldDbResult<Vec<String>>

Execute a batch of mutations.

This is a convenience method that delegates to the underlying FoldDB. It is primarily used by tests and internal components that need direct access without going through the OperationProcessor.

impl DataFoldNode

pub fn get_node_private_key(&self) -> &str

Gets the node’s private key.

pub fn get_node_public_key(&self) -> &str

Gets the node’s public key.

pub fn get_security_manager(&self) -> &Arc<SecurityManager>

Gets a reference to the security manager.

pub fn get_schema_client(&self) -> SchemaServiceClient

Get a schema service client for communicating with the schema service

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

impl DataFoldNode

pub async fn add_transform_to_queue( &self, transform_id: &str, ) -> FoldDbResult<()>

Add a transform to the queue

pub async fn get_transform_queue_info(&self) -> FoldDbResult<TransformQueueInfo>

Get information about the transform queue

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

Get all backfill information

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

Get active backfills

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

Get specific backfill info by transform ID

pub async fn get_backfill_by_hash( &self, hash: &str, ) -> FoldDbResult<Option<BackfillInfo>>

Get specific backfill info by backfill hash

pub async fn get_event_statistics(&self) -> FoldDbResult<EventStatistics>

Get event statistics

Trait Implementations

impl Clone for DataFoldNode

fn clone(&self) -> DataFoldNode

Returns a duplicate of the value.

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

Performs copy-assignment from source.