pub struct RatEngine { /* private fields */ }Expand description
高性能 RAT 引擎核心(空实现 - 所有功能通过 RatEngineBuilder 访问)
Implementations§
Source§impl RatEngine
impl RatEngine
Sourcepub fn builder() -> RatEngineBuilder
pub fn builder() -> RatEngineBuilder
创建 RatEngineBuilder(唯一的配置入口点)
Sourcepub fn config(&self) -> &EngineConfig
pub fn config(&self) -> &EngineConfig
获取引擎配置(通过 builder 访问)
Sourcepub fn get_metrics(&self) -> HashMap<String, u64>
pub fn get_metrics(&self) -> HashMap<String, u64>
获取性能指标(通过 builder 访问)
Sourcepub fn get_smart_transfer(&self) -> &Arc<SmartTransferManager>
pub fn get_smart_transfer(&self) -> &Arc<SmartTransferManager>
获取智能传输管理器(通过 builder 访问)
Sourcepub fn smart_transfer_data(&self, data: &[u8]) -> RatResult<TransferResult>
pub fn smart_transfer_data(&self, data: &[u8]) -> RatResult<TransferResult>
智能传输数据(通过 builder 访问)
Sourcepub fn get_transfer_stats(&self) -> PerformanceStats
pub fn get_transfer_stats(&self) -> PerformanceStats
获取智能传输性能统计(通过 builder 访问)
Sourcepub fn reset_transfer_stats(&self)
pub fn reset_transfer_stats(&self)
重置智能传输统计(通过 builder 访问)
Sourcepub async fn enable_congestion_control(
&self,
) -> Result<(), Box<dyn Error + Send + Sync>>
pub async fn enable_congestion_control( &self, ) -> Result<(), Box<dyn Error + Send + Sync>>
启用拥塞控制(通过 builder 访问)
Sourcepub async fn disable_congestion_control(
&self,
) -> Result<(), Box<dyn Error + Send + Sync>>
pub async fn disable_congestion_control( &self, ) -> Result<(), Box<dyn Error + Send + Sync>>
禁用拥塞控制(通过 builder 访问)
Sourcepub async fn switch_congestion_algorithm(
&self,
algorithm: &str,
) -> Result<(), Box<dyn Error + Send + Sync>>
pub async fn switch_congestion_algorithm( &self, algorithm: &str, ) -> Result<(), Box<dyn Error + Send + Sync>>
手动切换拥塞控制算法(通过 builder 访问)
Sourcepub async fn get_congestion_algorithm(&self) -> String
pub async fn get_congestion_algorithm(&self) -> String
获取当前拥塞控制算法(通过 builder 访问)
Sourcepub async fn get_congestion_stats(&self) -> HashMap<String, f64>
pub async fn get_congestion_stats(&self) -> HashMap<String, f64>
获取拥塞控制统计信息(通过 builder 访问)
Sourcepub async fn get_congestion_window(&self) -> u32
pub async fn get_congestion_window(&self) -> u32
获取拥塞控制窗口大小(通过 builder 访问)
Sourcepub async fn get_congestion_send_rate(&self) -> f64
pub async fn get_congestion_send_rate(&self) -> f64
获取拥塞控制发送速率(通过 builder 访问)
Sourcepub async fn on_packet_sent(&self, packet_size: u32)
pub async fn on_packet_sent(&self, packet_size: u32)
处理数据包发送事件(通过 builder 访问)
Sourcepub async fn on_packet_acked(&self, packet_size: u32, rtt: Duration)
pub async fn on_packet_acked(&self, packet_size: u32, rtt: Duration)
处理数据包确认事件(通过 builder 访问)
Sourcepub async fn on_packet_lost(&self, packet_size: u32)
pub async fn on_packet_lost(&self, packet_size: u32)
处理数据包丢失事件(通过 builder 访问)
Auto Trait Implementations§
impl Freeze for RatEngine
impl RefUnwindSafe for RatEngine
impl Send for RatEngine
impl Sync for RatEngine
impl Unpin for RatEngine
impl UnwindSafe for RatEngine
Blanket Implementations§
Source§impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
Source§impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
Source§impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
Source§impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more