Struct HttpBlockingSession 

pub struct HttpBlockingSession { /* private fields */ }

A blocking HTTP session that waits for responses synchronously

Implementations

impl HttpBlockingSession

pub fn new(host: &str, port: u16, token: Option<String>) -> Result<Self, Error>

Create a new blocking HTTP session

pub fn from_client( client: HttpClient, token: Option<String>, ) -> Result<Self, Error>

Create a new blocking HTTP session from an existing client

pub fn from_url(url: &str, token: Option<String>) -> Result<Self, Error>

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

pub fn with_timeout(self, timeout: Duration) -> Self

Set timeout for requests

pub fn command( &mut self, rql: &str, params: Option<Params>, ) -> Result<CommandResult, Error>

Send a command and wait for response

Examples found in repository

examples/blocking_http.rs (line 14)

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 query( &mut self, rql: &str, params: Option<Params>, ) -> Result<QueryResult, Error>

Send a query and wait for response

Examples found in repository

examples/blocking_http.rs (line 18)

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 is_authenticated(&self) -> bool

Check if the session is authenticated