Struct TypeDBClient 

pub struct TypeDBClient { /* private fields */ }

Wrapper around the TypeDB Rust driver providing a clean async API for query execution and schema retrieval.

Implementations

impl TypeDBClient

pub async fn connect(config: &TypeDBSection) -> Result<Self, PipelineError>

Connect to a TypeDB server using the provided configuration.

pub async fn execute( &self, database: &str, typeql: &str, tx_type: &str, ) -> Result<Value, PipelineError>

Execute a TypeQL query and return results as JSON.

For read transactions, the transaction is used directly. For write and schema transactions, the transaction is committed after execution.

pub async fn database_exists( &self, database: &str, ) -> Result<bool, PipelineError>

Return whether a TypeDB database exists on the connected server.

pub async fn create_database(&self, database: &str) -> Result<(), PipelineError>

Create a TypeDB database.

pub async fn delete_database(&self, database: &str) -> Result<(), PipelineError>

Delete a TypeDB database.

pub async fn reset_database(&self, database: &str) -> Result<(), PipelineError>

Delete a TypeDB database if it exists, then create it.

pub fn is_connected(&self) -> bool

Check if the driver connection is open.

Trait Implementations

impl QueryExecutor for TypeDBClient

fn execute<'a>( &'a self, database: &'a str, typeql: &'a str, transaction_type: &'a str, ) -> Pin<Box<dyn Future<Output = Result<Value, PipelineError>> + Send + 'a>>

Execute a TypeQL string against the given database.

fn is_connected(&self) -> bool

Check if the backend connection is alive.