Struct ClusterClient 

pub struct ClusterClient { /* private fields */ }

Cluster-aware client with automatic node discovery. It discovers nodes and maintains healthy connections for read availability per Architecture §21.

Implementations

impl ClusterClient

pub async fn connect(seed_addrs: &[&str]) -> Result<Self, ClientError>

Creates a cluster client using the provided seed nodes, aligning with Architecture §21’s discovery process.

Arguments

• seed_addrs - List of seed endpoints ("host:port") used to fetch the cluster topology.

Returns

• Result<Self> - Initialized client after a successful discovery round-trip.

Errors

• ClientError::ProtocolError when no seed nodes resolve.
• Propagates underlying connect/discovery errors when all nodes fail.

pub async fn connect_tls( seed_addrs: &[&str], tls_config: TlsClientConfig, ) -> Result<Self, ClientError>

Creates a TLS-enabled cluster client using the provided seed nodes so we can satisfy Architecture §14’s transport security guidance.

Arguments

• seed_addrs - List of seed endpoints for discovery.
• tls_config - Certificates and trust roots forwarded to LanceClient.

Returns

• Result<Self> - Initialized TLS client once discovery succeeds.

Errors

Mirrors ClusterClient::connect, plus TLS handshake failures.

pub fn with_discovery_interval(self, interval: Duration) -> Self

Set the discovery refresh interval

pub async fn client(&mut self) -> Result<&mut LanceClient, ClientError>

Get a client connection, refreshing discovery if needed

pub fn primary(&self) -> Option<SocketAddr>

Get the current primary node address

pub fn nodes(&self) -> &[SocketAddr]

Get all known cluster nodes

pub fn tls_config(&self) -> Option<&TlsClientConfig>

Get the TLS configuration if set

pub fn is_tls_enabled(&self) -> bool

Check if TLS is enabled

pub async fn refresh(&mut self) -> Result<(), ClientError>

Force a cluster discovery refresh