Struct AsyncNode 

pub struct AsyncNode { /* private fields */ }

Async VoltDB connection node

Implementations

impl AsyncNode

pub async fn new(opt: NodeOpt) -> Result<AsyncNode, VoltError>

Create a new async connection to VoltDB server

pub fn get_sequence(&self) -> i64

Get the next sequence number for request tracking

pub fn pending_count(&self) -> usize

Get the current pending request count (used for load balancing)

pub fn conn_info(&self) -> &ConnInfo

Get connection info from authentication

pub async fn list_procedures(&self) -> Result<Receiver<VoltTable>, VoltError>

List all stored procedures available in the database

pub async fn call_sp( &self, query: &str, param: Vec<&dyn Value>, ) -> Result<Receiver<VoltTable>, VoltError>

Call a stored procedure with parameters

pub async fn call_sp_with_timeout( &self, query: &str, param: Vec<&dyn Value>, _timeout_duration: Duration, ) -> Result<Receiver<VoltTable>, VoltError>

Call a stored procedure with custom timeout

pub async fn upload_jar( &self, bs: Vec<u8>, ) -> Result<Receiver<VoltTable>, VoltError>

Upload a JAR file containing stored procedure classes

pub async fn query(&self, sql: &str) -> Result<Receiver<VoltTable>, VoltError>

Execute an ad-hoc SQL query

pub async fn ping(&self) -> Result<(), VoltError>

Send a ping to keep the connection alive

pub async fn shutdown(&self) -> Result<(), VoltError>

Shutdown the connection gracefully

Trait Implementations

impl Debug for AsyncNode

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Drop for AsyncNode

fn drop(&mut self)

Executes the destructor for this type.