Struct UnityCatalog 

pub struct UnityCatalog<C: UcClient, K: Clock> { /* private fields */ }

A Unity Catalog backend, generic over the transport (UcClient) and the clock (Clock) so it is fully testable without a live workspace.

Implementations

impl<C: UcClient, K: Clock> UnityCatalog<C, K>

pub fn new( client: C, client_id: impl Into<String>, client_secret: impl Into<String>, clock: K, ) -> Self

Construct a backend from a transport, OAuth client credentials, and a clock.

pub fn with_authenticator(client: C, auth: Authenticator<K>) -> Self

Construct a backend from a pre-built Authenticator (e.g. with a non-default token endpoint).

Trait Implementations

impl<C: UcClient, K: Clock> Debug for UnityCatalog<C, K>

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

Prints only the (secret-redacted) authenticator; the transport is opaque.

impl<C: UcClient, K: Clock> TableCatalog for UnityCatalog<C, K>

fn describe<'life0, 'life1, 'async_trait>( &'life0 self, table: &'life1 TableRef, ) -> Pin<Box<dyn Future<Output = Result<Option<TableState>, CatalogError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Return the live state of table, or None if it does not exist.

fn reconcile<'life0, 'life1, 'async_trait>( &'life0 self, desired: &'life1 DesiredTable, _opts: ReconcileOptions, ) -> Pin<Box<dyn Future<Output = Result<ReconcileOutcome, CatalogError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Reconcile table toward desired: describe it, compute a plan with crate::reconcile::plan, and execute the plan. Idempotent — a steady-state redeploy is a no-op.

fn register_sink<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, table: &'life1 TableRef, _sink: &'life2 SinkId, ) -> Pin<Box<dyn Future<Output = Result<(), CatalogError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Register sink as a writer of table for ownership/coverage bookkeeping.

fn vend_credentials<'life0, 'life1, 'async_trait>( &'life0 self, table: &'life1 TableRef, _access: Access, ) -> Pin<Box<dyn Future<Output = Result<VendedCredentials, CatalogError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Vend temporary, scoped credentials granting access to table, inheriting the caller’s privileges. Serves both the write path and the Iceberg recovery read path.