Struct BusCapture 

pub struct BusCapture { /* private fields */ }

Unified bus capture — WireTap implementation with three storage modes.

Wrap in Arc to share between client and test code:

Examples

use oms_modbus::*;
use std::sync::Arc;

let cap = Arc::new(BusCapture::unbounded());
let opts = ClientOptions::default().with_tap(cap.clone());

Implementations

impl BusCapture

pub fn stats_only() -> Self

Statistics only — no recording, atomic counters only. Zero memory allocation beyond the counters themselves.

pub fn unbounded() -> Self

Full recording — stores every record, never evicts.

pub fn bounded(capacity: usize) -> Self

Bounded ring buffer — oldest records evicted when full. Records are returned in chronological order by Self::drain and Self::snapshot.

capacity is clamped to a minimum of 1. Passing 0 is equivalent to passing 1 — a single-record buffer.

pub fn count_requests(&self) -> u64

pub fn count_responses(&self) -> u64

pub fn count_errors(&self) -> u64

pub fn dropped(&self) -> u64

pub fn reset_stats(&self)

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

pub fn drain(&self) -> Vec<PacketRecord>

Drain all records in chronological order. Stats are NOT reset.

pub fn snapshot(&self) -> Vec<PacketRecord>

Snapshot without clearing. Records are in chronological order.

Clones all records under the lock. For large capture buffers in hot paths, prefer Self::drain which swaps the buffer and releases the lock immediately.

Trait Implementations

impl WireTap for BusCapture

fn on_write(&self, bytes: &[u8], ts: u64)

Bytes successfully written to the transport. Called once per poll_write that returns Ok(n) with n > 0.

fn on_read(&self, bytes: &[u8], ts: u64)

Bytes successfully read from the transport. Called once per poll_read that returns Ready(Ok(())) with new data.

fn on_error(&self, bytes: &[u8], error: &str, ts: u64)

Read returned an error, but partial data may have been received. Called when poll_read returns Ready(Err(e)) and the read buffer contains bytes that arrived before the error.