Tag: Rust Tokio Client

The Geode Rust client library (<code>geode-client-rust</code>) provides a high-performance, type-safe async interface for connecting to Geode graph databases. Built on tokio with Quinn for QUIC transport, it delivers exceptional throughput with zero-cost abstractions while leveraging Rust’s strong type system to catch errors at compile time. The Rust client is designed for performance-critical applications, high-throughput data processing, and systems where reliability and efficiency are paramount. With support for 10,000+ queries per second and sub-millisecond latency, it is ideal for demanding production workloads. <h3 id="key-features" class="position-relative d-flex align-items-center group"> Key Features <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="key-features" aria-haspopup="dialog" aria-label="Share link: Key Features"> Share link </button> </h3><div id="headingShareModal" class="heading-share-modal" role="dialog" aria-modal="true" aria-labelledby="headingShareTitle" hidden> <div class="hsm-dialog" role="document"> <div class="hsm-header"> <h2 id="headingShareTitle" class="h6 mb-0 fw-bold">Share this section</h2> <button type="button" class="hsm-close" aria-label="Close"> </button> </div> <div class="hsm-body"> <label for="headingShareInput" class="form-label small text-muted mb-1 text-uppercase fw-bold" style="font-size: 0.7rem; letter-spacing: 0.5px;">Permalink</label> <div class="input-group mb-4 hsm-url-group"> <input id="headingShareInput" type="text" class="form-control font-monospace" readonly aria-readonly="true" style="font-size: 0.85rem;" /> <button class="btn btn-primary hsm-copy" type="button" aria-label="Copy" title="Copy"> </button> </div> <div class="small fw-bold mb-2 text-muted text-uppercase" style="font-size: 0.7rem; letter-spacing: 0.5px;">Share via</div> <div class="hsm-share-grid"> <a id="share-twitter" class="btn btn-outline-secondary w-100" target="_blank" rel="noopener noreferrer"> Twitter </a> <a id="share-linkedin" class="btn btn-outline-secondary w-100" target="_blank" rel="noopener noreferrer"> LinkedIn </a> <a id="share-facebook" class="btn btn-outline-secondary w-100" target="_blank" rel="noopener noreferrer"> Facebook </a> </div> </div> </div> </div> <style> .heading-share-modal { position: fixed; inset: 0; display: flex; justify-content: center; align-items: center; background: rgba(0, 0, 0, 0.6); z-index: 1050; padding: 1rem; backdrop-filter: blur(4px); -webkit-backdrop-filter: blur(4px); } .heading-share-modal[hidden] { display: none !important; } .hsm-dialog { max-width: 420px; width: 100%; background: var(--bs-body-bg, #fff); color: var(--bs-body-color, #212529); border: 1px solid var(--bs-border-color, rgba(0,0,0,0.1)); border-radius: 1rem; box-shadow: 0 25px 50px -12px rgba(0, 0, 0, 0.25); overflow: hidden; animation: hsm-fade-in 0.2s ease-out; } @keyframes hsm-fade-in { from { opacity: 0; transform: scale(0.95); } to { opacity: 1; transform: scale(1); } } [data-bs-theme="dark"] .hsm-dialog { background: #1e293b; border-color: rgba(255,255,255,0.1); color: #f8f9fa; } .hsm-header { display: flex; justify-content: space-between; align-items: center; padding: 1rem 1.5rem; border-bottom: 1px solid var(--bs-border-color, rgba(0,0,0,0.1)); background: rgba(0,0,0,0.02); } [data-bs-theme="dark"] .hsm-header { background: rgba(255,255,255,0.02); border-color: rgba(255,255,255,0.1); } .hsm-close { background: transparent; border: none; color: inherit; opacity: 0.5; padding: 0.25rem 0.5rem; border-radius: 0.25rem; font-size: 1.2rem; line-height: 1; transition: opacity 0.2s; } .hsm-close:hover { opacity: 1; } .hsm-body { padding: 1.5rem; } .hsm-url-group { display: flex !important; align-items: stretch; } .hsm-url-group .form-control { flex: 1; min-width: 0; margin: 0; background: var(--bs-secondary-bg, #f8f9fa); border-color: var(--bs-border-color, #dee2e6); border-top-right-radius: 0; border-bottom-right-radius: 0; height: 42px; } .hsm-url-group .btn { flex: 0 0 auto; margin: 0; margin-left: -1px; border-top-left-radius: 0; border-bottom-left-radius: 0; height: 42px; display: flex; align-items: center; justify-content: center; padding: 0 1.25rem; z-index: 2; } [data-bs-theme="dark"] .hsm-url-group .form-control { background: #0f172a; border-color: #334155; color: #e2e8f0; } .hsm-share-grid { display: flex; flex-direction: column; gap: 0.5rem; } .hsm-share-grid .btn { display: flex; align-items: center; justify-content: center; font-size: 0.9rem; padding: 0.6rem; border-color: var(--bs-border-color); width: 100%; } [data-bs-theme="dark"] .hsm-share-grid .btn { color: #e2e8f0; border-color: #475569; } [data-bs-theme="dark"] .hsm-share-grid .btn:hover { background: #334155; border-color: #cbd5e1; } </style> <script> (function(){ const modal = document.getElementById('headingShareModal'); if(!modal) return; const input = modal.querySelector('#headingShareInput'); const copyBtn = modal.querySelector('.hsm-copy'); const twitter = modal.querySelector('#share-twitter'); const linkedin = modal.querySelector('#share-linkedin'); const facebook = modal.querySelector('#share-facebook'); const closeBtn = modal.querySelector('.hsm-close'); let lastFocus=null; let trapBound=false; function buildUrl(id){ return window.location.origin + window.location.pathname + '#' + id; } function isOpen(){ return !modal.hasAttribute('hidden'); } function hydrate(id){ const url=buildUrl(id); input.value=url; const enc=encodeURIComponent(url); const text=encodeURIComponent(document.title); if(twitter) twitter.href=`https://twitter.com/intent/tweet?url=${enc}&text=${text}`; if(linkedin) linkedin.href=`https://www.linkedin.com/sharing/share-offsite/?url=${enc}`; if(facebook) facebook.href=`https://www.facebook.com/sharer/sharer.php?u=${enc}`; } function openModal(id){ lastFocus=document.activeElement; hydrate(id); if(!isOpen()){ modal.removeAttribute('hidden'); } requestAnimationFrame(()=>{ input.focus(); }); trapFocus(); } function closeModal(){ if(!isOpen()) return; modal.setAttribute('hidden',''); if(lastFocus && typeof lastFocus.focus==='function') lastFocus.focus(); } function copyCurrent(){ try{ navigator.clipboard.writeText(input.value).then(()=>feedback(true),()=>fallback()); } catch(e){ fallback(); } } function fallback(){ input.select(); try{ document.execCommand('copy'); feedback(true);}catch(e){ feedback(false);} } function feedback(ok){ if(!copyBtn) return; const icon=copyBtn.querySelector('i'); if(!icon) return; const prev=copyBtn.getAttribute('data-prev')||icon.className; if(!copyBtn.getAttribute('data-prev')) copyBtn.setAttribute('data-prev',prev); icon.className= ok ? 'fa-duotone fa-clipboard-check':'fa-duotone fa-circle-exclamation'; setTimeout(()=>{ icon.className=prev; },1800); } function handleShareClick(e){ e.preventDefault(); const btn=e.currentTarget; const id=btn.getAttribute('data-share-target'); if(id) openModal(id); } function bindShareButtons(){ document.querySelectorAll('.h-share').forEach(btn=>{ if(!btn.dataset.hShareBound){ btn.addEventListener('click', handleShareClick); btn.dataset.hShareBound='1'; } }); } bindShareButtons(); if(document.readyState==='loading'){ document.addEventListener('DOMContentLoaded', bindShareButtons); } else { requestAnimationFrame(bindShareButtons); } document.addEventListener('click', function(e){ const shareBtn=e.target.closest && e.target.closest('.h-share'); if(shareBtn && !shareBtn.dataset.hShareBound){ handleShareClick.call(shareBtn, e); } }, true); document.addEventListener('click', e=>{ if(e.target===modal) closeModal(); if(e.target.closest && e.target.closest('.hsm-close')){ e.preventDefault(); closeModal(); } if(copyBtn && (e.target===copyBtn || (e.target.closest && e.target.closest('.hsm-copy')))) { e.preventDefault(); copyCurrent(); } }); document.addEventListener('keydown', e=>{ if(e.key==='Escape' && isOpen()) closeModal(); }); function trapFocus(){ if(trapBound) return; trapBound=true; modal.addEventListener('keydown', f=>{ if(f.key==='Tab' && isOpen()){ const focusable=[...modal.querySelectorAll('a[href],button,input,textarea,select,[tabindex]:not([tabindex="-1"])')].filter(el=>!el.hasAttribute('disabled')); if(!focusable.length) return; const first=focusable[0]; const last=focusable[focusable.length-1]; if(f.shiftKey && document.activeElement===first){ f.preventDefault(); last.focus(); } else if(!f.shiftKey && document.activeElement===last){ f.preventDefault(); first.focus(); } } }); } if(closeBtn) closeBtn.addEventListener('click', e=>{ e.preventDefault(); closeModal(); }); })(); </script>Fully Async with Tokio: Native tokio runtime integration for efficient async operations. Quinn QUIC Transport: High-performance QUIC implementation with TLS 1.3 using the quinn library. Type-Safe Query Builders: Compile-time checked query construction with fluent builder APIs. Zero-Cost Abstractions: Minimal runtime overhead from Rust’s type system and ownership model. Connection Pooling: Built-in pooling supporting 10,000+ queries per second. Rich Type System: Full GQL type support with Decimal, temporal types, and type-safe accessors. Comprehensive Error Handling: Result-based error handling with retry support. <h3 id="installation" class="position-relative d-flex align-items-center group"> Installation <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="installation" aria-haspopup="dialog" aria-label="Share link: Installation"> Share link </button> </h3>Install from <a href="https://crates.io/crates/geode-client" aria-label="crates.io – opens in new window" target="_blank" rel="noopener noreferrer" >crates.io ↗ </a> : <div class="highlight"><pre tabindex="0" class="chroma"><code class="language-bash" data-lang="bash">cargo add geode-client tokio --features tokio/full </code></pre></div>Or add to your <code>Cargo.toml</code>: <div class="highlight"><pre tabindex="0" class="chroma"><code class="language-toml" data-lang="toml">[dependencies] geode-client = "0.1.1-alpha.8" tokio = { version = "1", features = ["full"] } </code></pre></div> <h4 id="requirements" class="position-relative d-flex align-items-center group"> Requirements <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="requirements" aria-haspopup="dialog" aria-label="Share link: Requirements"> Share link </button> </h4><ul> <li>Rust 1.70 or later</li> <li>quinn >= 0.10 (QUIC support)</li> <li>tokio runtime</li> <li>Running Geode server with QUIC enabled</li> </ul> <h3 id="quick-start" class="position-relative d-flex align-items-center group"> Quick Start <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="quick-start" aria-haspopup="dialog" aria-label="Share link: Quick Start"> Share link </button> </h3> <h4 id="basic-connection" class="position-relative d-flex align-items-center group"> Basic Connection <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="basic-connection" aria-haspopup="dialog" aria-label="Share link: Basic Connection"> Share link </button> </h4><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-rust" data-lang="rust">use geode_client::{Client, Result}; #[tokio::main] async fn main() -> Result<()> { // Create QUIC client (skip TLS verification for development) let client = Client::new("127.0.0.1", 3141) .skip_verify(true) .page_size(1000); // Connect via QUIC let conn = client.connect().await?; println!("Connected to Geode via QUIC!"); // Execute query let page = conn.query("RETURN 1 AS x, 'Hello QUIC' AS greeting", None).await?; for row in &page.rows { let x = row.get("x").unwrap().as_int()?; let greeting = row.get("greeting").unwrap().as_string()?; println!("x={}, greeting={}", x, greeting); } // Close connection conn.close().await?; Ok(()) } </code></pre></div> <h4 id="query-with-parameters" class="position-relative d-flex align-items-center group"> Query with Parameters <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="query-with-parameters" aria-haspopup="dialog" aria-label="Share link: Query with Parameters"> Share link </button> </h4><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-rust" data-lang="rust">use std::collections::HashMap; async fn find_person(conn: &Connection, name: &str) -> Result<()> { let mut params = HashMap::new(); params.insert("name".to_string(), serde_json::json!(name)); let page = conn.query( "MATCH (p:Person {name: $name}) RETURN p.age AS age", Some(params) ).await?; if let Some(row) = page.rows.first() { let age = row.get("age").unwrap().as_int()?; println!("{} is {} years old", name, age); } Ok(()) } </code></pre></div> <h3 id="connection-configuration" class="position-relative d-flex align-items-center group"> Connection Configuration <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="connection-configuration" aria-haspopup="dialog" aria-label="Share link: Connection Configuration"> Share link </button> </h3>The client uses a builder pattern for configuration: <div class="highlight"><pre tabindex="0" class="chroma"><code class="language-rust" data-lang="rust">let client = Client::new("127.0.0.1", 3141) // host and port .skip_verify(true) // Skip TLS verification (development only) .page_size(1000) // Results page size .client_name("my-app") // Client name for server logs .client_version("1.0.0") // Client version .conformance("min") // GQL conformance level .username("admin") // Authentication username .password("secret"); // Authentication password </code></pre></div> <h4 id="dsn-connection-string" class="position-relative d-flex align-items-center group"> DSN Connection String <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="dsn-connection-string" aria-haspopup="dialog" aria-label="Share link: DSN Connection String"> Share link </button> </h4>Create a client from a DSN (Data Source Name) string: <div class="highlight"><pre tabindex="0" class="chroma"><code class="language-rust" data-lang="rust">use geode_client::Client; // Simple DSN let client = Client::from_dsn("localhost:3141").unwrap(); // With options let client = Client::from_dsn("localhost:3141?insecure_tls_skip_verify=true&page_size=500").unwrap(); // URL format with authentication let client = Client::from_dsn("quic://admin:secret@localhost:3141?insecure_tls_skip_verify=true").unwrap(); </code></pre></div> <h4 id="dsn-options" class="position-relative d-flex align-items-center group"> DSN Options <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="dsn-options" aria-haspopup="dialog" aria-label="Share link: DSN Options"> Share link </button> </h4><table> <thead> <tr> <th>Option</th> <th>Aliases</th> <th>Default</th> <th>Description</th> </tr> </thead> <tbody> <tr> <td><code>page_size</code></td> <td></td> <td>1000</td> <td>Results page size</td> </tr> <tr> <td><code>hello_name</code></td> <td></td> <td>“geode-rust-quinn”</td> <td>Client name</td> </tr> <tr> <td><code>hello_ver</code></td> <td></td> <td>“0.1.0”</td> <td>Client version</td> </tr> <tr> <td><code>conformance</code></td> <td></td> <td>“min”</td> <td>GQL conformance level</td> </tr> <tr> <td><code>insecure_tls_skip_verify</code></td> <td></td> <td>false</td> <td>Skip TLS verification</td> </tr> <tr> <td><code>username</code></td> <td><code>user</code></td> <td></td> <td>Authentication username</td> </tr> <tr> <td><code>password</code></td> <td><code>pass</code></td> <td></td> <td>Authentication password</td> </tr> </tbody> </table> <h4 id="configuration-options" class="position-relative d-flex align-items-center group"> Configuration Options <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="configuration-options" aria-haspopup="dialog" aria-label="Share link: Configuration Options"> Share link </button> </h4><table> <thead> <tr> <th>Method</th> <th>Default</th> <th>Description</th> </tr> </thead> <tbody> <tr> <td><code>skip_verify(bool)</code></td> <td>false</td> <td>Skip TLS certificate verification (insecure)</td> </tr> <tr> <td><code>page_size(usize)</code></td> <td>1000</td> <td>Results page size</td> </tr> <tr> <td><code>client_name(String)</code></td> <td>“geode-rust”</td> <td>Client name sent to server</td> </tr> <tr> <td><code>client_version(String)</code></td> <td>“0.1.0”</td> <td>Client version</td> </tr> <tr> <td><code>conformance(String)</code></td> <td>“min”</td> <td>GQL conformance level</td> </tr> <tr> <td><code>username(String)</code></td> <td></td> <td>Authentication username (optional)</td> </tr> <tr> <td><code>password(String)</code></td> <td></td> <td>Authentication password (optional)</td> </tr> </tbody> </table> <h3 id="query-builders" class="position-relative d-flex align-items-center group"> Query Builders <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="query-builders" aria-haspopup="dialog" aria-label="Share link: Query Builders"> Share link </button> </h3> <h4 id="querybuilder" class="position-relative d-flex align-items-center group"> QueryBuilder <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="querybuilder" aria-haspopup="dialog" aria-label="Share link: QueryBuilder"> Share link </button> </h4>Build queries programmatically with type safety: <div class="highlight"><pre tabindex="0" class="chroma"><code class="language-rust" data-lang="rust">use geode_client::QueryBuilder; let (query, params) = QueryBuilder::new() .match_pattern("(p:Person {name: $name})-[:KNOWS]->(friend:Person)") .where_clause("friend.age > 25") .return_(&["friend.name AS name", "friend.age AS age"]) .order_by(&["friend.age DESC"]) .limit(10) .with_param("name", "Alice") .build(); let page = conn.query(&query, Some(params)).await?; </code></pre></div> <h4 id="patternbuilder" class="position-relative d-flex align-items-center group"> PatternBuilder <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="patternbuilder" aria-haspopup="dialog" aria-label="Share link: PatternBuilder"> Share link </button> </h4>Build graph patterns: <div class="highlight"><pre tabindex="0" class="chroma"><code class="language-rust" data-lang="rust">use geode_client::{PatternBuilder, EdgeDirection}; let pattern = PatternBuilder::new() .node("a", "Person") .edge("knows", "KNOWS", EdgeDirection::Undirected) .node("b", "Person") .build(); // Result: (a:Person)-[knows:KNOWS]-(b:Person) </code></pre></div> <h4 id="available-querybuilder-methods" class="position-relative d-flex align-items-center group"> Available QueryBuilder Methods <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="available-querybuilder-methods" aria-haspopup="dialog" aria-label="Share link: Available QueryBuilder Methods"> Share link </button> </h4><table> <thead> <tr> <th>Method</th> <th>Description</th> </tr> </thead> <tbody> <tr> <td><code>match_pattern(pattern)</code></td> <td>MATCH clause</td> </tr> <tr> <td><code>optional_match(pattern)</code></td> <td>OPTIONAL MATCH clause</td> </tr> <tr> <td><code>where_clause(condition)</code></td> <td>WHERE clause</td> </tr> <tr> <td><code>with(expressions)</code></td> <td>WITH clause</td> </tr> <tr> <td><code>return_(expressions)</code></td> <td>RETURN clause</td> </tr> <tr> <td><code>order_by(expressions)</code></td> <td>ORDER BY clause</td> </tr> <tr> <td><code>skip(n)</code></td> <td>SKIP clause</td> </tr> <tr> <td><code>limit(n)</code></td> <td>LIMIT clause</td> </tr> <tr> <td><code>create(pattern)</code></td> <td>CREATE clause</td> </tr> <tr> <td><code>merge(pattern)</code></td> <td>MERGE clause</td> </tr> <tr> <td><code>delete(expressions)</code></td> <td>DELETE clause</td> </tr> <tr> <td><code>set(assignments)</code></td> <td>SET clause</td> </tr> <tr> <td><code>with_param(name, value)</code></td> <td>Add parameter</td> </tr> </tbody> </table> <h3 id="transaction-management" class="position-relative d-flex align-items-center group"> Transaction Management <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="transaction-management" aria-haspopup="dialog" aria-label="Share link: Transaction Management"> Share link </button> </h3> <h4 id="basic-transactions" class="position-relative d-flex align-items-center group"> Basic Transactions <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="basic-transactions" aria-haspopup="dialog" aria-label="Share link: Basic Transactions"> Share link </button> </h4><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-rust" data-lang="rust">async fn transfer_funds( conn: &mut Connection, from: &str, to: &str, amount: f64 ) -> Result<()> { conn.begin().await?; let mut params = HashMap::new(); params.insert("from".to_string(), serde_json::json!(from)); params.insert("to".to_string(), serde_json::json!(to)); params.insert("amount".to_string(), serde_json::json!(amount)); // Debit from source match conn.query(r#" MATCH (a:Account {id: $from}) WHERE a.balance >= $amount SET a.balance = a.balance - $amount "#, Some(params.clone())).await { Ok(_) => {} Err(e) => { conn.rollback().await?; return Err(e); } } // Credit to destination match conn.query(r#" MATCH (a:Account {id: $to}) SET a.balance = a.balance + $amount "#, Some(params)).await { Ok(_) => conn.commit().await, Err(e) => { conn.rollback().await?; Err(e) } } } </code></pre></div> <h4 id="savepoints-partial-rollback" class="position-relative d-flex align-items-center group"> Savepoints (Partial Rollback) <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="savepoints-partial-rollback" aria-haspopup="dialog" aria-label="Share link: Savepoints (Partial Rollback)"> Share link </button> </h4><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-rust" data-lang="rust">async fn complex_operation(conn: &mut Connection) -> Result<()> { conn.begin().await?; // Create initial data conn.query("CREATE (p:Person {name: 'Alice', age: 30})", None).await?; // Create a savepoint let sp = conn.savepoint("before_update")?; // Make changes conn.query("MATCH (p:Person {name: 'Alice'}) SET p.age = 40", None).await?; // Rollback to savepoint (undoes the age change) conn.rollback_to(&sp).await?; // Alice's age is still 30 conn.commit().await?; Ok(()) } </code></pre></div> <h3 id="connection-pooling" class="position-relative d-flex align-items-center group"> Connection Pooling <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="connection-pooling" aria-haspopup="dialog" aria-label="Share link: Connection Pooling"> Share link </button> </h3>Use connection pooling for high-throughput workloads: <div class="highlight"><pre tabindex="0" class="chroma"><code class="language-rust" data-lang="rust">use geode_client::ConnectionPool; #[tokio::main] async fn main() -> Result<()> { // Create connection pool let pool = ConnectionPool::new("127.0.0.1", 3141, 10) .skip_verify(true) .page_size(1000); // Acquire connection from pool let conn = pool.acquire().await?; let page = conn.query("RETURN 1", None).await?; // Connection automatically returns to pool when dropped println!("Pool size: {}", pool.size().await); Ok(()) } </code></pre></div> <h4 id="concurrent-queries" class="position-relative d-flex align-items-center group"> Concurrent Queries <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="concurrent-queries" aria-haspopup="dialog" aria-label="Share link: Concurrent Queries"> Share link </button> </h4><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-rust" data-lang="rust">use tokio::task::JoinSet; async fn concurrent_queries(pool: &ConnectionPool) -> Result<()> { let mut set = JoinSet::new(); for i in 0..100 { let pool = pool.clone(); set.spawn(async move { let conn = pool.acquire().await?; let mut params = HashMap::new(); params.insert("id".to_string(), serde_json::json!(i)); conn.query("MATCH (p:Person {id: $id}) RETURN p", Some(params)).await }); } while let Some(result) = set.join_next().await { let page = result??; // Process result... } Ok(()) } </code></pre></div> <h3 id="prepared-statements" class="position-relative d-flex align-items-center group"> Prepared Statements <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="prepared-statements" aria-haspopup="dialog" aria-label="Share link: Prepared Statements"> Share link </button> </h3><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-rust" data-lang="rust">use geode_client::PreparedStatement; async fn batch_lookup(conn: &mut Connection, ids: &[i64]) -> Result<()> { // Create a prepared statement let stmt = conn.prepare("MATCH (p:Person {id: $id}) RETURN p.name, p.age")?; // Execute multiple times with different parameters for id in ids { let mut params = HashMap::new(); params.insert("id".to_string(), Value::int(*id)); let (page, _) = stmt.execute(conn, &params).await?; // Process results... } Ok(()) } </code></pre></div> <h3 id="query-explain-and-profile" class="position-relative d-flex align-items-center group"> Query Explain and Profile <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="query-explain-and-profile" aria-haspopup="dialog" aria-label="Share link: Query Explain and Profile"> Share link </button> </h3><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-rust" data-lang="rust">// Get the execution plan without running the query let plan = conn.explain("MATCH (p:Person)-[:KNOWS]->(f) RETURN f").await?; println!("Estimated rows: {}", plan.estimated_rows); for op in &plan.operations { println!(" {} - {}", op.op_type, op.description); } // Execute with profiling to get actual timing let profile = conn.profile("MATCH (p:Person) RETURN p LIMIT 100").await?; println!("Execution time: {:.2}ms", profile.execution_time_ms); println!("Actual rows: {}", profile.actual_rows); </code></pre></div> <h3 id="batch-queries" class="position-relative d-flex align-items-center group"> Batch Queries <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="batch-queries" aria-haspopup="dialog" aria-label="Share link: Batch Queries"> Share link </button> </h3><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-rust" data-lang="rust">// Execute multiple queries efficiently let results = conn.batch(&[ ("MATCH (n:Person) RETURN count(n)", None), ("MATCH (n:Company) RETURN count(n)", None), ("MATCH ()-[r:WORKS_AT]->() RETURN count(r)", None), ]).await?; for (i, page) in results.iter().enumerate() { println!("Query {}: {} rows", i + 1, page.rows.len()); } </code></pre></div> <h3 id="type-system" class="position-relative d-flex align-items-center group"> Type System <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="type-system" aria-haspopup="dialog" aria-label="Share link: Type System"> Share link </button> </h3>The client provides a rich type system supporting all GQL data types: <div class="highlight"><pre tabindex="0" class="chroma"><code class="language-rust" data-lang="rust">use geode_client::{Value, ValueKind}; let value = row.get("count").unwrap(); // Type-safe access with Result let int_val = value.as_int()?; let str_val = value.as_string()?; let bool_val = value.as_bool()?; let decimal_val = value.as_decimal()?; let array_val = value.as_array()?; let object_val = value.as_object()?; let date_val = value.as_date()?; let timestamp_val = value.as_timestamp()?; // Check value kind match value.kind { ValueKind::Null => println!("null value"), ValueKind::Int => println!("integer: {}", value.as_int()?), ValueKind::String => println!("string: {}", value.as_string()?), _ => println!("other type"), } // Create values programmatically let int_value = Value::int(42); let str_value = Value::string("hello"); let bool_value = Value::bool(true); let array_value = Value::array(vec![Value::int(1), Value::int(2)]); </code></pre></div> <h4 id="supported-types" class="position-relative d-flex align-items-center group"> Supported Types <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="supported-types" aria-haspopup="dialog" aria-label="Share link: Supported Types"> Share link </button> </h4><table> <thead> <tr> <th>Type</th> <th>Rust Type</th> <th>Description</th> </tr> </thead> <tbody> <tr> <td><code>Null</code></td> <td><code>()</code></td> <td>SQL NULL</td> </tr> <tr> <td><code>Int</code></td> <td><code>i64</code></td> <td>64-bit integer</td> </tr> <tr> <td><code>Bool</code></td> <td><code>bool</code></td> <td>Boolean</td> </tr> <tr> <td><code>String</code></td> <td><code>String</code></td> <td>UTF-8 string</td> </tr> <tr> <td><code>Decimal</code></td> <td><code>rust_decimal::Decimal</code></td> <td>Arbitrary precision decimal</td> </tr> <tr> <td><code>Array</code></td> <td><code>Vec<Value></code></td> <td>Ordered collection</td> </tr> <tr> <td><code>Object</code></td> <td><code>HashMap<String, Value></code></td> <td>Key-value map</td> </tr> <tr> <td><code>Date</code></td> <td><code>chrono::NaiveDate</code></td> <td>Calendar date</td> </tr> <tr> <td><code>Timestamp</code></td> <td><code>chrono::DateTime<Utc></code></td> <td>Date and time</td> </tr> <tr> <td><code>Bytea</code></td> <td><code>Vec<u8></code></td> <td>Binary data</td> </tr> </tbody> </table> <h3 id="error-handling" class="position-relative d-flex align-items-center group"> Error Handling <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="error-handling" aria-haspopup="dialog" aria-label="Share link: Error Handling"> Share link </button> </h3>The client provides comprehensive error types with retry support: <div class="highlight"><pre tabindex="0" class="chroma"><code class="language-rust" data-lang="rust">use geode_client::{Error, Result}; use std::time::Duration; async fn query_with_retry( conn: &mut Connection, query: &str ) -> Result<Page> { let mut attempts = 0; loop { match conn.query(query, None).await { Ok((page, _)) => return Ok(page), Err(e) if e.is_retryable() && attempts < 3 => { attempts += 1; tokio::time::sleep(Duration::from_millis(100 * attempts)).await; continue; } Err(e) => return Err(e), } } } </code></pre></div> <h4 id="error-types" class="position-relative d-flex align-items-center group"> Error Types <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="error-types" aria-haspopup="dialog" aria-label="Share link: Error Types"> Share link </button> </h4><table> <thead> <tr> <th>Error</th> <th>Retryable</th> <th>Description</th> </tr> </thead> <tbody> <tr> <td><code>Connection</code></td> <td>Yes</td> <td>Network/QUIC connection issues</td> </tr> <tr> <td><code>Query</code></td> <td>Conditional</td> <td>Query errors (40001, 40P01, 40502 are retryable)</td> </tr> <tr> <td><code>Timeout</code></td> <td>Yes</td> <td>Operation timed out</td> </tr> <tr> <td><code>Pool</code></td> <td>Yes</td> <td>Connection pool exhausted</td> </tr> <tr> <td><code>Auth</code></td> <td>No</td> <td>Authentication failure</td> </tr> <tr> <td><code>Tls</code></td> <td>No</td> <td>TLS/certificate errors</td> </tr> <tr> <td><code>Validation</code></td> <td>No</td> <td>Input validation failure</td> </tr> <tr> <td><code>Type</code></td> <td>No</td> <td>Type conversion errors</td> </tr> </tbody> </table> <h4 id="input-validation" class="position-relative d-flex align-items-center group"> Input Validation <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="input-validation" aria-haspopup="dialog" aria-label="Share link: Input Validation"> Share link </button> </h4><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-rust" data-lang="rust">use geode_client::validate; // Validate queries before sending validate::query("MATCH (n) RETURN n")?; // Validate parameter names validate::param_name("user_id")?; // Validate connection parameters validate::hostname("geode.example.com")?; validate::port(3141)?; validate::page_size(1000)?; </code></pre></div> <h3 id="performance" class="position-relative d-flex align-items-center group"> Performance <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="performance" aria-haspopup="dialog" aria-label="Share link: Performance"> Share link </button> </h3>The QUIC client provides: <ul> <li>Low latency: ~1-2ms per query (localhost)</li> <li>High throughput: 10,000+ queries/second with connection pooling</li> <li>Zero-cost abstractions: Minimal overhead from Rust’s type system</li> <li>Concurrent: Full async support for parallel queries</li> </ul> <h4 id="quic-system-optimizations" class="position-relative d-flex align-items-center group"> QUIC System Optimizations <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="quic-system-optimizations" aria-haspopup="dialog" aria-label="Share link: QUIC System Optimizations"> Share link </button> </h4>For optimal throughput, configure UDP buffer sizes at the OS level. Linux: <div class="highlight"><pre tabindex="0" class="chroma"><code class="language-bash" data-lang="bash">sudo sysctl -w net.core.rmem_max=7340032 sudo sysctl -w net.core.wmem_max=7340032 # Persist across reboots echo "net.core.rmem_max=7340032" | sudo tee -a /etc/sysctl.d/99-geode-quic.conf echo "net.core.wmem_max=7340032" | sudo tee -a /etc/sysctl.d/99-geode-quic.conf </code></pre></div>BSD/macOS: <div class="highlight"><pre tabindex="0" class="chroma"><code class="language-bash" data-lang="bash">sudo sysctl -w kern.ipc.maxsockbuf=8441037 </code></pre></div>GSO (Generic Segmentation Offload): Automatically enabled on Linux 4.18+ by quinn. Batches UDP packets to reduce syscall overhead. Path MTU Discovery (DPLPMTUD): Enabled by default in quinn, probes for optimal packet sizes. <h3 id="testing" class="position-relative d-flex align-items-center group"> Testing <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="testing" aria-haspopup="dialog" aria-label="Share link: Testing"> Share link </button> </h3><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-bash" data-lang="bash"># Build cargo build cargo build --release # Run tests cargo test # Unit tests (274 tests) cargo test --test proptest # Property-based tests (28 tests) cargo test --features integration # Integration tests (requires server) # Run benchmarks cargo bench # All benchmarks (59 benchmarks) cargo bench -- "query" # Filter by name # Run fuzzing (requires nightly) cargo +nightly fuzz run fuzz_value_from_json # Code quality cargo fmt # Format code cargo clippy # Lint (0 warnings) cargo doc --open # Generate documentation # Run examples cargo run --example basic cargo run --example advanced cargo run --example transactions </code></pre></div> <h4 id="test-categories" class="position-relative d-flex align-items-center group"> Test Categories <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="test-categories" aria-haspopup="dialog" aria-label="Share link: Test Categories"> Share link </button> </h4><table> <thead> <tr> <th>Test Type</th> <th>Count</th> <th>Command</th> </tr> </thead> <tbody> <tr> <td>Unit tests</td> <td>274</td> <td><code>cargo test</code></td> </tr> <tr> <td>Property tests</td> <td>28</td> <td><code>cargo test --test proptest</code></td> </tr> <tr> <td>Integration tests</td> <td>36</td> <td><code>cargo test --features integration</code></td> </tr> <tr> <td>Benchmarks</td> <td>59</td> <td><code>cargo bench</code></td> </tr> <tr> <td>Fuzz targets</td> <td>4</td> <td><code>cargo +nightly fuzz run <target></code></td> </tr> </tbody> </table> <h3 id="best-practices" class="position-relative d-flex align-items-center group"> Best Practices <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="best-practices" aria-haspopup="dialog" aria-label="Share link: Best Practices"> Share link </button> </h3> <h4 id="connection-management" class="position-relative d-flex align-items-center group"> Connection Management <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="connection-management" aria-haspopup="dialog" aria-label="Share link: Connection Management"> Share link </button> </h4><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-rust" data-lang="rust">// Good: Reuse connection pool across application static POOL: OnceCell<ConnectionPool> = OnceCell::new(); async fn get_pool() -> &'static ConnectionPool { POOL.get_or_init(|| { ConnectionPool::new("localhost", 3141, 20) .skip_verify(true) }) } // Good: Use connection from pool async fn query() -> Result<()> { let conn = get_pool().acquire().await?; // Connection returns to pool when dropped Ok(()) } </code></pre></div> <h4 id="error-handling-1" class="position-relative d-flex align-items-center group"> Error Handling <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="error-handling-1" aria-haspopup="dialog" aria-label="Share link: Error Handling"> Share link </button> </h4><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-rust" data-lang="rust">// Good: Use ? operator with proper error propagation async fn safe_query(conn: &Connection) -> Result<Vec<String>> { let page = conn.query("MATCH (p:Person) RETURN p.name", None).await?; page.rows.iter() .map(|row| row.get("name").unwrap().as_string()) .collect() } // Good: Handle retryable errors async fn resilient_query(conn: &Connection) -> Result<Page> { for attempt in 1..=3 { match conn.query("...", None).await { Ok((page, _)) => return Ok(page), Err(e) if e.is_retryable() => { eprintln!("Attempt {} failed, retrying...", attempt); tokio::time::sleep(Duration::from_millis(100)).await; } Err(e) => return Err(e), } } Err(Error::MaxRetriesExceeded) } </code></pre></div> <h3 id="related-topics" class="position-relative d-flex align-items-center group"> Related Topics <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="related-topics" aria-haspopup="dialog" aria-label="Share link: Related Topics"> Share link </button> </h3><ul> <li><a href="/tags/rust/" >Rust</a> </li> <li><a href="/tags/client-libraries/" >Client Libraries</a> </li> <li><a href="/tags/quic/" >QUIC Protocol</a> </li> <li><a href="/tags/tokio/" >Tokio</a> </li> <li><a href="/tags/connection-pooling/" >Connection Pooling</a> </li> <li><a href="/tags/transactions/" >Transactions</a> </li> <li><a href="/tags/performance/" >Performance</a> </li> </ul> <h3 id="further-reading" class="position-relative d-flex align-items-center group"> Further Reading <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="further-reading" aria-haspopup="dialog" aria-label="Share link: Further Reading"> Share link </button> </h3><ul> <li><a href="https://tokio.rs/" aria-label="Tokio Documentation – opens in new window" target="_blank" rel="noopener noreferrer" >Tokio Documentation ↗ </a> </li> <li><a href="https://github.com/quinn-rs/quinn" aria-label="Quinn QUIC Library – opens in new window" target="_blank" rel="noopener noreferrer" >Quinn QUIC Library ↗ </a> </li> <li><a href="https://www.iso.org/standard/76120.html" aria-label="ISO/IEC 39075:2024 GQL Standard – opens in new window" target="_blank" rel="noopener noreferrer" >ISO/IEC 39075:2024 GQL Standard ↗ </a> </li> <li><a href="https://crates.io/crates/geode-client" aria-label="Rust Client on crates.io – opens in new window" target="_blank" rel="noopener noreferrer" >Rust Client on crates.io ↗ </a> </li> <li><a href="https://gitlab.com/devnw/codepros/geode/geode-client-rust" aria-label="Rust Client Repository – opens in new window" target="_blank" rel="noopener noreferrer" >Rust Client Repository ↗ </a> </li> <li><a href="/docs/" >Geode Documentation</a> </li> </ul>

Popular

Related Articles