Struct AsyncNode 

pub struct AsyncNode { /* private fields */ }

异步 VoltDB 连接节点

Implementations

impl AsyncNode

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

创建新的异步连接

pub fn get_sequence(&self) -> i64

获取下一个序列号

pub fn pending_count(&self) -> usize

获取当前待处理请求数 (用于负载均衡)

pub fn conn_info(&self) -> &ConnInfo

获取连接信息

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

列出所有存储过程

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

调用存储过程

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

带超时的存储过程调用

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

上传 JAR 文件

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

执行 Ad-Hoc SQL 查询

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

发送 Ping 保持连接

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

关闭连接

Trait Implementations

impl Debug for AsyncNode

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

Formats the value using the given formatter.