Struct DataLakeConnection 

pub struct DataLakeConnection {
    pub db_pool: Pool<Postgres>,
    pub blob_storage: Arc<BlobStorage>,
    /* private fields */
}

A connection to the data lake, including a database pool and a blob storage client.

Fields

db_pool: Pool<Postgres>

blob_storage: Arc<BlobStorage>

Implementations

impl DataLakeConnection

pub fn new( db_pool: Pool<Postgres>, blob_storage: Arc<BlobStorage>, ) -> DataLakeConnection

pub fn new_with_prefetch( db_pool: Pool<Postgres>, blob_storage: Arc<BlobStorage>, prefetch: Option<Arc<dyn ObjectPrefetch>>, ) -> DataLakeConnection

Like new, but also wires the object cache’s prefetch face for write-time warming (see warm_object).

pub fn warm_object(&self, key: &str, size: i64) -> Option<JoinHandle<()>>

Warm a freshly-written object in the object cache by key. Fire-and-forget at prefetch priority: spawns a detached task and returns immediately, so the caller’s write path is never delayed or failed by a warm. No-op when the cache is not configured or size <= 0. Returns the spawned task handle (or None) purely so tests can await completion deterministically; production callers ignore it.

This is a general “warm any object” primitive — the write-partition path is its first caller, but nothing here is partition-specific (e.g. the ingestion service could warm raw payloads the same way). key is the lake-root-relative object key; the configured prefetch handle applies the lake root prefix so the warmed key matches the key demand reads produce.

Trait Implementations

impl Clone for DataLakeConnection

fn clone(&self) -> DataLakeConnection

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DataLakeConnection

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

Formats the value using the given formatter.