Struct MockTransport 

pub struct MockTransport { /* private fields */ }

Mock transport for testing.

Implementations

impl MockTransport

pub fn new() -> Self

Create a new mock transport with default config.

pub fn with_config(config: MockConfig) -> Self

Create a mock transport with custom config.

pub fn sent_events(&self) -> Vec<UdmEvent>

Get all sent events.

pub fn last_event(&self) -> Option<UdmEvent>

Get the last sent event.

pub fn event_count(&self) -> usize

Get count of sent events.

pub fn clear_events(&self)

Clear sent events.

pub fn set_config(&self, config: MockConfig)

Update the mock configuration.

pub fn set_failure_rate(&self, rate: f64)

Set failure rate.

pub fn set_latency(&self, latency_ms: u64)

Set latency.

Trait Implementations

impl Debug for MockTransport

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

Formats the value using the given formatter.

impl Default for MockTransport

fn default() -> Self

Returns the “default value” for a type.

impl Transport for MockTransport

fn send<'life0, 'life1, 'async_trait>( &'life0 self, event: &'life1 UdmEvent, ) -> Pin<Box<dyn Future<Output = PhyTraceResult<SendResult>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Send a single event.

fn send_batch<'life0, 'life1, 'async_trait>( &'life0 self, events: &'life1 [UdmEvent], ) -> Pin<Box<dyn Future<Output = PhyTraceResult<BatchResult>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Send a batch of events.

fn is_connected<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = bool> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Check if the transport is connected/ready.

fn connect<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = PhyTraceResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Connect to the remote endpoint.

fn disconnect<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = PhyTraceResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Disconnect from the remote endpoint.

fn stats(&self) -> TransportStats

Get transport statistics.

fn name(&self) -> &str

Get transport name for logging.