Struct SharedDuckDbEngine 

pub struct SharedDuckDbEngine(pub Arc<DuckDbEngine>);

Arc-wrapped DuckDbEngine that implements rhei_core::OlapEngine.

This newtype sidesteps the Rust orphan rule that would prevent writing impl OlapEngine for Arc<DuckDbEngine> (both Arc and OlapEngine are defined in foreign crates). Use SharedDuckDbEngine wherever you need cheap clones of a shared engine handle — for example when passing the engine to multiple background tasks.

All trait methods delegate to the inner DuckDbEngine with zero overhead. The Deref implementation gives direct access to DuckDbEngine methods.

Tuple Fields

0: Arc<DuckDbEngine>

Implementations

impl SharedDuckDbEngine

pub fn new(engine: DuckDbEngine) -> Self

Wrap engine in an Arc, producing a cheaply cloneable handle.

Methods from Deref<Target = DuckDbEngine>

pub fn read_pool_size(&self) -> usize

Return the number of read connections in the pool.

Always at least 1 (pool size is clamped at construction time).

Trait Implementations

impl Clone for SharedDuckDbEngine

fn clone(&self) -> SharedDuckDbEngine

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Deref for SharedDuckDbEngine

fn deref(&self) -> &Self::Target

Dereferences to the inner DuckDbEngine.

type Target = DuckDbEngine

The resulting type after dereferencing.

impl OlapEngine for SharedDuckDbEngine

Delegates all rhei_core::OlapEngine calls to the inner DuckDbEngine. See that type’s documentation for per-method details.

async fn query(&self, sql: &str) -> Result<Vec<RecordBatch>, Self::Error>

Delegates to DuckDbEngine::query.

async fn execute(&self, sql: &str) -> Result<u64, Self::Error>

Delegates to DuckDbEngine::execute.

async fn load_arrow( &self, table: &str, batches: &[RecordBatch], ) -> Result<u64, Self::Error>

Delegates to DuckDbEngine::load_arrow.

async fn create_table( &self, table_name: &str, schema: &SchemaRef, primary_key: &[String], ) -> Result<(), Self::Error>

Delegates to DuckDbEngine::create_table.

async fn table_exists(&self, table_name: &str) -> Result<bool, Self::Error>

Delegates to DuckDbEngine::table_exists.

async fn add_column( &self, table_name: &str, column_name: &str, data_type: &DataType, ) -> Result<(), Self::Error>

Delegates to DuckDbEngine::add_column.

async fn drop_column( &self, table_name: &str, column_name: &str, ) -> Result<(), Self::Error>

Delegates to DuckDbEngine::drop_column.

fn supports_transactions(&self) -> bool

Delegates to DuckDbEngine::supports_transactions.

type Error = DuckDbError

Engine-specific error type returned by all fallible methods.

fn query_stream( &self, sql: &str, ) -> impl Future<Output = Result<Pin<Box<dyn Stream<Item = Result<RecordBatch, Box<dyn Error + Send + Sync>>> + Send>>, Self::Error>> + Send

Execute a SQL query and return a lazy RecordBatchBoxStream.