Struct BlockingSession 

pub struct BlockingSession { /* private fields */ }

A blocking session that waits for responses synchronously

Implementations

impl BlockingSession

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_ws.rs (line 16)

fn main() -> Result<(), Box<dyn std::error::Error>> {
	// Connect to ReifyDB server - various ways to specify address:
	// Using tuple (address, port):
	let client = Client::ws(("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_ws.rs (line 20)

fn main() -> Result<(), Box<dyn std::error::Error>> {
	// Connect to ReifyDB server - various ways to specify address:
	// Using tuple (address, port):
	let client = Client::ws(("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