Struct LanceClient 

pub struct LanceClient { /* private fields */ }

Implementations

impl LanceClient

pub async fn connect(config: ClientConfig) -> Result<Self, ClientError>

Connect to LANCE server, automatically using TLS if configured

pub async fn connect_tls( config: ClientConfig, tls_config: TlsClientConfig, ) -> Result<Self, ClientError>

Connect to LANCE server with TLS encryption

Arguments

• config - Client configuration with server address
• tls_config - TLS configuration including certificates

Example

use lnc_client::{ClientConfig, TlsClientConfig, LanceClient};

let config = ClientConfig::new("127.0.0.1:1992".parse().unwrap());
let tls = TlsClientConfig::new()
    .with_ca_cert("/path/to/ca.pem");

let client = LanceClient::connect_tls(config, tls).await?;

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

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

Connect to LANCE server with TLS using address string

pub async fn send_ingest( &mut self, payload: Bytes, record_count: u32, ) -> Result<u64, ClientError>

pub async fn send_ingest_to_topic( &mut self, topic_id: u32, payload: Bytes, record_count: u32, _auth_config: Option<&AuthConfig>, ) -> Result<u64, ClientError>

pub async fn send_ingest_sync( &mut self, payload: Bytes, record_count: u32, ) -> Result<u64, ClientError>

pub async fn send_ingest_to_topic_sync( &mut self, topic_id: u32, payload: Bytes, record_count: u32, auth_config: Option<&AuthConfig>, ) -> Result<u64, ClientError>

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

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

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

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

pub async fn create_topic( &mut self, name: &str, ) -> Result<TopicInfo, ClientError>

pub async fn list_topics(&mut self) -> Result<Vec<TopicInfo>, ClientError>

pub async fn get_topic( &mut self, topic_id: u32, ) -> Result<TopicInfo, ClientError>

pub async fn delete_topic(&mut self, topic_id: u32) -> Result<(), ClientError>

pub async fn set_retention( &mut self, topic_id: u32, max_age_secs: u64, max_bytes: u64, ) -> Result<(), ClientError>

Set retention policy for an existing topic

Arguments

• topic_id - Topic identifier
• max_age_secs - Maximum age in seconds (0 = no limit)
• max_bytes - Maximum size in bytes (0 = no limit)

pub async fn create_topic_with_retention( &mut self, name: &str, max_age_secs: u64, max_bytes: u64, ) -> Result<TopicInfo, ClientError>

Create a topic with retention policy in a single operation

Arguments

• name - Topic name
• max_age_secs - Maximum age in seconds (0 = no limit)
• max_bytes - Maximum size in bytes (0 = no limit)

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

Get cluster status and health information

pub async fn fetch( &mut self, topic_id: u32, start_offset: u64, max_bytes: u32, ) -> Result<FetchResult, ClientError>

Fetch data from a topic starting at the given offset Returns (data, next_offset, record_count)

pub async fn subscribe( &mut self, topic_id: u32, start_offset: u64, max_batch_bytes: u32, consumer_id: u64, ) -> Result<SubscribeResult, ClientError>

Subscribe to a topic for streaming data Returns the consumer ID and starting offset

pub async fn unsubscribe( &mut self, topic_id: u32, consumer_id: u64, ) -> Result<(), ClientError>

Unsubscribe from a topic

pub async fn commit_offset( &mut self, topic_id: u32, consumer_id: u64, offset: u64, ) -> Result<CommitResult, ClientError>

Commit consumer offset for checkpointing

pub fn config(&self) -> &ClientConfig

pub async fn close(self) -> Result<(), ClientError>

Trait Implementations

impl Debug for LanceClient

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

Formats the value using the given formatter.