Struct FrameBatchingCoordinator

pub struct FrameBatchingCoordinator { /* private fields */ }

Frame batching coordinator for reduced packet overhead

Implementations

impl FrameBatchingCoordinator

pub fn new(config: FrameBatchingConfig) -> Self

Create a new frame batching coordinator

pub async fn start(&mut self) -> Result<(), Box<dyn Error + Send + Sync>>

Start the frame batching coordinator

pub async fn add_frame( &self, destination: SocketAddr, frame_type: u8, payload: Vec<u8>, priority: FramePriority, ) -> Result<Option<Vec<u8>>, Box<dyn Error + Send + Sync>>

Add frame to batch

pub async fn get_stats(&self) -> FrameBatchingStats

Get batching statistics

pub async fn shutdown(&mut self)

Shutdown the frame batching coordinator

Trait Implementations

impl Debug for FrameBatchingCoordinator

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

Formats the value using the given formatter.