Struct GrpcClient 

pub struct GrpcClient { /* private fields */ }

gRPC client for Geode.

Provides gRPC-based connection to the Geode database server using the tonic-generated service client.

Implementations

impl GrpcClient

pub async fn connect(dsn: &Dsn) -> Result<Self>

Connect to a Geode server using gRPC.

Arguments

• dsn - Parsed DSN with gRPC transport

Example

use geode_client::dsn::Dsn;
use geode_client::grpc::GrpcClient;

let dsn = Dsn::parse("grpc://localhost:50051")?;
let client = GrpcClient::connect(&dsn).await?;

pub async fn query(&mut self, gql: &str) -> Result<(Page, Option<String>)>

Execute a GQL query.

pub async fn query_with_params( &mut self, gql: &str, params: &HashMap<String, Value>, ) -> Result<(Page, Option<String>)>

Execute a GQL query with parameters.

pub async fn begin(&mut self) -> Result<()>

Begin a transaction.

pub async fn commit(&mut self) -> Result<()>

Commit a transaction.

pub async fn rollback(&mut self) -> Result<()>

Rollback a transaction.

pub async fn savepoint(&mut self, _name: &str) -> Result<()>

Create a savepoint within the current transaction.

Note: Savepoints are not yet supported via the gRPC service definition. This method will return an error until the gRPC service is updated.

pub async fn rollback_to(&mut self, _name: &str) -> Result<()>

Roll back to a previously created savepoint.

Note: Rollback-to-savepoint is not yet supported via the gRPC service definition. This method will return an error until the gRPC service is updated.

pub async fn ping(&mut self) -> Result<bool>

Send a ping request.

pub fn close(&mut self) -> Result<()>

Close the connection.