Struct ConnectBuilder 

pub struct ConnectBuilder { /* private fields */ }

Builder for creating Lance namespace connections.

This builder provides a fluent API for configuring and establishing connections to Lance namespace implementations.

Examples

// Connect to directory implementation
let namespace = ConnectBuilder::new("dir")
    .property("root", "/path/to/data")
    .property("storage.region", "us-west-2")
    .connect()
    .await?;

// Connect with a shared session
let session = Arc::new(Session::default());
let namespace = ConnectBuilder::new("dir")
    .property("root", "/path/to/data")
    .session(session)
    .connect()
    .await?;

With Dynamic Context Provider

#[derive(Debug)]
struct MyProvider;

impl DynamicContextProvider for MyProvider {
    fn provide_context(&self, info: &OperationInfo) -> HashMap<String, String> {
        let mut ctx = HashMap::new();
        ctx.insert("headers.Authorization".to_string(), "Bearer token".to_string());
        ctx
    }
}

let namespace = ConnectBuilder::new("rest")
    .property("uri", "https://api.example.com")
    .context_provider(Arc::new(MyProvider))
    .connect()
    .await?;

Implementations

impl ConnectBuilder

pub fn new(impl_name: impl Into<String>) -> Self

Create a new ConnectBuilder for the specified implementation.

Arguments

• impl_name - Implementation identifier (“dir”, “rest”, etc.)

pub fn property(self, key: impl Into<String>, value: impl Into<String>) -> Self

Add a configuration property.

Arguments

• key - Property key
• value - Property value

pub fn properties(self, properties: HashMap<String, String>) -> Self

Add multiple configuration properties.

Arguments

• properties - HashMap of properties to add

pub fn session(self, session: Arc<Session>) -> Self

Set the Lance session to use for this connection.

When a session is provided, the namespace will reuse the session’s object store registry, allowing multiple namespaces and datasets to share the same underlying storage connections.

Arguments

• session - Arc-wrapped Lance session

pub fn context_provider(self, provider: Arc<dyn DynamicContextProvider>) -> Self

Set a dynamic context provider for per-request context.

The provider will be called before each operation to generate additional context. For RestNamespace, context keys that start with headers. are converted to HTTP headers by stripping the prefix.

Arguments

• provider - The context provider implementation

pub async fn connect(self) -> Result<Arc<dyn LanceNamespace>>

Build and establish the connection to the namespace.

Returns

Returns a trait object implementing LanceNamespace.

Errors

Returns an error if:

• The implementation type is not supported
• Required configuration properties are missing
• Connection to the backend fails

Trait Implementations

impl Clone for ConnectBuilder

fn clone(&self) -> ConnectBuilder

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConnectBuilder

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

Formats the value using the given formatter.