callback_http/
callback_http.rs

1// Copyright (c) reifydb.com 2025
2// This file is licensed under the MIT
3
4use std::{thread, time::Duration};
5
6use reifydb_client::http::HttpCallbackSession;
7
8fn main() -> Result<(), Box<dyn std::error::Error>> {
9	// Connect to ReifyDB HTTP server
10	let session = HttpCallbackSession::new("127.0.0.1", 8090, Some("mysecrettoken".to_string()))?;
11
12	// Execute a command to create a table
13	session.command("CREATE NAMESPACE test; CREATE TABLE test.users { id: INT4, name: UTF8 }", None, |result| {
14		match result {
15			Ok(data) => println!("Command executed: {} frames returned", data.frames.len()),
16			Err(e) => println!("Command failed: {}", e),
17		}
18	})?;
19	println!("Command sent");
20
21	// Execute a query
22	session.query("MAP { x: 42, y: 'hello' }", None, |result| {
23		match result {
24			Ok(data) => {
25				println!("Query executed: {} frames returned", data.frames.len());
26				// Print first frame if available
27				if let Some(frame) = data.frames.first() {
28					println!("First frame:\n{}", frame);
29				}
30			}
31			Err(e) => println!("Query failed: {}", e),
32		}
33	})?;
34	println!("Query sent");
35
36	// Wait for callbacks to complete
37	thread::sleep(Duration::from_millis(500));
38
39	Ok(())
40}
callback_http/callback_http.rs

callback_http/
callback_http.rs
