Struct LakehouseContext 

pub struct LakehouseContext { /* private fields */ }

Bundles all runtime resources needed for lakehouse query execution.

This struct holds the data lake connection, metadata cache, file cache, and DataFusion runtime, providing a single context object that can be passed through the query path.

Implementations

impl LakehouseContext

pub async fn from_connection( lake: Arc<DataLakeConnection>, ) -> Result<Arc<LakehouseContext>, Error>

Builds a lakehouse context from an already-connected DataLakeConnection.

Runs migrate_lakehouse on the supplied connection (idempotent) and creates the DataFusion runtime. The caller is responsible for running migrate_db (ingestion schema) before this if both migrations are needed — the monolith does this via connect_to_remote_data_lake.

pub async fn from_env() -> Result<Arc<LakehouseContext>, Error>

Reads MICROMEGAS_SQL_CONNECTION_STRING and MICROMEGAS_OBJECT_STORE_URI, connects to the data lake, runs lakehouse migrations, and creates the runtime environment.

pub fn new( lake: Arc<DataLakeConnection>, runtime: Arc<RuntimeEnv>, ) -> LakehouseContext

Creates a new lakehouse context with default-sized metadata and file caches.

pub fn with_caches( lake: Arc<DataLakeConnection>, runtime: Arc<RuntimeEnv>, metadata_cache: Arc<MetadataCache>, file_cache: Arc<FileCache>, ) -> LakehouseContext

Creates a new lakehouse context with custom metadata and file caches.

pub fn lake(&self) -> &Arc<DataLakeConnection>

Returns the data lake connection.

pub fn metadata_cache(&self) -> &Arc<MetadataCache>

Returns the metadata cache.

pub fn file_cache(&self) -> &Arc<FileCache>

Returns the file cache.

pub fn runtime(&self) -> &Arc<RuntimeEnv>

Returns the DataFusion runtime environment.

pub fn reader_factory(&self) -> &Arc<ReaderFactory>

Returns the shared ReaderFactory.

Trait Implementations

impl Clone for LakehouseContext

fn clone(&self) -> LakehouseContext

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for LakehouseContext

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.