Struct UnityFactoryProxyBackend 

pub struct UnityFactoryProxyBackend { /* private fields */ }

Available on crate feature client-arm only.

A StorageProxyBackend that resolves + vends through a UnityObjectStoreFactory. Portable against any UC server.

Implementations

impl UnityFactoryProxyBackend

pub async fn connect( base_uri: impl Into<String>, token: Option<String>, ) -> ProxyResult<Self>

Connect to a Unity Catalog server at base_uri (e.g. https://host/api/2.1/unity-catalog/) with an optional bearer token.

Forwards a per-request end-user identity to upstream UC under DEFAULT_FORWARDED_USER_HEADER. Use connect_with_forwarded_header to re-emit the identity under a different header name.

pub async fn connect_with_forwarded_header( base_uri: impl Into<String>, token: Option<String>, forwarded_header: impl Into<String>, ) -> ProxyResult<Self>

Like connect, but re-emits the forwarded end-user identity under forwarded_header on upstream UC requests (typically the same header name the proxy read the incoming identity from).

pub fn from_factory(factory: UnityObjectStoreFactory) -> Self

Build from an already-constructed factory (e.g. one sharing a client pool). Forwards identity under DEFAULT_FORWARDED_USER_HEADER.

Trait Implementations

impl Clone for UnityFactoryProxyBackend

fn clone(&self) -> UnityFactoryProxyBackend

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<Cx: ForwardedUser + Send + Sync + 'static> StorageProxyBackend<Cx> for UnityFactoryProxyBackend

fn capabilities(&self) -> ProxyCapabilities

Available on crate feature server only.

The proxy capabilities this backend advertises.

fn authorize<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, req: &'life1 ProxyReq, _cx: &'life2 Cx, ) -> Pin<Box<dyn Future<Output = ProxyResult<()>> + Send + 'async_trait>>

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

Available on crate feature server only.

Authorize + scope-check the request. Runs before open.

fn open<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, req: &'life1 ProxyReq, cx: &'life2 Cx, ) -> Pin<Box<dyn Future<Output = ProxyResult<Arc<DynObjectStore>>> + Send + 'async_trait>>

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

Available on crate feature server only.

Open a store scoped to req.securable at the access level implied by the verb (Get/Head → read, Put → read-write). The returned store is prefixed at the securable root, so req.key addresses relative to it.