Struct HttpClient 

pub struct HttpClient { /* private fields */ }

HTTP client implementation with worker thread

Implementations

impl HttpClient

pub fn new<A: ToSocketAddrs>(addr: A) -> Result<Self, Box<dyn Error>>

Create a new HTTP client from a socket address

pub fn from_url(url: &str) -> Result<Self, Box<dyn Error>>

Create HTTP client from URL (e.g., “http://localhost:8080”)

pub fn close(self) -> Result<(), Box<dyn Error>>

Close the client connection

pub fn test_connection(&self) -> Result<(), Box<dyn Error>>

Test connection to the server

pub fn blocking_session( &self, token: Option<String>, ) -> Result<HttpBlockingSession, Error>

Create a blocking session

Examples found in repository

examples/blocking_http.rs (line 10)

fn main() -> Result<(), Box<dyn std::error::Error>> {
	let client = Client::http(("127.0.0.1", 8090))?;

	// Create a blocking session with authentication
	let mut session = client.blocking_session(Some("mysecrettoken".to_string()))?;

	// Execute a command to create a table
	let command_result =
		session.command("CREATE NAMESPACE test; CREATE TABLE test.users { id: INT4, name: UTF8 }", None)?;
	println!("Command executed: {} frames returned", command_result.frames.len());

	// Execute a query
	let query_result = session.query("MAP { x: 42, y: 'hello' }", None)?;

	println!("Query executed: {} frames returned", query_result.frames.len());

	// Print first frame if available
	if let Some(frame) = query_result.frames.first() {
		println!("First frame:\n{}", frame);
	}

	Ok(())
}

pub fn callback_session( &self, token: Option<String>, ) -> Result<HttpCallbackSession, Error>

Create a callback session

pub fn channel_session( &self, token: Option<String>, ) -> Result<(HttpChannelSession, Receiver<HttpResponseMessage>), Error>

Create a channel session

Trait Implementations

impl Clone for HttpClient

fn clone(&self) -> HttpClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Drop for HttpClient

fn drop(&mut self)

Executes the destructor for this type.