Struct ClusterClient 

pub struct ClusterClient { /* private fields */ }

Cluster-aware client with automatic node discovery

Discovers cluster nodes and maintains connections for high availability. Note: Write routing to the leader is handled server-side via transparent forwarding - clients can send writes to ANY node.

Implementations

impl ClusterClient

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

Create a new cluster client with seed nodes

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

Create a new cluster client with TLS

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