Struct DeltaConnection 

pub struct DeltaConnection {
    pub table_uri: String,
    pub credentials: DeltaCredentials,
    pub storage_options: HashMap<String, String>,
}

Available on crate features source-delta and source-rest only.

Location + credentials for a Delta table. Flattened (#[serde(flatten)]) into both the source and sink config so the same three keys appear at the connector-config top level.

Fields

table_uri: String

Delta table location URI: file:///abs/path, s3://bucket/key, abfss://…, gs://bucket/key. A bare local path is accepted and treated as file://.

credentials: DeltaCredentials

Object-store credentials. Defaults to the ambient provider chain.

storage_options: HashMap<String, String>

Extra storage_options passed verbatim to delta-rs (e.g. a MinIO endpoint override, or any object-store key the DeltaCredentials enum does not model). Keys set here win over credential-derived keys.

Implementations

impl DeltaConnection

pub fn merged_storage_options(&self) -> HashMap<String, String>

Build the effective storage_options map: credential-derived keys with the user’s explicit storage_options layered on top (explicit wins).

pub fn redacted_uri(&self) -> String

The table URI with any embedded credentials scrubbed — safe for logs, lineage, and dataset_uri().

pub fn register_handlers(&self)

Register the object-store handlers delta-rs needs for this URI’s scheme.

delta-rs does not auto-register the cloud object stores; the relevant register_handlers must run once before opening/creating an s3:// / abfss:// / gs:// table. Idempotent and cheap — safe to call before every open.

pub fn location_string(&self) -> Result<String, FaucetError>

The resolved table location as a string — for delta-rs builders that take a location string (e.g. CreateBuilder::with_location).

pub async fn open(&self) -> Result<DeltaTable, FaucetError>

Open the table at its latest version. Registers handlers first.

pub async fn open_optional(&self) -> Result<Option<DeltaTable>, FaucetError>

Open the table if it exists; return Ok(None) when the URI is not (yet) a Delta table. Other errors (auth, I/O) propagate. Used by the sink’s create_if_not_missing path.

pub async fn open_at_version( &self, version: u64, ) -> Result<DeltaTable, FaucetError>

Open the table pinned to a specific version (time travel).

pub async fn open_at_timestamp( &self, timestamp: &str, ) -> Result<DeltaTable, FaucetError>

Open the table as of a timestamp (RFC 3339). Time travel.

Trait Implementations

impl Clone for DeltaConnection

fn clone(&self) -> DeltaConnection

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DeltaConnection

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for DeltaConnection

fn deserialize<__D>( __deserializer: __D, ) -> Result<DeltaConnection, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl JsonSchema for DeltaConnection

fn schema_name() -> Cow<'static, str>

The name of the generated JSON Schema.

fn schema_id() -> Cow<'static, str>

Returns a string that uniquely identifies the schema produced by this type.

fn json_schema(generator: &mut SchemaGenerator) -> Schema

Generates a JSON Schema for this type.

fn inline_schema() -> bool

Whether JSON Schemas generated for this type should be included directly in parent schemas, rather than being re-used where possible using the $ref keyword.

impl Serialize for DeltaConnection

fn serialize<__S>( &self, __serializer: __S, ) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.