Struct ReconnectingClient 

pub struct ReconnectingClient { /* private fields */ }

Reconnecting client wrapper with automatic reconnection Client with automatic reconnection and leader redirection support

Implementations

impl ReconnectingClient

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

Create a new reconnecting client

The address can be either an IP:port (e.g., “127.0.0.1:1992”) or a hostname:port (e.g., “lance.example.com:1992”).

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

Create a new reconnecting client with TLS

The address can be either an IP:port (e.g., “127.0.0.1:1992”) or a hostname:port (e.g., “lance.example.com:1992”).

pub fn with_max_attempts(self, attempts: u32) -> Self

Set maximum reconnection attempts

pub fn with_follow_leader(self, follow: bool) -> Self

Enable or disable automatic leader following

pub fn original_addr(&self) -> &str

Get the original connection address

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

Get the current leader address if known

pub fn set_leader_addr(&mut self, addr: SocketAddr)

Update the known leader address (called when redirect received)

pub fn reconnect_attempts(&self) -> u32

Get total reconnection attempts made

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

Get a reference to the underlying client, reconnecting if needed

pub async fn execute<F, T>(&mut self, op: F) -> Result<T, ClientError>

where F: Fn(&mut LanceClient) -> Pin<Box<dyn Future<Output = Result<T, ClientError>> + Send + '_>>,

Execute an operation with automatic reconnection on failure

pub fn mark_failed(&mut self)

Mark connection as failed