Struct DataFoldNode 

pub struct DataFoldNode { /* 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

Implementations

impl DataFoldNode

pub async fn query( &self, query: Query, ) -> FoldDbResult<HashMap<String, HashMap<KeyValue, FieldValue>>>

Executes a query against the database.

pub fn mutate(&self, mutation: Mutation) -> FoldDbResult<String>

👎Deprecated since 0.1.0: Use mutate_batch() instead for better performance

Executes a mutation on the database.

Deprecated

Use mutate_batch() instead for better performance, even for single mutations.

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

Executes multiple mutations in a batch for improved performance.

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

Executes multiple mutations in a batch (async version - preferred for DynamoDB)

pub fn list_transforms(&self) -> FoldDbResult<HashMap<String, Transform>>

List all registered transforms.

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 fn get_fold_db(&self) -> FoldDbResult<MutexGuard<'_, 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.

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 fn add_transform_to_queue(&self, transform_id: &str) -> FoldDbResult<()>

Add a transform to the queue

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

Get information about the transform queue

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

Get all backfill information

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

Get active backfills

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

Get specific backfill info by transform ID

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

Get specific backfill info by backfill hash

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

impl Drop for DataFoldNode

fn drop(&mut self)

Executes the destructor for this type.