Struct ManagedConnection 

pub struct ManagedConnection<T: Transport> { /* private fields */ }

连接管理器 - 封装重试、心跳、状态

Implementations

impl<T: Transport> ManagedConnection<T>

pub fn new(transport: Arc<T>) -> Self

pub async fn connect_with_retry(&self, addr: &str) -> Result<(), String>

带重试的连接（客户端用）

pub async fn send(&self, msg: Value) -> Result<(), String>

发送消息

pub async fn recv(&self) -> Result<Option<Value>, String>

接收消息

pub async fn start_heartbeat(&self) -> Result<(), String>

启动心跳（在独立 task 中运行）

pub async fn status(&self) -> ConnectionStatus

获取当前状态

pub async fn close(&self) -> Result<(), String>

关闭连接

Trait Implementations

impl<T: Transport> Clone for ManagedConnection<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.