Struct DeltaFunnelRuntime 

pub struct DeltaFunnelRuntime { /* private fields */ }

Blocking runtime boundary for high-level Delta Funnel session actions.

This type is intended to be owned by synchronous host bindings. Constructing it only creates a Tokio runtime; it does not register sources, plan SQL, execute DataFusion, contact SQL Server, or write rows.

The blocking methods are intended for non-async host threads. Rust async callers should use DeltaFunnelSession async methods directly. Calling these methods from inside an active Tokio runtime returns a configuration error instead of relying on Tokio’s nested-runtime panic.

Implementations

impl DeltaFunnelRuntime

pub fn new() -> Result<Self, DeltaFunnelError>

Creates a multi-threaded Tokio runtime for blocking host integrations.

Errors

Returns a configuration error if Tokio cannot create the runtime.

pub fn table_from_sql( &self, session: &mut DeltaFunnelSession, sql: &str, ) -> Result<LazyTable, DeltaFunnelError>

Runs async SQL table planning for a synchronous host.

Errors

Returns the same error as DeltaFunnelSession::table_from_sql.

pub fn dry_run_to_mssql( &self, session: &DeltaFunnelSession, request: &OutputWritePlan, ) -> Result<MssqlDryRunOutputReport, DeltaFunnelError>

Runs a single-output dry run through the high-level session API.

Errors

Returns the same error as DeltaFunnelSession::dry_run_to_mssql.

pub fn dry_run_all_to_mssql( &self, session: &DeltaFunnelSession, requests: &[OutputWritePlan], ) -> Result<MssqlDryRunWorkflowReport, DeltaFunnelError>

Runs a multi-output dry run through the high-level session API.

Errors

Returns the same error as DeltaFunnelSession::dry_run_all_to_mssql.

pub fn dry_run_all_to_mssql_with_scan_summary( &self, session: &DeltaFunnelSession, requests: &[OutputWritePlan], ) -> Result<MssqlDryRunWorkflowReport, DeltaFunnelError>

Runs a multi-output dry run with source scan-summary options.

Errors

Returns the same error as DeltaFunnelSession::dry_run_all_to_mssql_with_scan_summary.

pub fn write_to_mssql( &self, session: &DeltaFunnelSession, request: &OutputWritePlan, ) -> Result<MssqlWriteReport, DeltaFunnelError>

Blocks on one selected output write.

Errors

Returns the same error as DeltaFunnelSession::write_to_mssql.

pub fn write_all( &self, session: &DeltaFunnelSession, requests: &[OutputWritePlan], ) -> Result<WriteAllReport, DeltaFunnelError>

Blocks on the default multi-output write workflow.

Errors

Returns the same error as DeltaFunnelSession::write_all.

pub fn write_all_with_options( &self, session: &DeltaFunnelSession, requests: &[OutputWritePlan], options: WriteAllOptions, ) -> Result<WriteAllReport, DeltaFunnelError>

Blocks on the multi-output write workflow with explicit options.

Errors

Returns the same error as DeltaFunnelSession::write_all_with_options.